dagger auto commit dag-587d8e7cce4f5d9b115a008cae71b346f5ba81a3

onetonfoot · Jul 15, 2020 · acbd8c7 · acbd8c7
1 parent 7411770
commit acbd8c7
Showing 1 changed file with 16 additions and 16 deletions.
diff --git a/pycode_test/dag.py b/pycode_test/dag.py
@@ -1,12 +1,12 @@
 # -*- coding: utf-8 -*-
 #
-# This file was auto-generated at 2020-07-15T01:28:48.626148 by boundary-layer, version 1.7.16.
+# This file was auto-generated at 2020-07-15T01:30:04.266013 by boundary-layer, version 1.7.16.
 #
 #                           DO NOT EDIT!
 #
 # The configuration that generated this DAG was:
-#   filename: /var/folders/q_/chp38t3s533bk603sckrr9hm0000gn/T/tmp_iqtu0iq
-#       date: 2020-07-15T01:28:48.626148
+#   filename: /var/folders/q_/chp38t3s533bk603sckrr9hm0000gn/T/tmpziposrqb
+#       date: 2020-07-15T01:30:04.266013
 #        md5: 7d9b02c3151e64bfbb7cb580a14605b3
 #
 # The configuration contents are below:
@@ -19,11 +19,11 @@
 import re
 from airflow import DAG
 
-import airflow.contrib.kubernetes.volume
 import datetime
+import airflow.contrib.kubernetes.secret
 import airflow.contrib.kubernetes.volume_mount
+import airflow.contrib.kubernetes.volume
 import airflow.contrib.kubernetes.pod
-import airflow.contrib.kubernetes.secret
 
 from airflow.contrib.operators.kubernetes_pod_operator import KubernetesPodOperator
 
@@ -46,27 +46,22 @@
 }
 
 dag = DAG(
-    schedule_interval="@daily",
+    catchup=False,
     access_control={
         "Report_Runner": ["can_dag_edit", "can_dag_read"],
         "Report_Viewer": ["can_dag_read"],
     },
+    schedule_interval="@daily",
     max_active_runs=1,
-    catchup=False,
     dag_id="allianz_daily",
     default_args=DEFAULT_TASK_ARGS,
 )
 
 allianz_daily = KubernetesPodOperator(
     task_id="allianz_daily",
     retry_delay=(datetime.timedelta(seconds=300)),
-    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",
-    ],
+    name="allianz-daily",
+    cmds=["execute-report"],
     secrets=[
         (
             airflow.contrib.kubernetes.secret.Secret(
@@ -75,8 +70,13 @@
         )
     ],
     start_date=(datetime.datetime(2020, 6, 23, 0, 0)),
-    cmds=["execute-report"],
-    name="allianz-daily",
     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",
+    ],
 )