Update alarm_flink_job.py

d3b049be · 唐香港 · fcd30c36 · d3b049be
Commit d3b049be authored Aug 27, 2019 by 唐香港
Hide whitespace changes
Inline Side-by-side

Showing with 4 additions and 0 deletions

alarm_flink_job.py dags/flink/alarm_flink_job.py +4 -0

No files found.
--- a/dags/flink/alarm_flink_job.py
+++ b/dags/flink/alarm_flink_job.py
@@ -142,3 +142,6 @@ for service in SERVICES:
        on_failure_callback=failure_callback,
        dag=dag,
    )
+
+if __name__ == '__main__':
+    dag.cli()
\ No newline at end of file