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-09T17:00:00+00:00 EmrJobFlowSensor 2023-02-09T18:00:52.313949+00:00 2023-02-09T18:10:54.464013+00:00 0:10:02.150064 336660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T18:00:49.975020+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T18:00:30.263778+00:00 2023-02-09T18:00:31.138930+00:00 0:00:00.875152 336658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T18:00:27.952713+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T17:00:00+00:00 PythonOperator 2023-02-09T18:00:10.341076+00:00 2023-02-09T18:00:15.276424+00:00 0:00:04.935348 336656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T18:00:07.935133+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T16:00:00+00:00 TriggerDagRunOperator 2023-02-09T17:15:12.426992+00:00 2023-02-09T17:15:12.914597+00:00 0:00:00.487605 336643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T17:15:09.893604+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T16:00:00+00:00 TriggerDagRunOperator 2023-02-09T17:15:12.220508+00:00 2023-02-09T17:15:12.684125+00:00 0:00:00.463617 336642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T17:15:09.893575+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T16:00:00+00:00 EmrJobFlowSensor 2023-02-09T17:04:58.978578+00:00 2023-02-09T17:15:00.943475+00:00 0:10:01.964897 336636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T17:04:56.549209+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T17:04:39.859495+00:00 2023-02-09T17:04:40.661803+00:00 0:00:00.802308 336634 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T17:04:34.516720+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T16:00:00+00:00 PythonOperator 2023-02-09T17:04:17.296188+00:00 2023-02-09T17:04:20.032787+00:00 0:00:02.736599 336632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T17:04:14.458908+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T15:00:00+00:00 TriggerDagRunOperator 2023-02-09T16:22:13.952444+00:00 2023-02-09T16:22:14.452895+00:00 0:00:00.500451 336620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T16:22:11.489332+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T15:00:00+00:00 TriggerDagRunOperator 2023-02-09T16:22:13.908914+00:00 2023-02-09T16:22:14.370067+00:00 0:00:00.461153 336619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T16:22:11.489359+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T15:00:00+00:00 EmrJobFlowSensor 2023-02-09T16:04:47.777682+00:00 2023-02-09T16:14:49.560888+00:00 0:10:01.783206 336613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T16:04:45.631620+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T16:04:25.745805+00:00 2023-02-09T16:04:26.609984+00:00 0:00:00.864179 336611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T16:04:23.605310+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T15:00:00+00:00 PythonOperator 2023-02-09T16:04:05.750303+00:00 2023-02-09T16:04:09.488455+00:00 0:00:03.738152 336609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T16:04:03.580359+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T14:00:00+00:00 TriggerDagRunOperator 2023-02-09T15:10:59.669694+00:00 2023-02-09T15:11:00.329815+00:00 0:00:00.660121 336596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T15:10:57.390265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T14:00:00+00:00 TriggerDagRunOperator 2023-02-09T15:10:59.622630+00:00 2023-02-09T15:11:00.234500+00:00 0:00:00.611870 336595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T15:10:57.390292+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T14:00:00+00:00 EmrJobFlowSensor 2023-02-09T15:00:49.543057+00:00 2023-02-09T15:10:51.420081+00:00 0:10:01.877024 336588 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T15:00:46.598048+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T15:00:28.853491+00:00 2023-02-09T15:00:29.657303+00:00 0:00:00.803812 336586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T15:00:26.508775+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T14:00:00+00:00 PythonOperator 2023-02-09T15:00:06.999551+00:00 2023-02-09T15:00:10.025333+00:00 0:00:03.025782 336584 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T15:00:04.433109+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T13:00:00+00:00 TriggerDagRunOperator 2023-02-09T14:11:03.251996+00:00 2023-02-09T14:11:03.747254+00:00 0:00:00.495258 336571 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T14:11:00.604229+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T13:00:00+00:00 TriggerDagRunOperator 2023-02-09T14:11:03.048474+00:00 2023-02-09T14:11:03.609585+00:00 0:00:00.561111 336570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T14:11:00.604181+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T13:00:00+00:00 EmrJobFlowSensor 2023-02-09T14:00:50.103596+00:00 2023-02-09T14:10:52.405959+00:00 0:10:02.302363 336563 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T14:00:47.479023+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T13:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T14:00:28.283494+00:00 2023-02-09T14:00:29.136075+00:00 0:00:00.852581 336561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T14:00:25.521245+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T13:00:00+00:00 PythonOperator 2023-02-09T14:00:08.910827+00:00 2023-02-09T14:00:13.503310+00:00 0:00:04.592483 336559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T14:00:05.498351+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T12:00:00+00:00 TriggerDagRunOperator 2023-02-09T13:11:04.162558+00:00 2023-02-09T13:11:04.706726+00:00 0:00:00.544168 336546 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T13:11:01.700132+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T12:00:00+00:00 TriggerDagRunOperator 2023-02-09T13:11:04.130554+00:00 2023-02-09T13:11:04.634368+00:00 0:00:00.503814 336545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T13:11:01.700181+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T12:00:00+00:00 EmrJobFlowSensor 2023-02-09T13:00:53.105016+00:00 2023-02-09T13:10:54.865989+00:00 0:10:01.760973 336539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T13:00:50.709323+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T13:00:33.141311+00:00 2023-02-09T13:00:33.931594+00:00 0:00:00.790283 336537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T13:00:30.696257+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T12:00:00+00:00 PythonOperator 2023-02-09T13:00:09.997351+00:00 2023-02-09T13:00:14.308432+00:00 0:00:04.311081 336535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T13:00:06.726807+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T11:00:00+00:00 TriggerDagRunOperator 2023-02-09T12:22:35.540791+00:00 2023-02-09T12:22:36.074324+00:00 0:00:00.533533 336523 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T12:22:33.151754+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T11:00:00+00:00 TriggerDagRunOperator 2023-02-09T12:22:35.537363+00:00 2023-02-09T12:22:36.000023+00:00 0:00:00.462660 336522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T12:22:33.151781+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T11:00:00+00:00 EmrJobFlowSensor 2023-02-09T12:10:50.088252+00:00 2023-02-09T12:20:51.879975+00:00 0:10:01.791723 336519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T12:10:47.452390+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T12:10:27.985177+00:00 2023-02-09T12:10:28.860512+00:00 0:00:00.875335 336516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T12:10:25.443445+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T11:00:00+00:00 PythonOperator 2023-02-09T12:10:07.686500+00:00 2023-02-09T12:10:11.538059+00:00 0:00:03.851559 336513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T12:10:05.388971+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T10:00:00+00:00 TriggerDagRunOperator 2023-02-09T11:11:24.648375+00:00 2023-02-09T11:11:25.191241+00:00 0:00:00.542866 336501 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T11:11:21.923483+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T10:00:00+00:00 TriggerDagRunOperator 2023-02-09T11:11:24.401688+00:00 2023-02-09T11:11:24.876807+00:00 0:00:00.475119 336500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T11:11:21.923512+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T10:00:00+00:00 EmrJobFlowSensor 2023-02-09T11:01:03.901724+00:00 2023-02-09T11:11:05.787240+00:00 0:10:01.885516 336493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T11:01:01.405062+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T11:00:43.669711+00:00 2023-02-09T11:00:44.631315+00:00 0:00:00.961604 336491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T11:00:41.332070+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T10:00:00+00:00 PythonOperator 2023-02-09T11:00:21.609271+00:00 2023-02-09T11:00:24.469082+00:00 0:00:02.859811 336489 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T11:00:19.274189+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T09:00:00+00:00 TriggerDagRunOperator 2023-02-09T10:17:29.299295+00:00 2023-02-09T10:17:29.819429+00:00 0:00:00.520134 336477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T10:17:26.893571+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T09:00:00+00:00 TriggerDagRunOperator 2023-02-09T10:17:29.233990+00:00 2023-02-09T10:17:29.819447+00:00 0:00:00.585457 336476 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T10:17:26.893544+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T09:00:00+00:00 EmrJobFlowSensor 2023-02-09T10:07:02.625435+00:00 2023-02-09T10:17:04.434625+00:00 0:10:01.809190 336473 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T10:07:00.133395+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T10:06:44.808007+00:00 2023-02-09T10:06:46.166835+00:00 0:00:01.358828 336470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T10:06:40.051330+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T09:00:00+00:00 PythonOperator 2023-02-09T10:06:20.267394+00:00 2023-02-09T10:06:23.962775+00:00 0:00:03.695381 336466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T10:06:18.010843+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T08:00:00+00:00 TriggerDagRunOperator 2023-02-09T09:24:26.300538+00:00 2023-02-09T09:24:27.108421+00:00 0:00:00.807883 336452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T09:24:21.831290+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T08:00:00+00:00 TriggerDagRunOperator 2023-02-09T09:24:24.284750+00:00 2023-02-09T09:24:24.782494+00:00 0:00:00.497744 336451 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T09:24:21.831325+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T08:00:00+00:00 EmrJobFlowSensor 2023-02-09T09:00:58.127284+00:00 2023-02-09T09:11:00.127226+00:00 0:10:01.999942 336447 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T09:00:55.645865+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T09:00:36.027179+00:00 2023-02-09T09:00:36.889469+00:00 0:00:00.862290 336445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T09:00:33.693116+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T08:00:00+00:00 PythonOperator 2023-02-09T09:00:15.919440+00:00 2023-02-09T09:00:20.203882+00:00 0:00:04.284442 336443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T09:00:13.622182+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T07:00:00+00:00 TriggerDagRunOperator 2023-02-09T08:11:29.761543+00:00 2023-02-09T08:11:30.454605+00:00 0:00:00.693062 336428 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T08:11:27.103581+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T07:00:00+00:00 TriggerDagRunOperator 2023-02-09T08:11:29.577555+00:00 2023-02-09T08:11:30.142406+00:00 0:00:00.564851 336427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T08:11:27.103544+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T07:00:00+00:00 EmrJobFlowSensor 2023-02-09T08:01:05.113026+00:00 2023-02-09T08:11:07.409590+00:00 0:10:02.296564 336420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T08:01:02.192788+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T08:00:43.097444+00:00 2023-02-09T08:00:44.512120+00:00 0:00:01.414676 336418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T08:00:40.202618+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T07:00:00+00:00 PythonOperator 2023-02-09T08:00:21.488160+00:00 2023-02-09T08:00:26.028628+00:00 0:00:04.540468 336416 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T08:00:18.105581+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T06:00:00+00:00 TriggerDagRunOperator 2023-02-09T07:18:24.641482+00:00 2023-02-09T07:18:25.162064+00:00 0:00:00.520582 336403 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T07:18:21.770206+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T06:00:00+00:00 TriggerDagRunOperator 2023-02-09T07:18:24.512373+00:00 2023-02-09T07:18:25.002968+00:00 0:00:00.490595 336402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T07:18:21.770254+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T06:00:00+00:00 EmrJobFlowSensor 2023-02-09T07:07:13.946035+00:00 2023-02-09T07:18:15.985758+00:00 0:11:02.039723 336397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T07:07:11.291383+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T07:06:52.091976+00:00 2023-02-09T07:06:53.318826+00:00 0:00:01.226850 336395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T07:06:49.245321+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T06:00:00+00:00 PythonOperator 2023-02-09T07:06:30.908189+00:00 2023-02-09T07:06:37.457483+00:00 0:00:06.549294 336391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T07:06:27.232995+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T05:00:00+00:00 TriggerDagRunOperator 2023-02-09T06:18:18.235082+00:00 2023-02-09T06:18:18.860394+00:00 0:00:00.625312 336380 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T06:18:15.246157+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T05:00:00+00:00 TriggerDagRunOperator 2023-02-09T06:18:17.817661+00:00 2023-02-09T06:18:18.351209+00:00 0:00:00.533548 336379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T06:18:15.246127+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T05:00:00+00:00 EmrJobFlowSensor 2023-02-09T06:01:06.851671+00:00 2023-02-09T06:12:08.748666+00:00 0:11:01.896995 336372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T06:01:04.130995+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T05:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T06:00:44.358410+00:00 2023-02-09T06:00:45.272633+00:00 0:00:00.914223 336370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T06:00:42.095974+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T05:00:00+00:00 PythonOperator 2023-02-09T06:00:25.206080+00:00 2023-02-09T06:00:28.265557+00:00 0:00:03.059477 336368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T06:00:22.086175+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T04:00:00+00:00 TriggerDagRunOperator 2023-02-09T05:16:11.456835+00:00 2023-02-09T05:16:11.975127+00:00 0:00:00.518292 336356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T05:16:08.439959+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T04:00:00+00:00 TriggerDagRunOperator 2023-02-09T05:16:11.290293+00:00 2023-02-09T05:16:11.759331+00:00 0:00:00.469038 336355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T05:16:08.440008+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T04:00:00+00:00 EmrJobFlowSensor 2023-02-09T05:00:55.693427+00:00 2023-02-09T05:10:57.598318+00:00 0:10:01.904891 336347 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T05:00:53.403847+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T04:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T05:00:33.640252+00:00 2023-02-09T05:00:34.439276+00:00 0:00:00.799024 336345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T05:00:31.401379+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T04:00:00+00:00 PythonOperator 2023-02-09T05:00:13.755020+00:00 2023-02-09T05:00:17.639975+00:00 0:00:03.884955 336343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T05:00:11.361006+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T03:00:00+00:00 TriggerDagRunOperator 2023-02-09T04:13:48.548287+00:00 2023-02-09T04:13:49.154582+00:00 0:00:00.606295 336330 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T04:13:46.146251+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T03:00:00+00:00 TriggerDagRunOperator 2023-02-09T04:13:48.532703+00:00 2023-02-09T04:13:49.003687+00:00 0:00:00.470984 336329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T04:13:46.146221+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T03:00:00+00:00 EmrJobFlowSensor 2023-02-09T04:03:27.839333+00:00 2023-02-09T04:13:29.692659+00:00 0:10:01.853326 336323 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T04:03:25.507658+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T04:03:05.644346+00:00 2023-02-09T04:03:06.512748+00:00 0:00:00.868402 336321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T04:03:03.485520+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T03:00:00+00:00 PythonOperator 2023-02-09T04:02:47.597732+00:00 2023-02-09T04:02:50.668243+00:00 0:00:03.070511 336319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T04:02:43.469782+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T02:00:00+00:00 TriggerDagRunOperator 2023-02-09T03:14:20.320486+00:00 2023-02-09T03:14:20.899569+00:00 0:00:00.579083 336306 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T03:14:17.400391+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T02:00:00+00:00 TriggerDagRunOperator 2023-02-09T03:14:20.128868+00:00 2023-02-09T03:14:20.715246+00:00 0:00:00.586378 336305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T03:14:17.400349+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T02:00:00+00:00 EmrJobFlowSensor 2023-02-09T03:01:22.646508+00:00 2023-02-09T03:11:24.403009+00:00 0:10:01.756501 336298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T03:01:20.468006+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T02:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T03:01:02.658146+00:00 2023-02-09T03:01:03.551997+00:00 0:00:00.893851 336296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T03:01:00.451781+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T02:00:00+00:00 PythonOperator 2023-02-09T03:00:41.253897+00:00 2023-02-09T03:00:44.957817+00:00 0:00:03.703920 336294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T03:00:38.360044+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T01:00:00+00:00 TriggerDagRunOperator 2023-02-09T02:11:12.945945+00:00 2023-02-09T02:11:13.551865+00:00 0:00:00.605920 336283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T02:11:10.101592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T01:00:00+00:00 TriggerDagRunOperator 2023-02-09T02:11:12.919096+00:00 2023-02-09T02:11:13.576375+00:00 0:00:00.657279 336282 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T02:11:10.101633+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T01:00:00+00:00 EmrJobFlowSensor 2023-02-09T02:00:59.468444+00:00 2023-02-09T02:11:01.363414+00:00 0:10:01.894970 336276 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T02:00:56.503760+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T02:00:37.507275+00:00 2023-02-09T02:00:38.372812+00:00 0:00:00.865537 336274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T02:00:34.433211+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T01:00:00+00:00 PythonOperator 2023-02-09T02:00:16.525132+00:00 2023-02-09T02:00:19.325706+00:00 0:00:02.800574 336272 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T02:00:14.346606+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T00:00:00+00:00 TriggerDagRunOperator 2023-02-09T01:11:11.144872+00:00 2023-02-09T01:11:11.625696+00:00 0:00:00.480824 336252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T01:11:08.656559+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T00:00:00+00:00 TriggerDagRunOperator 2023-02-09T01:11:11.030196+00:00 2023-02-09T01:11:11.611420+00:00 0:00:00.581224 336251 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T01:11:08.656588+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T00:00:00+00:00 EmrJobFlowSensor 2023-02-09T01:00:49.516801+00:00 2023-02-09T01:10:51.316344+00:00 0:10:01.799543 336243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T01:00:47.152090+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T01:00:27.389182+00:00 2023-02-09T01:00:28.239635+00:00 0:00:00.850453 336241 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T01:00:25.136916+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T00:00:00+00:00 PythonOperator 2023-02-09T01:00:05.479640+00:00 2023-02-09T01:00:09.256036+00:00 0:00:03.776396 336239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T01:00:03.161109+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T23:00:00+00:00 TriggerDagRunOperator 2023-02-09T00:10:57.968600+00:00 2023-02-09T00:10:58.468666+00:00 0:00:00.500066 336226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T00:10:55.405228+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T23:00:00+00:00 TriggerDagRunOperator 2023-02-09T00:10:57.728746+00:00 2023-02-09T00:10:58.260224+00:00 0:00:00.531478 336225 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T00:10:55.405257+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T23:00:00+00:00 EmrJobFlowSensor 2023-02-09T00:00:50.208267+00:00 2023-02-09T00:10:52.032294+00:00 0:10:01.824027 336217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T00:00:47.891137+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T00:00:28.254663+00:00 2023-02-09T00:00:29.112547+00:00 0:00:00.857884 336215 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T00:00:25.870865+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T23:00:00+00:00 PythonOperator 2023-02-09T00:00:08.294179+00:00 2023-02-09T00:00:11.273037+00:00 0:00:02.978858 336213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T00:00:05.852274+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T22:00:00+00:00 TriggerDagRunOperator 2023-02-08T23:11:18.673989+00:00 2023-02-08T23:11:19.527653+00:00 0:00:00.853664 336199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T23:11:16.102790+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T22:00:00+00:00 TriggerDagRunOperator 2023-02-08T23:11:18.614498+00:00 2023-02-08T23:11:19.406429+00:00 0:00:00.791931 336198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T23:11:16.102819+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T22:00:00+00:00 EmrJobFlowSensor 2023-02-08T23:00:58.204756+00:00 2023-02-08T23:11:00.125834+00:00 0:10:01.921078 336191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T23:00:55.650820+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T23:00:37.832524+00:00 2023-02-08T23:00:38.641250+00:00 0:00:00.808726 336188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T23:00:35.626483+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T22:00:00+00:00 PythonOperator 2023-02-08T23:00:16.052833+00:00 2023-02-08T23:00:19.863701+00:00 0:00:03.810868 336185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T23:00:13.580813+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T21:00:00+00:00 TriggerDagRunOperator 2023-02-08T22:11:08.697707+00:00 2023-02-08T22:11:09.171524+00:00 0:00:00.473817 336170 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T22:11:05.919126+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T21:00:00+00:00 TriggerDagRunOperator 2023-02-08T22:11:08.453885+00:00 2023-02-08T22:11:08.905152+00:00 0:00:00.451267 336169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T22:11:05.919078+00:00 2 default_pool