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 create_cluster_and_add_emr_steps 2023-05-27T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T11:01:55.963403+00:00 2023-05-27T11:01:56.995226+00:00 0:00:01.031823 386672 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T11:01:53.734395+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T10:00:00+00:00 PythonOperator 2023-05-27T11:01:36.091862+00:00 2023-05-27T11:01:37.028763+00:00 0:00:00.936901 386670 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T11:01:33.718106+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T09:00:00+00:00 TriggerDagRunOperator 2023-05-27T10:11:02.734270+00:00 2023-05-27T10:11:03.182735+00:00 0:00:00.448465 386659 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T10:11:00.304847+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T09:00:00+00:00 TriggerDagRunOperator 2023-05-27T10:11:02.623289+00:00 2023-05-27T10:11:03.052418+00:00 0:00:00.429129 386658 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T10:11:00.304891+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T09:00:00+00:00 EmrJobFlowSensor 2023-05-27T10:00:48.490496+00:00 2023-05-27T10:10:50.301902+00:00 0:10:01.811406 386650 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T10:00:46.490413+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T10:00:26.449686+00:00 2023-05-27T10:00:27.371129+00:00 0:00:00.921443 386648 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T10:00:24.467712+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T09:00:00+00:00 PythonOperator 2023-05-27T10:00:06.511677+00:00 2023-05-27T10:00:07.358750+00:00 0:00:00.847073 386646 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T10:00:04.448906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T08:00:00+00:00 TriggerDagRunOperator 2023-05-27T09:10:54.449988+00:00 2023-05-27T09:10:54.908794+00:00 0:00:00.458806 386636 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T09:10:52.305349+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T08:00:00+00:00 TriggerDagRunOperator 2023-05-27T09:10:54.282482+00:00 2023-05-27T09:10:54.736670+00:00 0:00:00.454188 386635 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T09:10:52.305315+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T08:00:00+00:00 EmrJobFlowSensor 2023-05-27T09:00:47.047680+00:00 2023-05-27T09:10:48.808036+00:00 0:10:01.760356 386628 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T09:00:44.946121+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T09:00:27.020761+00:00 2023-05-27T09:00:27.973933+00:00 0:00:00.953172 386626 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T09:00:24.924682+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T08:00:00+00:00 PythonOperator 2023-05-27T09:00:05.163989+00:00 2023-05-27T09:00:06.085436+00:00 0:00:00.921447 386624 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T09:00:02.899016+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T07:00:00+00:00 TriggerDagRunOperator 2023-05-27T08:16:54.402257+00:00 2023-05-27T08:16:54.854625+00:00 0:00:00.452368 386617 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T08:16:52.073362+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T07:00:00+00:00 TriggerDagRunOperator 2023-05-27T08:16:54.415680+00:00 2023-05-27T08:16:54.889052+00:00 0:00:00.473372 386616 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T08:16:52.073335+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T07:00:00+00:00 EmrJobFlowSensor 2023-05-27T08:01:24.437045+00:00 2023-05-27T08:11:26.277766+00:00 0:10:01.840721 386610 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T08:01:22.393798+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T08:01:02.726401+00:00 2023-05-27T08:01:03.744874+00:00 0:00:01.018473 386608 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T08:01:00.427965+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T07:00:00+00:00 PythonOperator 2023-05-27T08:00:10.610610+00:00 2023-05-27T08:00:11.632158+00:00 0:00:01.021548 386605 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T08:00:08.506860+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T06:00:00+00:00 TriggerDagRunOperator 2023-05-27T07:26:48.472107+00:00 2023-05-27T07:26:48.990524+00:00 0:00:00.518417 386597 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T07:26:46.009213+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T06:00:00+00:00 TriggerDagRunOperator 2023-05-27T07:26:48.398538+00:00 2023-05-27T07:26:48.890091+00:00 0:00:00.491553 386596 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T07:26:46.009245+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T06:00:00+00:00 EmrJobFlowSensor 2023-05-27T07:13:51.885041+00:00 2023-05-27T07:23:53.602729+00:00 0:10:01.717688 386591 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T07:13:49.852415+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T07:13:31.824634+00:00 2023-05-27T07:13:32.716823+00:00 0:00:00.892189 386589 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T07:13:29.841950+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T06:00:00+00:00 PythonOperator 2023-05-27T07:13:10.308309+00:00 2023-05-27T07:13:11.238914+00:00 0:00:00.930605 386586 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T07:13:07.870036+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T05:00:00+00:00 TriggerDagRunOperator 2023-05-27T06:18:29.974221+00:00 2023-05-27T06:18:30.598897+00:00 0:00:00.624676 386577 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T06:18:27.638187+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T05:00:00+00:00 TriggerDagRunOperator 2023-05-27T06:18:29.913723+00:00 2023-05-27T06:18:30.504987+00:00 0:00:00.591264 386576 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T06:18:27.638215+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T05:00:00+00:00 EmrJobFlowSensor 2023-05-27T06:08:10.759866+00:00 2023-05-27T06:18:12.578900+00:00 0:10:01.819034 386571 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T06:08:08.727662+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T06:07:50.737018+00:00 2023-05-27T06:07:51.697128+00:00 0:00:00.960110 386568 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T06:07:48.708657+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T05:00:00+00:00 PythonOperator 2023-05-27T06:07:29.059957+00:00 2023-05-27T06:07:29.961581+00:00 0:00:00.901624 386565 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T06:07:26.691162+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T04:00:00+00:00 TriggerDagRunOperator 2023-05-27T05:17:16.620715+00:00 2023-05-27T05:17:17.094456+00:00 0:00:00.473741 386557 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T05:17:14.376383+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T04:00:00+00:00 TriggerDagRunOperator 2023-05-27T05:17:16.532997+00:00 2023-05-27T05:17:16.946264+00:00 0:00:00.413267 386556 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T05:17:14.376355+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T04:00:00+00:00 EmrJobFlowSensor 2023-05-27T05:06:55.472358+00:00 2023-05-27T05:16:57.304278+00:00 0:10:01.831920 386553 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T05:06:53.517398+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T05:06:33.551195+00:00 2023-05-27T05:06:34.581239+00:00 0:00:01.030044 386549 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T05:06:31.483547+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T04:00:00+00:00 PythonOperator 2023-05-27T05:06:13.665062+00:00 2023-05-27T05:06:14.552900+00:00 0:00:00.887838 386547 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T05:06:11.463578+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T03:00:00+00:00 TriggerDagRunOperator 2023-05-27T04:11:07.813039+00:00 2023-05-27T04:11:08.252863+00:00 0:00:00.439824 386534 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T04:11:05.440633+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T03:00:00+00:00 TriggerDagRunOperator 2023-05-27T04:11:07.687881+00:00 2023-05-27T04:11:08.092260+00:00 0:00:00.404379 386533 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T04:11:05.440661+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T03:00:00+00:00 EmrJobFlowSensor 2023-05-27T04:00:55.333076+00:00 2023-05-27T04:10:57.321802+00:00 0:10:01.988726 386526 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T04:00:53.348700+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T04:00:35.332663+00:00 2023-05-27T04:00:36.231425+00:00 0:00:00.898762 386524 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T04:00:33.335267+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T03:00:00+00:00 PythonOperator 2023-05-27T04:00:13.380949+00:00 2023-05-27T04:00:14.217618+00:00 0:00:00.836669 386522 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T04:00:11.308153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T02:00:00+00:00 TriggerDagRunOperator 2023-05-27T03:11:09.595983+00:00 2023-05-27T03:11:10.074163+00:00 0:00:00.478180 386514 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T03:11:07.331366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T02:00:00+00:00 TriggerDagRunOperator 2023-05-27T03:11:09.530711+00:00 2023-05-27T03:11:10.007575+00:00 0:00:00.476864 386513 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T03:11:07.331338+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T02:00:00+00:00 EmrJobFlowSensor 2023-05-27T03:00:58.907971+00:00 2023-05-27T03:11:00.608938+00:00 0:10:01.700967 386505 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T03:00:56.965605+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T03:00:38.923929+00:00 2023-05-27T03:00:39.855404+00:00 0:00:00.931475 386503 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T03:00:36.944527+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T02:00:00+00:00 PythonOperator 2023-05-27T03:00:17.454824+00:00 2023-05-27T03:00:18.372929+00:00 0:00:00.918105 386501 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T03:00:14.987487+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T01:00:00+00:00 TriggerDagRunOperator 2023-05-27T02:11:29.781497+00:00 2023-05-27T02:11:30.433989+00:00 0:00:00.652492 386491 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T02:11:27.403662+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T01:00:00+00:00 TriggerDagRunOperator 2023-05-27T02:11:29.757140+00:00 2023-05-27T02:11:30.412544+00:00 0:00:00.655404 386490 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T02:11:27.403634+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T01:00:00+00:00 EmrJobFlowSensor 2023-05-27T02:01:08.162338+00:00 2023-05-27T02:11:10.368648+00:00 0:10:02.206310 386483 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T02:01:06.078607+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T02:00:46.181195+00:00 2023-05-27T02:00:47.054197+00:00 0:00:00.873002 386481 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T02:00:44.057110+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T01:00:00+00:00 PythonOperator 2023-05-27T02:00:24.050950+00:00 2023-05-27T02:00:24.942413+00:00 0:00:00.891463 386479 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T02:00:22.036018+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T00:00:00+00:00 TriggerDagRunOperator 2023-05-27T01:11:21.050255+00:00 2023-05-27T01:11:21.516161+00:00 0:00:00.465906 386458 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T01:11:19.074878+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T00:00:00+00:00 TriggerDagRunOperator 2023-05-27T01:11:21.019321+00:00 2023-05-27T01:11:21.429751+00:00 0:00:00.410430 386457 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T01:11:19.074912+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T00:00:00+00:00 EmrJobFlowSensor 2023-05-27T01:00:57.073526+00:00 2023-05-27T01:10:58.946962+00:00 0:10:01.873436 386450 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T01:00:55.048201+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T01:00:37.763283+00:00 2023-05-27T01:00:38.746423+00:00 0:00:00.983140 386449 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T01:00:35.025250+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T00:00:00+00:00 PythonOperator 2023-05-27T01:00:15.263843+00:00 2023-05-27T01:00:16.163582+00:00 0:00:00.899739 386446 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T01:00:13.002860+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T23:00:00+00:00 TriggerDagRunOperator 2023-05-27T00:11:11.270030+00:00 2023-05-27T00:11:11.690757+00:00 0:00:00.420727 386435 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T00:11:09.209756+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T23:00:00+00:00 TriggerDagRunOperator 2023-05-27T00:11:11.204192+00:00 2023-05-27T00:11:11.682139+00:00 0:00:00.477947 386434 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T00:11:09.209726+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T23:00:00+00:00 EmrJobFlowSensor 2023-05-27T00:00:47.202900+00:00 2023-05-27T00:10:49.042016+00:00 0:10:01.839116 386427 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T00:00:45.163960+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T00:00:27.142034+00:00 2023-05-27T00:00:28.098768+00:00 0:00:00.956734 386425 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T00:00:25.132228+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T23:00:00+00:00 PythonOperator 2023-05-27T00:00:05.228381+00:00 2023-05-27T00:00:06.068824+00:00 0:00:00.840443 386423 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T00:00:03.113431+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T22:00:00+00:00 TriggerDagRunOperator 2023-05-26T23:11:21.562956+00:00 2023-05-26T23:11:22.047403+00:00 0:00:00.484447 386412 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T23:11:19.481281+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T22:00:00+00:00 TriggerDagRunOperator 2023-05-26T23:11:21.532363+00:00 2023-05-26T23:11:21.947622+00:00 0:00:00.415259 386411 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T23:11:19.481329+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T22:00:00+00:00 EmrJobFlowSensor 2023-05-26T23:01:04.962410+00:00 2023-05-26T23:11:07.071563+00:00 0:10:02.109153 386405 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T23:01:02.588115+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T23:00:42.599344+00:00 2023-05-26T23:00:43.511466+00:00 0:00:00.912122 386401 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T23:00:40.524555+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T22:00:00+00:00 PythonOperator 2023-05-26T23:00:22.547947+00:00 2023-05-26T23:00:23.492926+00:00 0:00:00.944979 386399 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T23:00:20.497792+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T21:00:00+00:00 TriggerDagRunOperator 2023-05-26T22:11:30.324344+00:00 2023-05-26T22:11:30.758332+00:00 0:00:00.433988 386386 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T22:11:27.904153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T21:00:00+00:00 TriggerDagRunOperator 2023-05-26T22:11:30.246162+00:00 2023-05-26T22:11:30.724719+00:00 0:00:00.478557 386385 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T22:11:27.904125+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T21:00:00+00:00 EmrJobFlowSensor 2023-05-26T22:01:07.394135+00:00 2023-05-26T22:11:09.190807+00:00 0:10:01.796672 386379 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T22:01:05.317087+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T22:00:45.375190+00:00 2023-05-26T22:00:46.323879+00:00 0:00:00.948689 386377 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T22:00:43.294705+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T21:00:00+00:00 PythonOperator 2023-05-26T22:00:25.656834+00:00 2023-05-26T22:00:26.493423+00:00 0:00:00.836589 386375 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T22:00:23.276814+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T20:00:00+00:00 TriggerDagRunOperator 2023-05-26T21:11:06.967616+00:00 2023-05-26T21:11:07.400522+00:00 0:00:00.432906 386363 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T21:11:04.804494+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T20:00:00+00:00 TriggerDagRunOperator 2023-05-26T21:11:06.953049+00:00 2023-05-26T21:11:07.370621+00:00 0:00:00.417572 386362 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T21:11:04.804459+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T20:00:00+00:00 EmrJobFlowSensor 2023-05-26T21:00:48.235199+00:00 2023-05-26T21:10:50.049766+00:00 0:10:01.814567 386355 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T21:00:46.188063+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T21:00:26.206449+00:00 2023-05-26T21:00:27.152498+00:00 0:00:00.946049 386353 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T21:00:24.110057+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T20:00:00+00:00 PythonOperator 2023-05-26T21:00:06.348610+00:00 2023-05-26T21:00:07.289988+00:00 0:00:00.941378 386351 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T21:00:04.104761+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T19:00:00+00:00 TriggerDagRunOperator 2023-05-26T20:11:17.223996+00:00 2023-05-26T20:11:17.663050+00:00 0:00:00.439054 386340 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T20:11:15.211684+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T19:00:00+00:00 TriggerDagRunOperator 2023-05-26T20:11:17.172673+00:00 2023-05-26T20:11:17.624489+00:00 0:00:00.451816 386339 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T20:11:15.211716+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T19:00:00+00:00 EmrJobFlowSensor 2023-05-26T20:01:04.738825+00:00 2023-05-26T20:11:06.577219+00:00 0:10:01.838394 386333 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T20:01:02.599180+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T20:00:44.693697+00:00 2023-05-26T20:00:45.693964+00:00 0:00:01.000267 386331 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T20:00:42.595954+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T19:00:00+00:00 PythonOperator 2023-05-26T20:00:22.600443+00:00 2023-05-26T20:00:23.477961+00:00 0:00:00.877518 386329 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T20:00:20.525827+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T18:00:00+00:00 TriggerDagRunOperator 2023-05-26T19:11:15.771236+00:00 2023-05-26T19:11:16.207635+00:00 0:00:00.436399 386315 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T19:11:13.705010+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T18:00:00+00:00 TriggerDagRunOperator 2023-05-26T19:11:15.780958+00:00 2023-05-26T19:11:16.244218+00:00 0:00:00.463260 386314 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T19:11:13.705039+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T18:00:00+00:00 EmrJobFlowSensor 2023-05-26T19:01:03.937842+00:00 2023-05-26T19:11:05.654066+00:00 0:10:01.716224 386307 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T19:01:01.970903+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T19:00:43.941958+00:00 2023-05-26T19:00:44.936762+00:00 0:00:00.994804 386306 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T19:00:41.952047+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T18:00:00+00:00 PythonOperator 2023-05-26T19:00:21.929275+00:00 2023-05-26T19:00:22.788118+00:00 0:00:00.858843 386305 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T19:00:19.933341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T17:00:00+00:00 TriggerDagRunOperator 2023-05-26T18:11:22.101402+00:00 2023-05-26T18:11:22.557244+00:00 0:00:00.455842 386291 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T18:11:19.906202+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T17:00:00+00:00 TriggerDagRunOperator 2023-05-26T18:11:22.007886+00:00 2023-05-26T18:11:22.437895+00:00 0:00:00.430009 386290 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T18:11:19.906235+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T17:00:00+00:00 EmrJobFlowSensor 2023-05-26T18:01:00.999725+00:00 2023-05-26T18:11:02.923424+00:00 0:10:01.923699 386283 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T18:00:58.995857+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T18:00:41.016879+00:00 2023-05-26T18:00:41.941821+00:00 0:00:00.924942 386282 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T18:00:38.975354+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T17:00:00+00:00 PythonOperator 2023-05-26T18:00:19.068780+00:00 2023-05-26T18:00:19.983548+00:00 0:00:00.914768 386280 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T18:00:16.956166+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T16:00:00+00:00 TriggerDagRunOperator 2023-05-26T17:11:21.581934+00:00 2023-05-26T17:11:22.068072+00:00 0:00:00.486138 386269 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T17:11:19.511669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T16:00:00+00:00 TriggerDagRunOperator 2023-05-26T17:11:21.559097+00:00 2023-05-26T17:11:21.990931+00:00 0:00:00.431834 386268 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T17:11:19.511703+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T16:00:00+00:00 EmrJobFlowSensor 2023-05-26T17:00:55.431815+00:00 2023-05-26T17:10:57.188116+00:00 0:10:01.756301 386259 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T17:00:53.402791+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T17:00:35.390694+00:00 2023-05-26T17:00:36.332286+00:00 0:00:00.941592 386258 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T17:00:33.374115+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T16:00:00+00:00 PythonOperator 2023-05-26T17:00:13.407674+00:00 2023-05-26T17:00:14.335056+00:00 0:00:00.927382 386257 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T17:00:11.355939+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T15:00:00+00:00 TriggerDagRunOperator 2023-05-26T16:14:55.779905+00:00 2023-05-26T16:14:56.225342+00:00 0:00:00.445437 386247 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T16:14:53.406301+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T15:00:00+00:00 TriggerDagRunOperator 2023-05-26T16:14:55.726805+00:00 2023-05-26T16:14:56.154086+00:00 0:00:00.427281 386246 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T16:14:53.406333+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T15:00:00+00:00 EmrJobFlowSensor 2023-05-26T16:01:37.739890+00:00 2023-05-26T16:11:39.482317+00:00 0:10:01.742427 386240 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T16:01:35.667553+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-26T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-26T16:01:15.650037+00:00 2023-05-26T16:01:16.571368+00:00 0:00:00.921331 386238 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-26T16:01:13.646599+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-26T15:00:00+00:00 PythonOperator 2023-05-26T16:00:55.946573+00:00 2023-05-26T16:00:56.806902+00:00 0:00:00.860329 386236 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-26T16:00:53.627290+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-26T14:00:00+00:00 TriggerDagRunOperator 2023-05-26T15:16:18.010371+00:00 2023-05-26T15:16:18.455911+00:00 0:00:00.445540 386225 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T15:16:15.436412+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-26T14:00:00+00:00 TriggerDagRunOperator 2023-05-26T15:16:17.990292+00:00 2023-05-26T15:16:18.416355+00:00 0:00:00.426063 386224 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-26T15:16:15.436383+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-26T14:00:00+00:00 EmrJobFlowSensor 2023-05-26T15:03:28.976417+00:00 2023-05-26T15:13:30.703786+00:00 0:10:01.727369 386218 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-26T15:03:26.921881+00:00 2 default_pool