dagger auto commit dag-587d8e7cce4f5d9b115a008cae71b346f5ba81a3

pycode_test/dag.py

@@ -1,12 +1,12 @@
 # -*- coding: utf-8 -*-
 #
-# This file was auto-generated at 2020-07-15T01:42:28.472374 by boundary-layer, version 1.7.16.
+# This file was auto-generated at 2020-07-15T03:17:01.081855 by boundary-layer, version 1.7.16.
 #
 #                           DO NOT EDIT!
 #
 # The configuration that generated this DAG was:
-#   filename: /var/folders/q_/chp38t3s533bk603sckrr9hm0000gn/T/tmprid8i1du
-#       date: 2020-07-15T01:42:28.472374
+#   filename: /var/folders/q_/chp38t3s533bk603sckrr9hm0000gn/T/tmpiphbqiqf
+#       date: 2020-07-15T03:17:01.081855
 #        md5: 7d9b02c3151e64bfbb7cb580a14605b3
 #
 # The configuration contents are below:
@@ -19,11 +19,11 @@
 import re
 from airflow import DAG
 
-import airflow.contrib.kubernetes.volume_mount
-import airflow.contrib.kubernetes.secret
+import airflow.contrib.kubernetes.volume
 import airflow.contrib.kubernetes.pod
 import datetime
-import airflow.contrib.kubernetes.volume
+import airflow.contrib.kubernetes.secret
+import airflow.contrib.kubernetes.volume_mount
 
 from airflow.contrib.operators.kubernetes_pod_operator import KubernetesPodOperator
 
@@ -46,37 +46,37 @@
 }
 
 dag = DAG(
-    schedule_interval="@daily",
+    catchup=False,
     access_control={
         "Report_Runner": ["can_dag_edit", "can_dag_read"],
         "Report_Viewer": ["can_dag_read"],
     },
-    catchup=False,
     max_active_runs=1,
+    schedule_interval="@daily",
     dag_id="allianz_daily",
     default_args=DEFAULT_TASK_ARGS,
 )
 
 allianz_daily = KubernetesPodOperator(
-    name="allianz-daily",
     start_date=(datetime.datetime(2020, 6, 23, 0, 0)),
-    task_id="allianz_daily",
-    cmds=["execute-report"],
-    dag=(dag),
-    retry_delay=(datetime.timedelta(seconds=300)),
+    name="allianz-daily",
     secrets=[
         (
             airflow.contrib.kubernetes.secret.Secret(
                 deploy_type="env", deploy_target="None", secret="reports"
             )
         )
     ],
+    dag=(dag),
+    cmds=["execute-report"],
+    task_id="allianz_daily",
     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",
     ],
+    retry_delay=(datetime.timedelta(seconds=300)),
 )