dagger auto commit dag-587d8e7cce4f5d9b115a008cae71b346f5ba81a3

pycode_test/dag.py

@@ -1,12 +1,12 @@
 # -*- coding: utf-8 -*-
 #
-# This file was auto-generated at 2020-07-15T08:48:02.819692 by boundary-layer, version 1.7.16.
+# This file was auto-generated at 2020-07-15T08:49:19.132171 by boundary-layer, version 1.7.16.
 #
 #                           DO NOT EDIT!
 #
 # The configuration that generated this DAG was:
-#   filename: /var/folders/q_/chp38t3s533bk603sckrr9hm0000gn/T/tmpwpyravvk
-#       date: 2020-07-15T08:48:02.819692
+#   filename: /var/folders/q_/chp38t3s533bk603sckrr9hm0000gn/T/tmpy8qy72t3
+#       date: 2020-07-15T08:49:19.132171
 #        md5: ce8e96a6825a70b086e4e64bba33ddae
 #
 # The configuration contents are below:
@@ -19,11 +19,11 @@
 import re
 from airflow import DAG
 
-import airflow.contrib.kubernetes.volume
+import airflow.contrib.kubernetes.secret
 import airflow.contrib.kubernetes.pod
-import airflow.contrib.kubernetes.volume_mount
 import datetime
-import airflow.contrib.kubernetes.secret
+import airflow.contrib.kubernetes.volume_mount
+import airflow.contrib.kubernetes.volume
 
 from airflow.contrib.operators.kubernetes_pod_operator import KubernetesPodOperator
 
@@ -46,8 +46,8 @@
 }
 
 dag = DAG(
-    schedule_interval='@daily',
     max_active_runs=1,
+    schedule_interval='@daily',
     catchup=False,
     access_control={'Report_Runner': [
         'can_dag_edit', 'can_dag_read'], 'Report_Viewer': ['can_dag_read']},
@@ -56,14 +56,14 @@
 )
 
 allianz_daily = KubernetesPodOperator(
+    name='allianz-daily',
+    retry_delay=(datetime.timedelta(seconds=300)),
     start_date=(datetime.datetime(2020, 6, 23, 0, 0)),
     cmds=['execute-report'],
-    retry_delay=(datetime.timedelta(seconds=300)),
     dag=(dag),
     arguments=['--report-date={{ts}}', '--profile=env', '--verbose',
                '--params-yaml={"report_name": "moneyhero-ob-allianz-daily", "report_group": "refapp", "target": {"name": "pp"}, "encoding": "csv", "notebook_params": {"datasource": "crm", "report_sql": "file://jobs/online_banking/allianz_daily/models/main.sql", "params": {"header": true, "partner": "Allianz HK", "country": "HKG", "names": ["Online Banking (Gift)"]}}}', 'sql-query-report'],
     secrets=[(airflow.contrib.kubernetes.secret.Secret(
         deploy_type='env', deploy_target='None', secret='reports'))],
     task_id='allianz_daily',
-    name='allianz-daily',
 )