diff --git a/pycode_test/dag.py b/pycode_test/dag.py index d89c067..6b608fe 100644 --- 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-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', )