Update alarm_flink_job.py

dags/flink/alarm_flink_job.py

@@ -129,7 +129,7 @@ def get_jobs(cmd):
         raise Exception(msg)
     return jobs_dict
 
-def judge_job_status(job):
+def judge_job_status(job, cmd):
     if 'errors' in job:
         msg = "\n- **errors**: %s" % (job['errors'])
         logger.error(msg)