Skip to content

A
airflow-dags-hub
Commit fcd30c36 authored by 唐香港's avatar 唐香港
Browse files
Options

Update alarm_flink_job.py

parent 0f9f05c8
Hide whitespace changes
Inline Side-by-side
Showing with 0 additions and 3 deletions
dags/flink/alarm_flink_job.py
View file @ fcd30c36
...@@ -142,6 +142,3 @@ for service in SERVICES: ...@@ -142,6 +142,3 @@ for service in SERVICES:
on_failure_callback=failure_callback, on_failure_callback=failure_callback,
dag=dag, dag=dag,
) )
if __name__ == '__main__':
dag.cli()
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