From acbd8c79c165fa7cdd50af0fb510f8204a94700d Mon Sep 17 00:00:00 2001 From: dom-zuhlke Date: Wed, 15 Jul 2020 09:30:06 +0800 Subject: [PATCH] dagger auto commit dag-587d8e7cce4f5d9b115a008cae71b346f5ba81a3 --- pycode_test/dag.py | 32 ++++++++++++++++---------------- 1 file changed, 16 insertions(+), 16 deletions(-) diff --git a/pycode_test/dag.py b/pycode_test/dag.py index 9b8d65a..7fa0417 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: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,13 +46,13 @@ } 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, ) @@ -60,13 +60,8 @@ 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", + ], )