From 59cbad067e21e99c3c56d6927cdf5b99c49256f9 Mon Sep 17 00:00:00 2001 From: dom-zuhlke Date: Wed, 15 Jul 2020 09:42:31 +0800 Subject: [PATCH] dagger auto commit dag-587d8e7cce4f5d9b115a008cae71b346f5ba81a3 --- pycode_test/dag.py | 24 ++++++++++++------------ 1 file changed, 12 insertions(+), 12 deletions(-) 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",