Merge pull request #198 from Shubha-accenture/composer-email-field-ty…

…pe-changes changing email retry, email failure, email success fields to boolean …
GoogleCloudDataproc · Dec 18, 2024 · 09e649a · 09e649a
2 parents 7b17aed + a508ca7
commit 09e649a
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/dataproc_jupyter_plugin/dagTemplates/pysparkBatchTemplate-v1.txt b/dataproc_jupyter_plugin/dagTemplates/pysparkBatchTemplate-v1.txt
@@ -27,9 +27,9 @@ default_args = {
     'retries': '{{retry_count}}',
     'retry_delay': timedelta(minutes=int('{{retry_delay}}')), 
     'email': {{email}}, 
-    'email_on_failure': '{{email_failure}}',     
-    'email_on_retry': '{{email_delay}}',      
-    'email_on_success':'{{email_success}}'
+    'email_on_failure': {{email_failure}},     
+    'email_on_retry': {{email_delay}},      
+    'email_on_success': {{email_success}}
 }
 
 def write_output_to_file(run_id, **kwargs):

diff --git a/dataproc_jupyter_plugin/dagTemplates/pysparkJobTemplate-v1.txt b/dataproc_jupyter_plugin/dagTemplates/pysparkJobTemplate-v1.txt
@@ -25,9 +25,9 @@ default_args = {
     'retries': '{{retry_count}}',
     'retry_delay': timedelta(minutes=int('{{retry_delay}}')), 
     'email': {{email}}, 
-    'email_on_failure': '{{email_failure}}',     
-    'email_on_retry': '{{email_delay}}',     
-    'email_on_success':'{{email_success}}'
+    'email_on_failure': {{email_failure}},     
+    'email_on_retry': {{email_delay}},     
+    'email_on_success': {{email_success}}
 }
 
 def write_output_to_file(run_id, **kwargs):