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.

Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 check_cluster_status 2023-03-17T07:00:00+00:00 EmrJobFlowSensor 2023-03-17T08:00:54.134523+00:00 2023-03-17T08:10:56.061739+00:00 0:10:01.927216 354939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T08:00:51.787523+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T08:00:33.950978+00:00 2023-03-17T08:00:34.915842+00:00 0:00:00.964864 354937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T08:00:31.691370+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T07:00:00+00:00 PythonOperator 2023-03-17T08:00:12.359192+00:00 2023-03-17T08:00:16.482813+00:00 0:00:04.123621 354935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T08:00:09.651107+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T06:00:00+00:00 TriggerDagRunOperator 2023-03-17T07:38:01.818809+00:00 2023-03-17T07:38:02.364192+00:00 0:00:00.545383 354928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T07:37:59.035630+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T06:00:00+00:00 TriggerDagRunOperator 2023-03-17T07:38:01.808965+00:00 2023-03-17T07:38:02.480167+00:00 0:00:00.671202 354927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T07:37:59.035660+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T06:00:00+00:00 EmrJobFlowSensor 2023-03-17T07:25:07.406088+00:00 2023-03-17T07:35:09.286909+00:00 0:10:01.880821 354923 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T07:25:04.420500+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T07:24:46.723275+00:00 2023-03-17T07:24:47.707636+00:00 0:00:00.984361 354920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T07:24:44.355086+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T06:00:00+00:00 PythonOperator 2023-03-17T07:24:26.324091+00:00 2023-03-17T07:24:36.051848+00:00 0:00:09.727757 354917 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T07:24:22.331113+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T05:00:00+00:00 TriggerDagRunOperator 2023-03-17T06:26:20.827644+00:00 2023-03-17T06:26:21.420035+00:00 0:00:00.592391 354910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T06:26:18.229751+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T05:00:00+00:00 TriggerDagRunOperator 2023-03-17T06:26:20.840090+00:00 2023-03-17T06:26:21.518053+00:00 0:00:00.677963 354909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T06:26:18.229723+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T05:00:00+00:00 EmrJobFlowSensor 2023-03-17T06:16:12.258133+00:00 2023-03-17T06:26:14.115291+00:00 0:10:01.857158 354906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T06:16:09.908036+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T06:15:51.232135+00:00 2023-03-17T06:15:52.512558+00:00 0:00:01.280423 354903 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T06:15:47.855772+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T05:00:00+00:00 PythonOperator 2023-03-17T06:15:28.610589+00:00 2023-03-17T06:15:33.262813+00:00 0:00:04.652224 354900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T06:15:25.860689+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T04:00:00+00:00 TriggerDagRunOperator 2023-03-17T05:29:38.719211+00:00 2023-03-17T05:29:39.210198+00:00 0:00:00.490987 354891 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T05:29:35.764778+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T04:00:00+00:00 TriggerDagRunOperator 2023-03-17T05:29:38.703219+00:00 2023-03-17T05:29:39.305236+00:00 0:00:00.602017 354890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T05:29:35.764741+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T04:00:00+00:00 EmrJobFlowSensor 2023-03-17T05:05:26.379621+00:00 2023-03-17T05:15:28.658701+00:00 0:10:02.279080 354885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T05:05:22.335923+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T05:05:02.711966+00:00 2023-03-17T05:05:03.871392+00:00 0:00:01.159426 354882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T05:05:00.279187+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T04:00:00+00:00 PythonOperator 2023-03-17T05:04:40.546123+00:00 2023-03-17T05:04:44.613081+00:00 0:00:04.066958 354880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T05:04:38.258571+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T03:00:00+00:00 TriggerDagRunOperator 2023-03-17T04:12:01.999744+00:00 2023-03-17T04:12:02.604209+00:00 0:00:00.604465 354872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T04:11:59.265211+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T03:00:00+00:00 TriggerDagRunOperator 2023-03-17T04:12:01.960235+00:00 2023-03-17T04:12:02.456015+00:00 0:00:00.495780 354871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T04:11:59.265168+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T03:00:00+00:00 EmrJobFlowSensor 2023-03-17T04:01:36.206556+00:00 2023-03-17T04:11:38.190467+00:00 0:10:01.983911 354865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T04:01:33.715529+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T04:01:14.281590+00:00 2023-03-17T04:01:15.186784+00:00 0:00:00.905194 354862 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T04:01:11.670187+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T03:00:00+00:00 PythonOperator 2023-03-17T04:00:53.016494+00:00 2023-03-17T04:00:58.744992+00:00 0:00:05.728498 354860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T04:00:49.693016+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T02:00:00+00:00 TriggerDagRunOperator 2023-03-17T03:11:06.840302+00:00 2023-03-17T03:11:07.542934+00:00 0:00:00.702632 354850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T03:11:03.701972+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T02:00:00+00:00 TriggerDagRunOperator 2023-03-17T03:11:06.657802+00:00 2023-03-17T03:11:07.176315+00:00 0:00:00.518513 354849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T03:11:03.702016+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T02:00:00+00:00 EmrJobFlowSensor 2023-03-17T03:00:49.208024+00:00 2023-03-17T03:10:51.114931+00:00 0:10:01.906907 354841 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T03:00:46.825152+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T03:00:27.432463+00:00 2023-03-17T03:00:28.461323+00:00 0:00:01.028860 354839 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T03:00:24.791507+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T02:00:00+00:00 PythonOperator 2023-03-17T03:00:07.237590+00:00 2023-03-17T03:00:11.486640+00:00 0:00:04.249050 354837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T03:00:04.779973+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T01:00:00+00:00 TriggerDagRunOperator 2023-03-17T02:12:44.282799+00:00 2023-03-17T02:12:44.773622+00:00 0:00:00.490823 354830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T02:12:41.737332+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T01:00:00+00:00 TriggerDagRunOperator 2023-03-17T02:12:44.218227+00:00 2023-03-17T02:12:44.667589+00:00 0:00:00.449362 354829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T02:12:41.737302+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T01:00:00+00:00 EmrJobFlowSensor 2023-03-17T02:02:35.440124+00:00 2023-03-17T02:12:37.375376+00:00 0:10:01.935252 354823 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T02:02:32.257236+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T02:02:12.449582+00:00 2023-03-17T02:02:13.296883+00:00 0:00:00.847301 354821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T02:02:10.241758+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T01:00:00+00:00 PythonOperator 2023-03-17T02:00:21.087047+00:00 2023-03-17T02:00:25.063902+00:00 0:00:03.976855 354817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T02:00:18.598042+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T00:00:00+00:00 TriggerDagRunOperator 2023-03-17T01:11:04.352085+00:00 2023-03-17T01:11:04.917740+00:00 0:00:00.565655 354801 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T01:11:01.843951+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T00:00:00+00:00 TriggerDagRunOperator 2023-03-17T01:11:04.267306+00:00 2023-03-17T01:11:04.741500+00:00 0:00:00.474194 354800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T01:11:01.843990+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T00:00:00+00:00 EmrJobFlowSensor 2023-03-17T01:01:43.784734+00:00 2023-03-17T01:10:45.448343+00:00 0:09:01.663609 354792 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T01:01:40.546112+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T01:00:25.353732+00:00 2023-03-17T01:00:26.344618+00:00 0:00:00.990886 354790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T01:00:23.173611+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T00:00:00+00:00 PythonOperator 2023-03-17T01:00:05.458064+00:00 2023-03-17T01:00:09.485807+00:00 0:00:04.027743 354788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T01:00:03.153200+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T23:00:00+00:00 TriggerDagRunOperator 2023-03-17T00:10:38.374678+00:00 2023-03-17T00:10:38.844757+00:00 0:00:00.470079 354778 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T00:10:35.559362+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T23:00:00+00:00 TriggerDagRunOperator 2023-03-17T00:10:38.137082+00:00 2023-03-17T00:10:38.595284+00:00 0:00:00.458202 354777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T00:10:35.559404+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T23:00:00+00:00 EmrJobFlowSensor 2023-03-17T00:01:18.774425+00:00 2023-03-17T00:10:20.484190+00:00 0:09:01.709765 354770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T00:01:15.940421+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T00:00:30.272990+00:00 2023-03-17T00:00:31.212484+00:00 0:00:00.939494 354768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T00:00:27.758876+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T23:00:00+00:00 PythonOperator 2023-03-17T00:00:08.150722+00:00 2023-03-17T00:00:11.369252+00:00 0:00:03.218530 354765 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T00:00:05.728383+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T22:00:00+00:00 TriggerDagRunOperator 2023-03-16T23:11:53.303286+00:00 2023-03-16T23:11:53.801674+00:00 0:00:00.498388 354755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T23:11:50.783012+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T22:00:00+00:00 TriggerDagRunOperator 2023-03-16T23:11:53.245994+00:00 2023-03-16T23:11:53.696143+00:00 0:00:00.450149 354754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T23:11:50.783049+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T22:00:00+00:00 EmrJobFlowSensor 2023-03-16T23:01:35.536770+00:00 2023-03-16T23:11:37.415034+00:00 0:10:01.878264 354748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T23:01:33.322749+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T23:01:15.796458+00:00 2023-03-16T23:01:16.676683+00:00 0:00:00.880225 354746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T23:01:13.305425+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T22:00:00+00:00 PythonOperator 2023-03-16T23:00:19.735016+00:00 2023-03-16T23:00:23.652932+00:00 0:00:03.917916 354741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T23:00:16.733799+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T21:00:00+00:00 TriggerDagRunOperator 2023-03-16T22:11:46.646528+00:00 2023-03-16T22:11:47.132877+00:00 0:00:00.486349 354729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T22:11:44.185634+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T21:00:00+00:00 TriggerDagRunOperator 2023-03-16T22:11:46.589187+00:00 2023-03-16T22:11:47.061604+00:00 0:00:00.472417 354728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T22:11:44.185664+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T21:00:00+00:00 EmrJobFlowSensor 2023-03-16T22:01:23.940368+00:00 2023-03-16T22:11:25.790433+00:00 0:10:01.850065 354721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T22:01:21.714260+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T22:01:02.083767+00:00 2023-03-16T22:01:03.033268+00:00 0:00:00.949501 354719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T22:00:59.671191+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T21:00:00+00:00 PythonOperator 2023-03-16T22:00:17.835702+00:00 2023-03-16T22:00:21.336244+00:00 0:00:03.500542 354716 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T22:00:15.437712+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T20:00:00+00:00 TriggerDagRunOperator 2023-03-16T21:11:29.176491+00:00 2023-03-16T21:11:29.654330+00:00 0:00:00.477839 354706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T21:11:26.310823+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T20:00:00+00:00 TriggerDagRunOperator 2023-03-16T21:11:29.016235+00:00 2023-03-16T21:11:29.490316+00:00 0:00:00.474081 354705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T21:11:26.310852+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T20:00:00+00:00 EmrJobFlowSensor 2023-03-16T21:01:20.468704+00:00 2023-03-16T21:11:22.319492+00:00 0:10:01.850788 354698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T21:01:18.178306+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T21:00:59.099431+00:00 2023-03-16T21:00:59.966917+00:00 0:00:00.867486 354697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T21:00:56.010047+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T20:00:00+00:00 PythonOperator 2023-03-16T21:00:22.131265+00:00 2023-03-16T21:00:25.474648+00:00 0:00:03.343383 354694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T21:00:18.804667+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T19:00:00+00:00 TriggerDagRunOperator 2023-03-16T20:11:59.948272+00:00 2023-03-16T20:12:00.535891+00:00 0:00:00.587619 354683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T20:11:57.432128+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T19:00:00+00:00 TriggerDagRunOperator 2023-03-16T20:11:59.835631+00:00 2023-03-16T20:12:00.357494+00:00 0:00:00.521863 354682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T20:11:57.432156+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T19:00:00+00:00 EmrJobFlowSensor 2023-03-16T20:01:41.617976+00:00 2023-03-16T20:11:43.397984+00:00 0:10:01.780008 354676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T20:01:38.992407+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T20:01:19.149862+00:00 2023-03-16T20:01:19.987469+00:00 0:00:00.837607 354674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T20:01:16.970914+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T19:00:00+00:00 PythonOperator 2023-03-16T20:00:25.040137+00:00 2023-03-16T20:00:29.080679+00:00 0:00:04.040542 354671 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T20:00:22.832808+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T18:00:00+00:00 TriggerDagRunOperator 2023-03-16T19:11:37.464852+00:00 2023-03-16T19:11:37.925117+00:00 0:00:00.460265 354660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T19:11:34.706238+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T18:00:00+00:00 TriggerDagRunOperator 2023-03-16T19:11:37.318865+00:00 2023-03-16T19:11:37.800777+00:00 0:00:00.481912 354659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T19:11:34.706210+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T18:00:00+00:00 EmrJobFlowSensor 2023-03-16T19:01:15.739867+00:00 2023-03-16T19:11:17.461553+00:00 0:10:01.721686 354652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T19:01:13.503047+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T19:00:30.228859+00:00 2023-03-16T19:00:31.156501+00:00 0:00:00.927642 354649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T19:00:27.720386+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T18:00:00+00:00 PythonOperator 2023-03-16T19:00:08.190173+00:00 2023-03-16T19:00:11.553465+00:00 0:00:03.363292 354647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T19:00:05.657938+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T17:00:00+00:00 TriggerDagRunOperator 2023-03-16T18:12:06.504505+00:00 2023-03-16T18:12:07.064325+00:00 0:00:00.559820 354637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T18:12:04.118583+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T17:00:00+00:00 TriggerDagRunOperator 2023-03-16T18:12:06.446509+00:00 2023-03-16T18:12:07.037067+00:00 0:00:00.590558 354636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T18:12:04.118555+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T17:00:00+00:00 EmrJobFlowSensor 2023-03-16T18:01:48.955973+00:00 2023-03-16T18:11:50.724288+00:00 0:10:01.768315 354630 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T18:01:46.745186+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T18:01:28.919163+00:00 2023-03-16T18:01:29.774475+00:00 0:00:00.855312 354628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T18:01:26.724547+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T17:00:00+00:00 PythonOperator 2023-03-16T18:00:15.354230+00:00 2023-03-16T18:00:18.592044+00:00 0:00:03.237814 354624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T18:00:12.637764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T16:00:00+00:00 TriggerDagRunOperator 2023-03-16T17:12:15.840150+00:00 2023-03-16T17:12:16.370944+00:00 0:00:00.530794 354614 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T17:12:13.194542+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T16:00:00+00:00 TriggerDagRunOperator 2023-03-16T17:12:15.739366+00:00 2023-03-16T17:12:16.222770+00:00 0:00:00.483404 354613 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T17:12:13.194582+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T16:00:00+00:00 EmrJobFlowSensor 2023-03-16T17:02:00.343697+00:00 2023-03-16T17:12:02.283742+00:00 0:10:01.940045 354608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T17:01:57.835929+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T17:01:39.971176+00:00 2023-03-16T17:01:40.876968+00:00 0:00:00.905792 354606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T17:01:37.796156+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T16:00:00+00:00 PythonOperator 2023-03-16T17:00:20.973714+00:00 2023-03-16T17:00:24.451691+00:00 0:00:03.477977 354602 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T17:00:18.668016+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T15:00:00+00:00 TriggerDagRunOperator 2023-03-16T16:12:29.192310+00:00 2023-03-16T16:12:29.707632+00:00 0:00:00.515322 354590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T16:12:26.319048+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T15:00:00+00:00 TriggerDagRunOperator 2023-03-16T16:12:29.018254+00:00 2023-03-16T16:12:29.491290+00:00 0:00:00.473036 354589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T16:12:26.319083+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T15:00:00+00:00 EmrJobFlowSensor 2023-03-16T16:00:52.459573+00:00 2023-03-16T16:10:54.171872+00:00 0:10:01.712299 354585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T16:00:50.148917+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T16:00:28.834063+00:00 2023-03-16T16:00:29.715766+00:00 0:00:00.881703 354583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T16:00:26.292490+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T15:00:00+00:00 PythonOperator 2023-03-16T16:00:06.918213+00:00 2023-03-16T16:00:10.555126+00:00 0:00:03.636913 354581 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T16:00:04.187855+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T14:00:00+00:00 TriggerDagRunOperator 2023-03-16T15:12:35.473365+00:00 2023-03-16T15:12:36.056454+00:00 0:00:00.583089 354572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T15:12:32.690799+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T14:00:00+00:00 TriggerDagRunOperator 2023-03-16T15:12:35.233023+00:00 2023-03-16T15:12:35.706000+00:00 0:00:00.472977 354571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T15:12:32.690845+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T14:00:00+00:00 EmrJobFlowSensor 2023-03-16T15:02:13.432478+00:00 2023-03-16T15:12:15.212044+00:00 0:10:01.779566 354566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T15:02:10.939016+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T15:01:51.243856+00:00 2023-03-16T15:01:52.064151+00:00 0:00:00.820295 354564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T15:01:48.924369+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T14:00:00+00:00 PythonOperator 2023-03-16T15:00:24.815732+00:00 2023-03-16T15:00:27.909371+00:00 0:00:03.093639 354560 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T15:00:22.472236+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T13:00:00+00:00 TriggerDagRunOperator 2023-03-16T14:19:36.148218+00:00 2023-03-16T14:19:36.700341+00:00 0:00:00.552123 354549 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T14:19:30.714135+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T13:00:00+00:00 TriggerDagRunOperator 2023-03-16T14:19:33.429295+00:00 2023-03-16T14:19:33.872414+00:00 0:00:00.443119 354547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T14:19:30.714148+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T13:00:00+00:00 EmrJobFlowSensor 2023-03-16T14:01:03.390220+00:00 2023-03-16T14:11:05.232198+00:00 0:10:01.841978 354545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T14:01:01.148665+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T14:00:41.510366+00:00 2023-03-16T14:00:42.433760+00:00 0:00:00.923394 354543 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T14:00:39.139234+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T13:00:00+00:00 PythonOperator 2023-03-16T14:00:21.281218+00:00 2023-03-16T14:00:24.403457+00:00 0:00:03.122239 354541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T14:00:19.082941+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T12:00:00+00:00 TriggerDagRunOperator 2023-03-16T13:13:33.064308+00:00 2023-03-16T13:13:33.588002+00:00 0:00:00.523694 354530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T13:13:30.532759+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T12:00:00+00:00 TriggerDagRunOperator 2023-03-16T13:13:33.059238+00:00 2023-03-16T13:13:33.531327+00:00 0:00:00.472089 354529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T13:13:30.532731+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T12:00:00+00:00 EmrJobFlowSensor 2023-03-16T13:03:22.881264+00:00 2023-03-16T13:13:24.709067+00:00 0:10:01.827803 354523 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T13:03:20.727642+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T13:03:00.897557+00:00 2023-03-16T13:03:01.758936+00:00 0:00:00.861379 354521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T13:02:58.660449+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T12:00:00+00:00 PythonOperator 2023-03-16T13:02:38.834031+00:00 2023-03-16T13:02:41.919828+00:00 0:00:03.085797 354519 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T13:02:36.642113+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T11:00:00+00:00 TriggerDagRunOperator 2023-03-16T12:14:22.076927+00:00 2023-03-16T12:14:22.579261+00:00 0:00:00.502334 354508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T12:14:19.732109+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T11:00:00+00:00 TriggerDagRunOperator 2023-03-16T12:14:21.948032+00:00 2023-03-16T12:14:22.390599+00:00 0:00:00.442567 354507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T12:14:19.732077+00:00 2 default_pool