The scheduler does not appear to be running. Last heartbeat was received .

The DAGs list may not update, and new tasks will not be scheduled.

Logs

Reset Filters
Id Dttm Dag Id Task Id Event Execution Date Owner Extra
2555774 09-17T14:35:52.925037+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 log 2021-05-10T08:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-10T08:00:00+00:00'), ('task_id', 'trigger_dagrun_campaign-history-job_v002')]
2555773 09-17T14:35:52.735383+00:00 campaign-flow-job_v002 graph 2021-05-17T13:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-17 13:00:00+00:00')]
2555766 09-17T14:35:51.837376+00:00 campaign-flow-job_v002 graph 2021-05-07T06:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-07 06:00:00+00:00')]
2555764 09-17T14:35:51.627705+00:00 campaign-flow-job_v002 create_emr_steps task 2021-05-10T11:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-10T11:00:00+00:00'), ('task_id', 'create_emr_steps')]
2555760 09-17T14:35:50.625529+00:00 campaign-flow-job_v002 create_cluster_and_add_emr_steps xcom 2021-04-24T15:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-24T15:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2555757 09-17T14:35:50.138273+00:00 campaign-flow-job_v002 create_emr_steps xcom 2021-04-26T00:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-26T00:00:00+00:00'), ('task_id', 'create_emr_steps')]
2555750 09-17T14:35:48.431400+00:00 campaign-flow-job_v002 graph 2021-05-08T11:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-08 11:00:00+00:00')]
2555748 09-17T14:35:48.332522+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 xcom 2021-04-26T00:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-26T00:00:00+00:00'), ('task_id', 'trigger_dagrun_booking-processing-job_v002')]
2555731 09-17T14:35:44.823908+00:00 campaign-flow-job_v002 create_cluster_and_add_emr_steps task 2021-05-10T23:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-10T23:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2555729 09-17T14:35:43.847213+00:00 campaign-flow-job_v002 graph 2021-05-15T09:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15 09:00:00+00:00'), ('run_id', 'scheduled__2021-05-15T09:00:00+00:00')]
2555725 09-17T14:35:43.338751+00:00 campaign-flow-job_v002 graph 2021-05-12T01:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-12 01:00:00+00:00')]
2555720 09-17T14:35:42.643490+00:00 campaign-flow-job_v002 create_cluster_and_add_emr_steps task 2021-05-10T06:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-10T06:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2555718 09-17T14:35:42.015024+00:00 campaign-flow-job_v002 graph 2021-05-14T09:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-14 09:00:00+00:00')]
2555711 09-17T14:35:40.432028+00:00 campaign-flow-job_v002 graph 2021-04-12T23:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-12T23:00:00+00:00'), ('root', 'trigger_dagrun_campaign-history-job_v002')]
2555710 09-17T14:35:40.309505+00:00 campaign-flow-job_v002 check_cluster_status task 2021-04-13T01:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-13T01:00:00+00:00'), ('task_id', 'check_cluster_status')]
2555708 09-17T14:35:40.308766+00:00 campaign-flow-job_v002 graph 2021-04-12T23:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-12T23:00:00+00:00'), ('root', 'create_emr_steps')]
2555679 09-17T14:35:33.691973+00:00 campaign-flow-job_v002 graph 2021-05-08T02:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-08 02:00:00+00:00')]
2555677 09-17T14:35:33.283825+00:00 campaign-flow-job_v002 graph 2021-05-06T23:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-06T23:00:00+00:00')]
2555674 09-17T14:35:32.933466+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 xcom 2021-04-25T23:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-25T23:00:00+00:00'), ('task_id', 'trigger_dagrun_campaign-history-job_v002')]
2555667 09-17T14:35:31.433878+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 task 2021-05-11T14:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-11T14:00:00+00:00'), ('task_id', 'trigger_dagrun_campaign-history-job_v002')]
2555662 09-17T14:35:31.004147+00:00 campaign-flow-job_v002 graph 2021-05-04T10:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-04T10:00:00+00:00')]
2555657 09-17T14:35:29.625326+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 task 2021-05-09T18:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-09T18:00:00+00:00'), ('task_id', 'trigger_dagrun_campaign-history-job_v002')]
2555656 09-17T14:35:29.624968+00:00 campaign-flow-job_v002 graph 2021-05-09T16:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-09T16:00:00+00:00'), ('root', 'trigger_dagrun_booking-processing-job_v002')]
2555655 09-17T14:35:29.624573+00:00 campaign-flow-job_v002 graph 2021-04-13T01:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-13T01:00:00+00:00'), ('root', 'trigger_dagrun_booking-processing-job_v002')]
2555652 09-17T14:35:28.839554+00:00 campaign-flow-job_v002 graph 2021-05-13T16:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-13 16:00:00+00:00'), ('run_id', 'scheduled__2021-05-13T16:00:00+00:00')]
2555651 09-17T14:35:28.746193+00:00 campaign-flow-job_v002 graph 2021-05-13T05:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-13 05:00:00+00:00'), ('run_id', 'scheduled__2021-05-13T05:00:00+00:00')]
2555639 09-17T14:35:27.370212+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 log 2021-05-11T02:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-11T02:00:00+00:00'), ('task_id', 'trigger_dagrun_campaign-history-job_v002')]
2555638 09-17T14:35:26.428666+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 log 2021-04-12T23:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-12T23:00:00+00:00'), ('task_id', 'trigger_dagrun_booking-processing-job_v002')]
2555636 09-17T14:35:26.258718+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 task 2021-04-13T02:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-13T02:00:00+00:00'), ('task_id', 'trigger_dagrun_campaign-history-job_v002')]
2555637 09-17T14:35:26.258559+00:00 campaign-flow-job_v002 check_cluster_status rendered 2021-04-19T02:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-19T02:00:00+00:00'), ('task_id', 'check_cluster_status')]
2555635 09-17T14:35:26.258255+00:00 campaign-flow-job_v002 check_cluster_status task 2021-04-12T23:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-12T23:00:00+00:00'), ('task_id', 'check_cluster_status')]
2555626 09-17T14:35:23.809658+00:00 campaign-flow-job_v002 graph 2021-05-10T01:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-10T01:00:00+00:00'), ('root', 'trigger_dagrun_booking-processing-job_v002')]
2555625 09-17T14:35:23.609364+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 log 2021-05-10T21:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-10T21:00:00+00:00'), ('task_id', 'trigger_dagrun_campaign-history-job_v002')]
2555620 09-17T14:35:22.277550+00:00 campaign-flow-job_v002 check_cluster_status log 2021-05-10T00:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-10T00:00:00+00:00'), ('task_id', 'check_cluster_status')]
2555618 09-17T14:35:22.277481+00:00 campaign-flow-job_v002 check_cluster_status log 2021-05-10T03:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-10T03:00:00+00:00'), ('task_id', 'check_cluster_status')]
2555617 09-17T14:35:22.017917+00:00 campaign-flow-job_v002 graph 2021-05-10T10:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-10 10:00:00+00:00')]
2555615 09-17T14:35:20.728325+00:00 campaign-flow-job_v002 check_cluster_status log 2021-05-10T10:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-10T10:00:00+00:00'), ('task_id', 'check_cluster_status')]
2555611 09-17T14:35:20.452563+00:00 campaign-flow-job_v002 graph 2021-05-10T11:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-10T11:00:00+00:00'), ('root', 'check_cluster_status')]
2555610 09-17T14:35:19.837500+00:00 campaign-flow-job_v002 graph 2021-05-05T15:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-05T15:00:00+00:00')]
2555601 09-17T14:35:18.379786+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 task 2021-05-15T04:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T04:00:00+00:00'), ('task_id', 'trigger_dagrun_booking-processing-job_v002')]
2555602 09-17T14:35:18.379081+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 log 2021-05-14T23:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-14T23:00:00+00:00'), ('task_id', 'trigger_dagrun_booking-processing-job_v002')]
2555595 09-17T14:35:16.723485+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 xcom 2021-04-19T01:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-19T01:00:00+00:00'), ('task_id', 'trigger_dagrun_campaign-history-job_v002')]
2555592 09-17T14:35:16.130331+00:00 campaign-flow-job_v002 check_cluster_status xcom 2021-04-24T00:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-24T00:00:00+00:00'), ('task_id', 'check_cluster_status')]
2555590 09-17T14:35:15.947513+00:00 campaign-flow-job_v002 graph 2021-05-15T11:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T11:00:00+00:00'), ('root', 'trigger_dagrun_booking-processing-job_v002')]
2555583 09-17T14:35:14.613970+00:00 campaign-flow-job_v002 graph 2021-05-17T20:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-17 20:00:00+00:00')]
2555578 09-17T14:35:13.135983+00:00 campaign-flow-job_v002 create_emr_steps task 2021-04-13T03:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-13T03:00:00+00:00'), ('task_id', 'create_emr_steps')]
2555570 09-17T14:35:08.661205+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 task 2021-05-15T11:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T11:00:00+00:00'), ('task_id', 'trigger_dagrun_booking-processing-job_v002')]
2555565 09-17T14:35:07.523221+00:00 campaign-flow-job_v002 create_emr_steps log 2021-04-13T07:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-13T07:00:00+00:00'), ('task_id', 'create_emr_steps')]
2555563 09-17T14:35:06.662333+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 task 2021-05-15T16:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T16:00:00+00:00'), ('task_id', 'trigger_dagrun_campaign-history-job_v002')]
2555559 09-17T14:35:05.532698+00:00 campaign-flow-job_v002 graph 2021-05-15T07:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15 07:00:00+00:00')]
2555549 09-17T14:35:02.377947+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 log 2021-05-15T14:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T14:00:00+00:00'), ('task_id', 'trigger_dagrun_campaign-history-job_v002')]
2555545 09-17T14:34:59.026654+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 rendered 2021-04-24T04:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-24T04:00:00+00:00'), ('task_id', 'trigger_dagrun_booking-processing-job_v002')]
2555541 09-17T14:34:58.832799+00:00 campaign-flow-job_v002 graph 2021-04-13T07:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-13T07:00:00+00:00'), ('root', 'trigger_dagrun_campaign-history-job_v002')]
2555535 09-17T14:34:57.811032+00:00 campaign-flow-job_v002 graph 2021-05-15T03:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T03:00:00+00:00'), ('root', 'check_cluster_status')]
2555532 09-17T14:34:56.841213+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 task 2021-05-15T04:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T04:00:00+00:00'), ('task_id', 'trigger_dagrun_campaign-history-job_v002')]
2555525 09-17T14:34:55.355149+00:00 campaign-flow-job_v002 graph 2021-05-15T13:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T13:00:00+00:00'), ('root', 'check_cluster_status')]
2555524 09-17T14:34:55.353802+00:00 campaign-flow-job_v002 graph 2021-05-15T13:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15 13:00:00+00:00')]
2555520 09-17T14:34:53.977839+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 xcom 2021-04-24T00:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-24T00:00:00+00:00'), ('task_id', 'trigger_dagrun_booking-processing-job_v002')]
2555516 09-17T14:34:53.029941+00:00 campaign-flow-job_v002 create_cluster_and_add_emr_steps task 2021-05-15T04:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T04:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2555509 09-17T14:34:51.442828+00:00 campaign-flow-job_v002 check_cluster_status log 2021-04-13T03:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-13T03:00:00+00:00'), ('task_id', 'check_cluster_status')]
2555490 09-17T14:34:48.747357+00:00 campaign-flow-job_v002 graph 2021-05-15T02:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T02:00:00+00:00'), ('root', 'check_cluster_status')]
2555482 09-17T14:34:45.825257+00:00 campaign-flow-job_v002 check_cluster_status log 2021-05-15T15:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T15:00:00+00:00'), ('task_id', 'check_cluster_status')]
2555472 09-17T14:34:44.561779+00:00 campaign-flow-job_v002 check_cluster_status log 2021-05-14T23:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-14T23:00:00+00:00'), ('task_id', 'check_cluster_status')]
2555460 09-17T14:34:40.652533+00:00 campaign-flow-job_v002 graph 2021-04-13T05:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-13T05:00:00+00:00'), ('root', 'check_cluster_status')]
2555453 09-17T14:34:39.236609+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 log 2021-05-14T22:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-14T22:00:00+00:00'), ('task_id', 'trigger_dagrun_campaign-history-job_v002')]
2555447 09-17T14:34:36.854397+00:00 campaign-flow-job_v002 graph 2021-05-15T15:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T15:00:00+00:00'), ('root', 'create_emr_steps')]
2555440 09-17T14:34:33.165342+00:00 campaign-flow-job_v002 create_cluster_and_add_emr_steps task 2021-05-15T15:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T15:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2555433 09-17T14:34:31.596029+00:00 campaign-flow-job_v002 create_emr_steps task 2021-05-14T23:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-14T23:00:00+00:00'), ('task_id', 'create_emr_steps')]
2555431 09-17T14:34:31.061572+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 task 2021-04-13T09:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-13T09:00:00+00:00'), ('task_id', 'trigger_dagrun_booking-processing-job_v002')]
2555410 09-17T14:34:26.395362+00:00 campaign-flow-job_v002 graph 2021-05-15T08:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T08:00:00+00:00'), ('root', 'trigger_dagrun_booking-processing-job_v002')]
2555405 09-17T14:34:24.673178+00:00 campaign-flow-job_v002 create_emr_steps log 2021-05-15T12:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T12:00:00+00:00'), ('task_id', 'create_emr_steps')]
2555402 09-17T14:34:24.672776+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 log 2021-05-15T09:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T09:00:00+00:00'), ('task_id', 'trigger_dagrun_booking-processing-job_v002')]
2555401 09-17T14:34:24.506736+00:00 campaign-flow-job_v002 create_emr_steps log 2021-04-13T04:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-13T04:00:00+00:00'), ('task_id', 'create_emr_steps')]
2555400 09-17T14:34:24.481069+00:00 campaign-flow-job_v002 check_cluster_status task 2021-05-15T14:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T14:00:00+00:00'), ('task_id', 'check_cluster_status')]
2555387 09-17T14:34:18.174891+00:00 campaign-flow-job_v002 create_cluster_and_add_emr_steps xcom 2021-04-24T05:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-24T05:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2555372 09-17T14:34:12.225524+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 xcom 2021-04-24T00:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-24T00:00:00+00:00'), ('task_id', 'trigger_dagrun_campaign-history-job_v002')]
2555362 09-17T14:34:09.344741+00:00 campaign-flow-job_v002 check_cluster_status log 2021-05-15T16:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T16:00:00+00:00'), ('task_id', 'check_cluster_status')]
2555354 09-17T14:34:08.065481+00:00 campaign-flow-job_v002 create_emr_steps log 2021-05-15T09:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T09:00:00+00:00'), ('task_id', 'create_emr_steps')]
2555352 09-17T14:34:08.064023+00:00 campaign-flow-job_v002 create_emr_steps task 2021-05-15T06:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T06:00:00+00:00'), ('task_id', 'create_emr_steps')]
2555343 09-17T14:34:04.631898+00:00 campaign-flow-job_v002 create_cluster_and_add_emr_steps log 2021-05-15T17:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T17:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2555328 09-17T14:33:57.439514+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 task 2021-05-15T13:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T13:00:00+00:00'), ('task_id', 'trigger_dagrun_booking-processing-job_v002')]
2555325 09-17T14:33:57.374319+00:00 campaign-flow-job_v002 create_cluster_and_add_emr_steps task 2021-05-15T05:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T05:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2555324 09-17T14:33:57.374257+00:00 campaign-flow-job_v002 check_cluster_status task 2021-05-15T03:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T03:00:00+00:00'), ('task_id', 'check_cluster_status')]
2555311 09-17T14:33:53.439911+00:00 campaign-flow-job_v002 graph 2021-05-15T12:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T12:00:00+00:00'), ('root', 'create_cluster_and_add_emr_steps')]
2555310 09-17T14:33:53.429748+00:00 campaign-flow-job_v002 create_cluster_and_add_emr_steps log 2021-05-15T09:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T09:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2555309 09-17T14:33:53.429721+00:00 campaign-flow-job_v002 create_cluster_and_add_emr_steps log 2021-05-15T12:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T12:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2555294 09-17T14:33:49.694054+00:00 campaign-flow-job_v002 check_cluster_status task 2021-04-13T07:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-13T07:00:00+00:00'), ('task_id', 'check_cluster_status')]
2555291 09-17T14:33:48.803351+00:00 campaign-flow-job_v002 graph 2021-05-15T03:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T03:00:00+00:00'), ('root', 'trigger_dagrun_booking-processing-job_v002')]
2555285 09-17T14:33:46.955608+00:00 campaign-flow-job_v002 graph 2021-05-15T04:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T04:00:00+00:00'), ('root', 'trigger_dagrun_booking-processing-job_v002')]
2555284 09-17T14:33:46.954581+00:00 campaign-flow-job_v002 create_cluster_and_add_emr_steps log 2021-05-15T00:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T00:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2555281 09-17T14:33:45.602879+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 task 2021-04-13T06:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-13T06:00:00+00:00'), ('task_id', 'trigger_dagrun_booking-processing-job_v002')]
2555277 09-17T14:33:44.292864+00:00 campaign-flow-job_v002 graph 2021-04-13T08:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-13T08:00:00+00:00'), ('root', 'create_cluster_and_add_emr_steps')]
2555265 09-17T14:33:41.445131+00:00 campaign-flow-job_v002 create_emr_steps xcom 2021-04-24T04:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-24T04:00:00+00:00'), ('task_id', 'create_emr_steps')]
2555264 09-17T14:33:41.248775+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 task 2021-05-15T02:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T02:00:00+00:00'), ('task_id', 'trigger_dagrun_booking-processing-job_v002')]
2555262 09-17T14:33:40.588489+00:00 campaign-flow-job_v002 graph 2021-05-15T14:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T14:00:00+00:00'), ('root', 'check_cluster_status')]
2555260 09-17T14:33:40.587346+00:00 campaign-flow-job_v002 graph 2021-05-15T17:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15 17:00:00+00:00')]
2555250 09-17T14:33:37.376208+00:00 campaign-flow-job_v002 graph 2021-05-15T04:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T04:00:00+00:00'), ('root', 'check_cluster_status')]
2555246 09-17T14:33:35.757490+00:00 campaign-flow-job_v002 graph 2021-05-15T01:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-05-15T01:00:00+00:00'), ('root', 'trigger_dagrun_campaign-history-job_v002')]
2555235 09-17T14:33:32.523888+00:00 campaign-flow-job_v002 graph 2021-04-13T03:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-13T03:00:00+00:00'), ('root', 'create_emr_steps')]
2555234 09-17T14:33:32.438306+00:00 campaign-flow-job_v002 create_emr_steps xcom 2021-04-24T02:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2021-04-24T02:00:00+00:00'), ('task_id', 'create_emr_steps')]