Commit 1ae1756e authored by 唐香港's avatar 唐香港

Update alarm_kafka_connect_v2.py

parent 26d4256b
...@@ -13,7 +13,7 @@ import airflow ...@@ -13,7 +13,7 @@ import airflow
#variable parameter #variable parameter
DAG_ID = 'alarm_kafka_connect_v2' DAG_ID = 'alarm_kafka_connect_v2'
START_DATE = datetime.now() - timedelta(minutes=15) START_DATE = datetime.now() - timedelta(minutes=30)
SCHEDULE_INTERVAL = timedelta(minutes=15) SCHEDULE_INTERVAL = timedelta(minutes=15)
SERVICES = [ SERVICES = [
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment