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-02-13T01:00:00+00:00 EmrJobFlowSensor 2023-02-13T02:00:52.576665+00:00 2023-02-13T02:10:54.419830+00:00 0:10:01.843165 338722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T02:00:50.097239+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T02:00:30.396685+00:00 2023-02-13T02:00:31.196501+00:00 0:00:00.799816 338720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T02:00:28.002171+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T01:00:00+00:00 PythonOperator 2023-02-13T02:00:10.271037+00:00 2023-02-13T02:00:13.166347+00:00 0:00:02.895310 338718 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T02:00:07.930832+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T00:00:00+00:00 TriggerDagRunOperator 2023-02-13T01:11:24.604150+00:00 2023-02-13T01:11:25.125800+00:00 0:00:00.521650 338699 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T01:11:22.141136+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T00:00:00+00:00 TriggerDagRunOperator 2023-02-13T01:11:24.568109+00:00 2023-02-13T01:11:25.027467+00:00 0:00:00.459358 338698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T01:11:22.141163+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T00:00:00+00:00 EmrJobFlowSensor 2023-02-13T01:01:01.996699+00:00 2023-02-13T01:11:03.961960+00:00 0:10:01.965261 338692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T01:00:59.105928+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T01:00:39.285760+00:00 2023-02-13T01:00:40.112602+00:00 0:00:00.826842 338690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T01:00:36.946308+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T00:00:00+00:00 PythonOperator 2023-02-13T01:00:19.385141+00:00 2023-02-13T01:00:23.425205+00:00 0:00:04.040064 338688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T01:00:16.930771+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T23:00:00+00:00 TriggerDagRunOperator 2023-02-13T00:15:23.993817+00:00 2023-02-13T00:15:24.462210+00:00 0:00:00.468393 338674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T00:15:21.261263+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T23:00:00+00:00 TriggerDagRunOperator 2023-02-13T00:15:23.807218+00:00 2023-02-13T00:15:24.293686+00:00 0:00:00.486468 338673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T00:15:21.261317+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T23:00:00+00:00 EmrJobFlowSensor 2023-02-13T00:02:27.325684+00:00 2023-02-13T00:11:29.100003+00:00 0:09:01.774319 338668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T00:02:23.960566+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T00:00:45.770873+00:00 2023-02-13T00:00:46.614449+00:00 0:00:00.843576 338664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T00:00:43.363593+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T23:00:00+00:00 PythonOperator 2023-02-13T00:00:23.734346+00:00 2023-02-13T00:00:26.679454+00:00 0:00:02.945108 338662 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T00:00:21.409115+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T22:00:00+00:00 TriggerDagRunOperator 2023-02-12T23:11:11.832736+00:00 2023-02-12T23:11:12.336702+00:00 0:00:00.503966 338647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T23:11:08.280364+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T22:00:00+00:00 TriggerDagRunOperator 2023-02-12T23:11:11.389177+00:00 2023-02-12T23:11:11.880594+00:00 0:00:00.491417 338646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T23:11:08.280408+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T22:00:00+00:00 EmrJobFlowSensor 2023-02-12T23:00:48.088408+00:00 2023-02-12T23:10:49.844574+00:00 0:10:01.756166 338637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T23:00:45.766393+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T23:00:26.747584+00:00 2023-02-12T23:00:27.568087+00:00 0:00:00.820503 338634 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T23:00:23.746930+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T22:00:00+00:00 PythonOperator 2023-02-12T23:00:06.123774+00:00 2023-02-12T23:00:08.988189+00:00 0:00:02.864415 338631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T23:00:03.729351+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T21:00:00+00:00 TriggerDagRunOperator 2023-02-12T22:11:25.112741+00:00 2023-02-12T22:11:25.625395+00:00 0:00:00.512654 338618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T22:11:22.190509+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T21:00:00+00:00 TriggerDagRunOperator 2023-02-12T22:11:24.787233+00:00 2023-02-12T22:11:25.279116+00:00 0:00:00.491883 338617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T22:11:22.190537+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T21:00:00+00:00 EmrJobFlowSensor 2023-02-12T22:01:03.175298+00:00 2023-02-12T22:11:05.070643+00:00 0:10:01.895345 338610 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T22:01:00.359732+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T22:00:43.509562+00:00 2023-02-12T22:00:44.372984+00:00 0:00:00.863422 338608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T22:00:38.399446+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T21:00:00+00:00 PythonOperator 2023-02-12T22:00:19.028604+00:00 2023-02-12T22:00:22.750203+00:00 0:00:03.721599 338606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T22:00:16.323205+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T20:00:00+00:00 TriggerDagRunOperator 2023-02-12T21:12:14.749190+00:00 2023-02-12T21:12:15.325409+00:00 0:00:00.576219 338592 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T21:12:12.101022+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T20:00:00+00:00 TriggerDagRunOperator 2023-02-12T21:12:14.481700+00:00 2023-02-12T21:12:14.935990+00:00 0:00:00.454290 338591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T21:12:12.100993+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T20:00:00+00:00 EmrJobFlowSensor 2023-02-12T21:01:01.864679+00:00 2023-02-12T21:12:03.667987+00:00 0:11:01.803308 338584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T21:00:59.591452+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T21:00:41.722437+00:00 2023-02-12T21:00:42.546007+00:00 0:00:00.823570 338582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T21:00:39.550692+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T20:00:00+00:00 PythonOperator 2023-02-12T21:00:19.935905+00:00 2023-02-12T21:00:23.129111+00:00 0:00:03.193206 338580 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T21:00:17.516933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T19:00:00+00:00 TriggerDagRunOperator 2023-02-12T20:11:08.824383+00:00 2023-02-12T20:11:09.330183+00:00 0:00:00.505800 338566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T20:11:06.150360+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T19:00:00+00:00 TriggerDagRunOperator 2023-02-12T20:11:08.728004+00:00 2023-02-12T20:11:09.197417+00:00 0:00:00.469413 338565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T20:11:06.150405+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T19:00:00+00:00 EmrJobFlowSensor 2023-02-12T20:01:01.309918+00:00 2023-02-12T20:11:03.197486+00:00 0:10:01.887568 338558 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T20:00:58.583130+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T20:00:39.252595+00:00 2023-02-12T20:00:40.112281+00:00 0:00:00.859686 338556 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T20:00:36.617020+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T19:00:00+00:00 PythonOperator 2023-02-12T20:00:19.102005+00:00 2023-02-12T20:00:22.311714+00:00 0:00:03.209709 338554 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T20:00:16.610660+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T18:00:00+00:00 TriggerDagRunOperator 2023-02-12T19:11:20.194077+00:00 2023-02-12T19:11:20.655412+00:00 0:00:00.461335 338540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T19:11:17.387655+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T18:00:00+00:00 TriggerDagRunOperator 2023-02-12T19:11:20.041101+00:00 2023-02-12T19:11:20.534852+00:00 0:00:00.493751 338539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T19:11:17.387699+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T18:00:00+00:00 EmrJobFlowSensor 2023-02-12T19:00:57.451528+00:00 2023-02-12T19:10:59.207504+00:00 0:10:01.755976 338532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T19:00:55.181100+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T19:00:37.389933+00:00 2023-02-12T19:00:38.216823+00:00 0:00:00.826890 338530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T19:00:35.156414+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T18:00:00+00:00 PythonOperator 2023-02-12T19:00:15.403401+00:00 2023-02-12T19:00:18.264400+00:00 0:00:02.860999 338528 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T19:00:13.143505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T17:00:00+00:00 TriggerDagRunOperator 2023-02-12T18:11:28.615989+00:00 2023-02-12T18:11:29.157606+00:00 0:00:00.541617 338514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T18:11:25.839046+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T17:00:00+00:00 TriggerDagRunOperator 2023-02-12T18:11:28.556046+00:00 2023-02-12T18:11:29.095755+00:00 0:00:00.539709 338513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T18:11:25.839016+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T17:00:00+00:00 EmrJobFlowSensor 2023-02-12T18:02:08.930460+00:00 2023-02-12T18:11:10.631725+00:00 0:09:01.701265 338504 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T18:02:06.074629+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T18:00:45.506100+00:00 2023-02-12T18:00:46.339715+00:00 0:00:00.833615 338502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T18:00:42.939778+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T17:00:00+00:00 PythonOperator 2023-02-12T18:00:25.164473+00:00 2023-02-12T18:00:29.022986+00:00 0:00:03.858513 338501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T18:00:22.904914+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T16:00:00+00:00 TriggerDagRunOperator 2023-02-12T17:11:09.485001+00:00 2023-02-12T17:11:09.988295+00:00 0:00:00.503294 338487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T17:11:06.704100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T16:00:00+00:00 TriggerDagRunOperator 2023-02-12T17:11:09.419829+00:00 2023-02-12T17:11:09.920732+00:00 0:00:00.500903 338486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T17:11:06.704057+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T16:00:00+00:00 EmrJobFlowSensor 2023-02-12T17:00:55.263210+00:00 2023-02-12T17:10:57.096560+00:00 0:10:01.833350 338478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T17:00:52.748569+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T17:00:33.206692+00:00 2023-02-12T17:00:33.989074+00:00 0:00:00.782382 338476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T17:00:30.801715+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T16:00:00+00:00 PythonOperator 2023-02-12T17:00:13.011790+00:00 2023-02-12T17:00:16.021881+00:00 0:00:03.010091 338474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T17:00:10.688121+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T15:00:00+00:00 TriggerDagRunOperator 2023-02-12T16:11:06.885422+00:00 2023-02-12T16:11:07.366241+00:00 0:00:00.480819 338462 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T16:11:04.253352+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T15:00:00+00:00 TriggerDagRunOperator 2023-02-12T16:11:06.767513+00:00 2023-02-12T16:11:07.239055+00:00 0:00:00.471542 338461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T16:11:04.253300+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T15:00:00+00:00 EmrJobFlowSensor 2023-02-12T16:00:49.797941+00:00 2023-02-12T16:10:51.682167+00:00 0:10:01.884226 338455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T16:00:46.957949+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T16:00:29.391871+00:00 2023-02-12T16:00:30.759570+00:00 0:00:01.367699 338453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T16:00:24.944023+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T15:00:00+00:00 PythonOperator 2023-02-12T16:00:05.447891+00:00 2023-02-12T16:00:09.309779+00:00 0:00:03.861888 338450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T16:00:02.862780+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T14:00:00+00:00 TriggerDagRunOperator 2023-02-12T15:11:03.106026+00:00 2023-02-12T15:11:03.607409+00:00 0:00:00.501383 338436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T15:11:00.456265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T14:00:00+00:00 TriggerDagRunOperator 2023-02-12T15:11:02.839001+00:00 2023-02-12T15:11:03.390743+00:00 0:00:00.551742 338435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T15:11:00.456234+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T14:00:00+00:00 EmrJobFlowSensor 2023-02-12T15:00:56.033031+00:00 2023-02-12T15:10:57.906331+00:00 0:10:01.873300 338428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T15:00:53.764209+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T15:00:34.301147+00:00 2023-02-12T15:00:35.178611+00:00 0:00:00.877464 338426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T15:00:31.811229+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T14:00:00+00:00 PythonOperator 2023-02-12T15:00:13.312482+00:00 2023-02-12T15:00:17.709267+00:00 0:00:04.396785 338424 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T15:00:09.801616+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T13:00:00+00:00 TriggerDagRunOperator 2023-02-12T14:11:04.060328+00:00 2023-02-12T14:11:04.561180+00:00 0:00:00.500852 338412 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T14:11:01.300641+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T13:00:00+00:00 TriggerDagRunOperator 2023-02-12T14:11:03.966327+00:00 2023-02-12T14:11:04.503089+00:00 0:00:00.536762 338411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T14:11:01.300685+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T13:00:00+00:00 EmrJobFlowSensor 2023-02-12T14:02:44.244602+00:00 2023-02-12T14:10:45.826112+00:00 0:08:01.581510 338405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T14:02:41.848841+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T13:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T14:00:41.522557+00:00 2023-02-12T14:00:42.306157+00:00 0:00:00.783600 338402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T14:00:39.305269+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T13:00:00+00:00 PythonOperator 2023-02-12T14:00:21.628358+00:00 2023-02-12T14:00:24.397584+00:00 0:00:02.769226 338400 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T14:00:19.296303+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T12:00:00+00:00 TriggerDagRunOperator 2023-02-12T13:11:20.861068+00:00 2023-02-12T13:11:21.375910+00:00 0:00:00.514842 338389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T13:11:18.415909+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T12:00:00+00:00 TriggerDagRunOperator 2023-02-12T13:11:20.847428+00:00 2023-02-12T13:11:21.332386+00:00 0:00:00.484958 338388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T13:11:18.415873+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T12:00:00+00:00 EmrJobFlowSensor 2023-02-12T13:07:09.539474+00:00 2023-02-12T13:11:10.797743+00:00 0:04:01.258269 338382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T13:07:05.943485+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T13:00:31.572707+00:00 2023-02-12T13:00:32.371425+00:00 0:00:00.798718 338379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T13:00:29.308437+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T12:00:00+00:00 PythonOperator 2023-02-12T13:00:09.766213+00:00 2023-02-12T13:00:12.861812+00:00 0:00:03.095599 338377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T13:00:07.290088+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T11:00:00+00:00 TriggerDagRunOperator 2023-02-12T12:21:26.732279+00:00 2023-02-12T12:21:27.255048+00:00 0:00:00.522769 338367 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T12:21:24.096539+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T11:00:00+00:00 TriggerDagRunOperator 2023-02-12T12:21:26.664596+00:00 2023-02-12T12:21:27.138094+00:00 0:00:00.473498 338366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T12:21:24.096510+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T11:00:00+00:00 EmrJobFlowSensor 2023-02-12T12:00:52.148107+00:00 2023-02-12T12:10:53.873748+00:00 0:10:01.725641 338359 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T12:00:49.560966+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T12:00:29.731592+00:00 2023-02-12T12:00:30.674032+00:00 0:00:00.942440 338357 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T12:00:27.511992+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T11:00:00+00:00 PythonOperator 2023-02-12T12:00:07.770249+00:00 2023-02-12T12:00:10.579691+00:00 0:00:02.809442 338355 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T12:00:05.491063+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T10:00:00+00:00 TriggerDagRunOperator 2023-02-12T11:13:29.069270+00:00 2023-02-12T11:13:29.647393+00:00 0:00:00.578123 338343 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T11:13:26.327030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T10:00:00+00:00 TriggerDagRunOperator 2023-02-12T11:13:28.844503+00:00 2023-02-12T11:13:29.348793+00:00 0:00:00.504290 338342 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T11:13:26.327001+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T10:00:00+00:00 EmrJobFlowSensor 2023-02-12T11:03:12.344372+00:00 2023-02-12T11:13:14.141165+00:00 0:10:01.796793 338336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T11:03:10.179301+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T11:02:50.598191+00:00 2023-02-12T11:02:51.506089+00:00 0:00:00.907898 338334 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T11:02:48.158866+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T10:00:00+00:00 PythonOperator 2023-02-12T11:02:30.862368+00:00 2023-02-12T11:02:34.412077+00:00 0:00:03.549709 338332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T11:02:28.163841+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T09:00:00+00:00 TriggerDagRunOperator 2023-02-12T10:16:25.973150+00:00 2023-02-12T10:16:26.548207+00:00 0:00:00.575057 338319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T10:16:23.448149+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T09:00:00+00:00 TriggerDagRunOperator 2023-02-12T10:16:25.936117+00:00 2023-02-12T10:16:26.442732+00:00 0:00:00.506615 338318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T10:16:23.448108+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T09:00:00+00:00 EmrJobFlowSensor 2023-02-12T10:06:01.514051+00:00 2023-02-12T10:16:03.375500+00:00 0:10:01.861449 338315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T10:05:59.239266+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T10:05:41.455581+00:00 2023-02-12T10:05:42.238728+00:00 0:00:00.783147 338312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T10:05:39.213961+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T09:00:00+00:00 PythonOperator 2023-02-12T10:05:19.662873+00:00 2023-02-12T10:05:22.492880+00:00 0:00:02.830007 338309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T10:05:17.206124+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T08:00:00+00:00 TriggerDagRunOperator 2023-02-12T09:11:35.252299+00:00 2023-02-12T09:11:35.765223+00:00 0:00:00.512924 338294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T09:11:32.796113+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T08:00:00+00:00 TriggerDagRunOperator 2023-02-12T09:11:35.169744+00:00 2023-02-12T09:11:35.634831+00:00 0:00:00.465087 338293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T09:11:32.796142+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T08:00:00+00:00 EmrJobFlowSensor 2023-02-12T09:01:07.933736+00:00 2023-02-12T09:11:09.748418+00:00 0:10:01.814682 338287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T09:01:05.701591+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T09:00:48.713297+00:00 2023-02-12T09:00:49.736994+00:00 0:00:01.023697 338285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T09:00:45.683251+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T08:00:00+00:00 PythonOperator 2023-02-12T09:00:26.352404+00:00 2023-02-12T09:00:29.499185+00:00 0:00:03.146781 338283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T09:00:23.714283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T07:00:00+00:00 TriggerDagRunOperator 2023-02-12T08:16:51.559527+00:00 2023-02-12T08:16:52.071626+00:00 0:00:00.512099 338268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T08:16:49.218141+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T07:00:00+00:00 TriggerDagRunOperator 2023-02-12T08:16:51.536124+00:00 2023-02-12T08:16:52.008817+00:00 0:00:00.472693 338267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T08:16:49.218112+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T07:00:00+00:00 EmrJobFlowSensor 2023-02-12T08:00:53.940119+00:00 2023-02-12T08:10:55.703312+00:00 0:10:01.763193 338259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T08:00:51.700565+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T08:00:34.160571+00:00 2023-02-12T08:00:35.075612+00:00 0:00:00.915041 338258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T08:00:31.682596+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T07:00:00+00:00 PythonOperator 2023-02-12T08:00:12.549771+00:00 2023-02-12T08:00:15.516363+00:00 0:00:02.966592 338255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T08:00:09.652418+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T06:00:00+00:00 TriggerDagRunOperator 2023-02-12T07:20:42.011362+00:00 2023-02-12T07:20:42.637970+00:00 0:00:00.626608 338242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T07:20:39.035537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T06:00:00+00:00 TriggerDagRunOperator 2023-02-12T07:20:41.924503+00:00 2023-02-12T07:20:42.494681+00:00 0:00:00.570178 338241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T07:20:39.035501+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-12T06:00:00+00:00 EmrJobFlowSensor 2023-02-12T07:00:58.213428+00:00 2023-02-12T07:10:59.946797+00:00 0:10:01.733369 338236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-12T07:00:55.627950+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-12T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-12T07:00:35.759504+00:00 2023-02-12T07:00:36.621435+00:00 0:00:00.861931 338234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-12T07:00:33.553834+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-12T06:00:00+00:00 PythonOperator 2023-02-12T07:00:16.174153+00:00 2023-02-12T07:00:20.704034+00:00 0:00:04.529881 338232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-12T07:00:13.538600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-12T05:00:00+00:00 TriggerDagRunOperator 2023-02-12T06:11:24.559714+00:00 2023-02-12T06:11:25.048118+00:00 0:00:00.488404 338219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T06:11:21.992529+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-12T05:00:00+00:00 TriggerDagRunOperator 2023-02-12T06:11:24.314889+00:00 2023-02-12T06:11:24.778655+00:00 0:00:00.463766 338218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-12T06:11:21.992501+00:00 2 default_pool