Commit 26d4256b authored by 唐香港's avatar 唐香港

Update alarm_kafka_connect.py

parent 14c2bd36
...@@ -13,7 +13,7 @@ import airflow ...@@ -13,7 +13,7 @@ import airflow
#variable parameter #variable parameter
DAG_ID = 'alarm_kafka_connect' DAG_ID = 'alarm_kafka_connect'
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