diff --git a/pycode_test/dag.py b/pycode_test/dag.py index 7fa0417..87190db 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-15T01:30:04.266013 by boundary-layer, version 1.7.16. +# This file was auto-generated at 2020-07-15T01:42:28.472374 by boundary-layer, version 1.7.16. # # DO NOT EDIT! # # The configuration that generated this DAG was: -# filename: /var/folders/q_/chp38t3s533bk603sckrr9hm0000gn/T/tmpziposrqb -# date: 2020-07-15T01:30:04.266013 +# filename: /var/folders/q_/chp38t3s533bk603sckrr9hm0000gn/T/tmprid8i1du +# date: 2020-07-15T01:42:28.472374 # md5: 7d9b02c3151e64bfbb7cb580a14605b3 # # The configuration contents are below: @@ -19,11 +19,11 @@ import re from airflow import DAG -import datetime -import airflow.contrib.kubernetes.secret import airflow.contrib.kubernetes.volume_mount -import airflow.contrib.kubernetes.volume +import airflow.contrib.kubernetes.secret import airflow.contrib.kubernetes.pod +import datetime +import airflow.contrib.kubernetes.volume from airflow.contrib.operators.kubernetes_pod_operator import KubernetesPodOperator @@ -46,22 +46,24 @@ } dag = DAG( - catchup=False, + schedule_interval="@daily", access_control={ "Report_Runner": ["can_dag_edit", "can_dag_read"], "Report_Viewer": ["can_dag_read"], }, - schedule_interval="@daily", + catchup=False, max_active_runs=1, dag_id="allianz_daily", default_args=DEFAULT_TASK_ARGS, ) allianz_daily = KubernetesPodOperator( - task_id="allianz_daily", - retry_delay=(datetime.timedelta(seconds=300)), 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)), secrets=[ ( airflow.contrib.kubernetes.secret.Secret( @@ -69,8 +71,6 @@ ) ) ], - start_date=(datetime.datetime(2020, 6, 23, 0, 0)), - dag=(dag), arguments=[ "--report-date={{ts}}", "--profile=env",