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 trigger_dagrun_booking-processing-job_v002 2023-04-07T23:00:00+00:00 TriggerDagRunOperator 2023-04-08T00:20:23.942616+00:00 2023-04-08T00:20:24.493427+00:00 0:00:00.550811 365629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-08T00:20:21.196808+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T23:00:00+00:00 EmrJobFlowSensor 2023-04-08T00:08:01.843854+00:00 2023-04-08T00:18:03.662425+00:00 0:10:01.818571 365625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-08T00:07:59.511913+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-08T00:07:40.301994+00:00 2023-04-08T00:07:41.143381+00:00 0:00:00.841387 365622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-08T00:07:37.493383+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T23:00:00+00:00 PythonOperator 2023-04-08T00:07:20.590223+00:00 2023-04-08T00:07:25.157404+00:00 0:00:04.567181 365619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-08T00:07:17.476664+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T22:00:00+00:00 TriggerDagRunOperator 2023-04-07T23:11:01.396350+00:00 2023-04-07T23:11:01.915501+00:00 0:00:00.519151 365607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T23:10:58.813944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T22:00:00+00:00 TriggerDagRunOperator 2023-04-07T23:11:01.234341+00:00 2023-04-07T23:11:01.769439+00:00 0:00:00.535098 365606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T23:10:58.813979+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T22:00:00+00:00 EmrJobFlowSensor 2023-04-07T23:00:53.844462+00:00 2023-04-07T23:10:55.521746+00:00 0:10:01.677284 365600 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T23:00:51.539612+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T22:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T23:00:33.732593+00:00 2023-04-07T23:00:34.552639+00:00 0:00:00.820046 365597 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T23:00:31.444051+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T22:00:00+00:00 PythonOperator 2023-04-07T23:00:11.650913+00:00 2023-04-07T23:00:15.648194+00:00 0:00:03.997281 365594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T23:00:09.423884+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T21:00:00+00:00 TriggerDagRunOperator 2023-04-07T22:14:24.918585+00:00 2023-04-07T22:14:25.396879+00:00 0:00:00.478294 365582 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T22:14:22.742905+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T21:00:00+00:00 TriggerDagRunOperator 2023-04-07T22:14:24.869012+00:00 2023-04-07T22:14:25.341572+00:00 0:00:00.472560 365581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T22:14:22.742871+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T21:00:00+00:00 EmrJobFlowSensor 2023-04-07T22:01:03.645020+00:00 2023-04-07T22:11:05.366655+00:00 0:10:01.721635 365576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T22:01:01.158818+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T21:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T22:00:41.750169+00:00 2023-04-07T22:00:42.676587+00:00 0:00:00.926418 365574 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T22:00:39.139794+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T21:00:00+00:00 PythonOperator 2023-04-07T22:00:21.931046+00:00 2023-04-07T22:00:26.124948+00:00 0:00:04.193902 365572 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T22:00:18.918023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T20:00:00+00:00 TriggerDagRunOperator 2023-04-07T21:11:31.155628+00:00 2023-04-07T21:11:31.695421+00:00 0:00:00.539793 365562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T21:11:28.520218+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T20:00:00+00:00 TriggerDagRunOperator 2023-04-07T21:11:30.846340+00:00 2023-04-07T21:11:31.337255+00:00 0:00:00.490915 365561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T21:11:28.520265+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T20:00:00+00:00 EmrJobFlowSensor 2023-04-07T21:01:05.596775+00:00 2023-04-07T21:11:07.388685+00:00 0:10:01.791910 365555 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T21:01:03.357971+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T20:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T21:00:43.609338+00:00 2023-04-07T21:00:44.514089+00:00 0:00:00.904751 365553 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T21:00:41.336769+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T20:00:00+00:00 PythonOperator 2023-04-07T21:00:21.733706+00:00 2023-04-07T21:00:25.763248+00:00 0:00:04.029542 365551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T21:00:19.292439+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T19:00:00+00:00 TriggerDagRunOperator 2023-04-07T20:11:05.880521+00:00 2023-04-07T20:11:06.411779+00:00 0:00:00.531258 365539 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T20:11:03.248342+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T19:00:00+00:00 TriggerDagRunOperator 2023-04-07T20:11:05.585668+00:00 2023-04-07T20:11:06.057785+00:00 0:00:00.472117 365538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T20:11:03.248371+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T19:00:00+00:00 EmrJobFlowSensor 2023-04-07T20:00:55.720442+00:00 2023-04-07T20:10:57.504611+00:00 0:10:01.784169 365532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T20:00:53.506145+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T19:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T20:00:35.765936+00:00 2023-04-07T20:00:36.634470+00:00 0:00:00.868534 365530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T20:00:33.407558+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T19:00:00+00:00 PythonOperator 2023-04-07T20:00:13.621365+00:00 2023-04-07T20:00:17.188615+00:00 0:00:03.567250 365528 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T20:00:11.260345+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T18:00:00+00:00 TriggerDagRunOperator 2023-04-07T19:11:01.233114+00:00 2023-04-07T19:11:01.730835+00:00 0:00:00.497721 365517 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T19:10:58.941103+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T18:00:00+00:00 TriggerDagRunOperator 2023-04-07T19:11:01.140602+00:00 2023-04-07T19:11:01.638849+00:00 0:00:00.498247 365516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T19:10:58.941069+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T18:00:00+00:00 EmrJobFlowSensor 2023-04-07T19:00:46.394497+00:00 2023-04-07T19:10:48.243201+00:00 0:10:01.848704 365507 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T19:00:44.024281+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T18:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T19:00:26.490396+00:00 2023-04-07T19:00:27.379347+00:00 0:00:00.888951 365506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T19:00:24.002814+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T18:00:00+00:00 PythonOperator 2023-04-07T19:00:05.416297+00:00 2023-04-07T19:00:10.938344+00:00 0:00:05.522047 365504 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T19:00:02.093657+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T17:00:00+00:00 TriggerDagRunOperator 2023-04-07T18:16:51.999369+00:00 2023-04-07T18:16:52.483793+00:00 0:00:00.484424 365495 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T18:16:48.916775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T17:00:00+00:00 TriggerDagRunOperator 2023-04-07T18:16:51.817709+00:00 2023-04-07T18:16:52.265311+00:00 0:00:00.447602 365494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T18:16:48.916819+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T17:00:00+00:00 EmrJobFlowSensor 2023-04-07T18:06:25.923492+00:00 2023-04-07T18:16:27.593408+00:00 0:10:01.669916 365489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T18:06:23.634110+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T17:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T18:06:05.727170+00:00 2023-04-07T18:06:06.605385+00:00 0:00:00.878215 365486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T18:06:03.598939+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T17:00:00+00:00 PythonOperator 2023-04-07T18:05:44.036265+00:00 2023-04-07T18:05:55.550495+00:00 0:00:11.514230 365483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T18:05:41.582296+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T16:00:00+00:00 TriggerDagRunOperator 2023-04-07T17:16:50.345006+00:00 2023-04-07T17:16:50.807304+00:00 0:00:00.462298 365475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T17:16:47.217908+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T16:00:00+00:00 TriggerDagRunOperator 2023-04-07T17:16:50.000838+00:00 2023-04-07T17:16:50.477794+00:00 0:00:00.476956 365474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T17:16:47.217865+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T16:00:00+00:00 EmrJobFlowSensor 2023-04-07T17:06:25.365391+00:00 2023-04-07T17:16:27.070075+00:00 0:10:01.704684 365471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T17:06:23.216300+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T16:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T17:06:03.394937+00:00 2023-04-07T17:06:04.250499+00:00 0:00:00.855562 365468 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T17:06:01.193202+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T16:00:00+00:00 PythonOperator 2023-04-07T17:05:41.840836+00:00 2023-04-07T17:05:46.011292+00:00 0:00:04.170456 365465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T17:05:39.177982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T15:00:00+00:00 TriggerDagRunOperator 2023-04-07T16:30:23.275133+00:00 2023-04-07T16:30:23.786929+00:00 0:00:00.511796 365457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T16:30:20.660469+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T15:00:00+00:00 TriggerDagRunOperator 2023-04-07T16:30:23.048004+00:00 2023-04-07T16:30:23.513202+00:00 0:00:00.465198 365456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T16:30:20.660497+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T15:00:00+00:00 EmrJobFlowSensor 2023-04-07T16:19:59.983847+00:00 2023-04-07T16:30:01.966305+00:00 0:10:01.982458 365452 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T16:19:57.788705+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T15:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T16:19:42.900608+00:00 2023-04-07T16:19:44.696949+00:00 0:00:01.796341 365448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T16:19:35.766950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T14:00:00+00:00 TriggerDagRunOperator 2023-04-07T16:19:18.792923+00:00 2023-04-07T16:19:19.446715+00:00 0:00:00.653792 365444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T16:19:13.729268+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T15:00:00+00:00 PythonOperator 2023-04-07T16:19:18.780078+00:00 2023-04-07T16:19:24.009487+00:00 0:00:05.229409 365443 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T16:19:13.729314+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T14:00:00+00:00 TriggerDagRunOperator 2023-04-07T16:19:15.929587+00:00 2023-04-07T16:19:16.355232+00:00 0:00:00.425645 365442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T16:19:13.729300+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T14:00:00+00:00 EmrJobFlowSensor 2023-04-07T15:55:00.576318+00:00 2023-04-07T16:05:02.313278+00:00 0:10:01.736960 365436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T15:54:58.359890+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T14:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T15:54:38.998710+00:00 2023-04-07T15:54:39.894752+00:00 0:00:00.896042 365432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T15:54:36.331947+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T14:00:00+00:00 PythonOperator 2023-04-07T15:54:20.570526+00:00 2023-04-07T15:54:24.746491+00:00 0:00:04.175965 365428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T15:54:16.315058+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T13:00:00+00:00 TriggerDagRunOperator 2023-04-07T15:54:20.431565+00:00 2023-04-07T15:54:20.957140+00:00 0:00:00.525575 365427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T15:54:16.315045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T13:00:00+00:00 TriggerDagRunOperator 2023-04-07T15:54:18.597854+00:00 2023-04-07T15:54:19.060487+00:00 0:00:00.462633 365426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T15:54:16.315011+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T13:00:00+00:00 EmrJobFlowSensor 2023-04-07T14:09:30.579808+00:00 2023-04-07T14:19:32.478143+00:00 0:10:01.898335 365419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T14:09:28.163698+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T13:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T14:09:09.335295+00:00 2023-04-07T14:09:10.156929+00:00 0:00:00.821634 365416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T14:09:06.146395+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T13:00:00+00:00 PythonOperator 2023-04-07T14:08:46.730408+00:00 2023-04-07T14:08:53.147958+00:00 0:00:06.417550 365413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T14:08:44.206083+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T12:00:00+00:00 TriggerDagRunOperator 2023-04-07T13:31:44.828848+00:00 2023-04-07T13:31:45.393986+00:00 0:00:00.565138 365406 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T13:31:40.689387+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T12:00:00+00:00 TriggerDagRunOperator 2023-04-07T13:31:42.915723+00:00 2023-04-07T13:31:43.353494+00:00 0:00:00.437771 365405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T13:31:40.689337+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T12:00:00+00:00 EmrJobFlowSensor 2023-04-07T13:01:07.201982+00:00 2023-04-07T13:11:08.931329+00:00 0:10:01.729347 365400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T13:01:04.704151+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T12:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T13:00:46.859900+00:00 2023-04-07T13:00:47.650551+00:00 0:00:00.790651 365398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T13:00:44.665438+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T12:00:00+00:00 PythonOperator 2023-04-07T13:00:25.263960+00:00 2023-04-07T13:00:29.449689+00:00 0:00:04.185729 365396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T13:00:22.700059+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T11:00:00+00:00 TriggerDagRunOperator 2023-04-07T12:48:06.847178+00:00 2023-04-07T12:48:07.352859+00:00 0:00:00.505681 365391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T12:48:04.431163+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T11:00:00+00:00 TriggerDagRunOperator 2023-04-07T12:48:06.833794+00:00 2023-04-07T12:48:07.293818+00:00 0:00:00.460024 365390 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T12:48:04.431134+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T11:00:00+00:00 EmrJobFlowSensor 2023-04-07T12:02:45.490496+00:00 2023-04-07T12:12:47.508274+00:00 0:10:02.017778 365383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T12:02:43.227298+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T11:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T12:02:23.501722+00:00 2023-04-07T12:02:24.668360+00:00 0:00:01.166638 365381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T12:02:21.186699+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T11:00:00+00:00 PythonOperator 2023-04-07T12:02:03.729987+00:00 2023-04-07T12:02:07.875207+00:00 0:00:04.145220 365379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T12:02:01.222731+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T10:00:00+00:00 TriggerDagRunOperator 2023-04-07T11:46:44.005572+00:00 2023-04-07T11:46:44.530439+00:00 0:00:00.524867 365373 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T11:46:41.096669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T10:00:00+00:00 TriggerDagRunOperator 2023-04-07T11:46:43.701539+00:00 2023-04-07T11:46:44.214372+00:00 0:00:00.512833 365372 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T11:46:41.096635+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T10:00:00+00:00 EmrJobFlowSensor 2023-04-07T11:15:30.309313+00:00 2023-04-07T11:25:32.162650+00:00 0:10:01.853337 365368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T11:15:28.073074+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T10:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T11:15:08.258514+00:00 2023-04-07T11:15:09.191142+00:00 0:00:00.932628 365365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T11:15:06.058720+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T10:00:00+00:00 PythonOperator 2023-04-07T11:14:50.103674+00:00 2023-04-07T11:14:54.648939+00:00 0:00:04.545265 365362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T11:14:46.048128+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T09:00:00+00:00 TriggerDagRunOperator 2023-04-07T10:11:21.231268+00:00 2023-04-07T10:11:21.748715+00:00 0:00:00.517447 365354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T10:11:18.908963+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T09:00:00+00:00 TriggerDagRunOperator 2023-04-07T10:11:21.141123+00:00 2023-04-07T10:11:21.617380+00:00 0:00:00.476257 365353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T10:11:18.908990+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T09:00:00+00:00 EmrJobFlowSensor 2023-04-07T10:01:06.852403+00:00 2023-04-07T10:11:08.737539+00:00 0:10:01.885136 365347 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T10:01:04.640189+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T09:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T10:00:44.751728+00:00 2023-04-07T10:00:46.016332+00:00 0:00:01.264604 365345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T10:00:42.580807+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T09:00:00+00:00 PythonOperator 2023-04-07T10:00:22.705880+00:00 2023-04-07T10:00:26.784781+00:00 0:00:04.078901 365343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T10:00:20.559986+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T08:00:00+00:00 TriggerDagRunOperator 2023-04-07T09:39:31.599798+00:00 2023-04-07T09:39:32.080201+00:00 0:00:00.480403 365337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T09:39:28.784950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T08:00:00+00:00 TriggerDagRunOperator 2023-04-07T09:39:31.527142+00:00 2023-04-07T09:39:31.967751+00:00 0:00:00.440609 365336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T09:39:28.784920+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T08:00:00+00:00 EmrJobFlowSensor 2023-04-07T09:03:55.846839+00:00 2023-04-07T09:13:57.514056+00:00 0:10:01.667217 365330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T09:03:53.657047+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T08:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T09:03:33.918090+00:00 2023-04-07T09:03:34.776194+00:00 0:00:00.858104 365328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T09:03:31.640599+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T08:00:00+00:00 PythonOperator 2023-04-07T09:03:11.737387+00:00 2023-04-07T09:03:14.989232+00:00 0:00:03.251845 365326 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T09:03:09.593158+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T07:00:00+00:00 TriggerDagRunOperator 2023-04-07T08:42:14.938629+00:00 2023-04-07T08:42:15.495549+00:00 0:00:00.556920 365319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T08:42:11.845330+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T07:00:00+00:00 TriggerDagRunOperator 2023-04-07T08:42:14.642857+00:00 2023-04-07T08:42:15.182218+00:00 0:00:00.539361 365318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T08:42:11.845362+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T07:00:00+00:00 EmrJobFlowSensor 2023-04-07T08:00:53.348850+00:00 2023-04-07T08:10:55.223365+00:00 0:10:01.874515 365312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T08:00:50.902739+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T07:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T08:00:31.296150+00:00 2023-04-07T08:00:32.208971+00:00 0:00:00.912821 365310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T08:00:28.803402+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T07:00:00+00:00 PythonOperator 2023-04-07T08:00:11.292420+00:00 2023-04-07T08:00:17.459601+00:00 0:00:06.167181 365308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T08:00:08.766923+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T06:00:00+00:00 TriggerDagRunOperator 2023-04-07T07:47:33.106259+00:00 2023-04-07T07:47:33.644719+00:00 0:00:00.538460 365303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T07:47:29.955639+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T06:00:00+00:00 TriggerDagRunOperator 2023-04-07T07:47:32.833823+00:00 2023-04-07T07:47:33.270975+00:00 0:00:00.437152 365302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T07:47:29.955676+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T06:00:00+00:00 EmrJobFlowSensor 2023-04-07T07:22:37.084668+00:00 2023-04-07T07:32:38.803094+00:00 0:10:01.718426 365297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T07:22:34.863561+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T06:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T07:22:15.298822+00:00 2023-04-07T07:22:16.151924+00:00 0:00:00.853102 365294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T07:22:12.841871+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T06:00:00+00:00 PythonOperator 2023-04-07T07:21:55.441032+00:00 2023-04-07T07:21:59.511613+00:00 0:00:04.070581 365291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T07:21:52.876620+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T05:00:00+00:00 TriggerDagRunOperator 2023-04-07T06:36:30.396850+00:00 2023-04-07T06:36:30.899049+00:00 0:00:00.502199 365285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T06:36:27.534931+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T05:00:00+00:00 TriggerDagRunOperator 2023-04-07T06:36:30.261416+00:00 2023-04-07T06:36:30.757788+00:00 0:00:00.496372 365284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T06:36:27.534903+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T05:00:00+00:00 EmrJobFlowSensor 2023-04-07T06:06:52.929883+00:00 2023-04-07T06:16:54.655377+00:00 0:10:01.725494 365279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T06:06:50.711383+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T05:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T06:06:30.829271+00:00 2023-04-07T06:06:31.646904+00:00 0:00:00.817633 365276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T06:06:28.657051+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T05:00:00+00:00 PythonOperator 2023-04-07T06:06:09.143263+00:00 2023-04-07T06:06:18.013933+00:00 0:00:08.870670 365273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T06:06:06.630131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-07T04:00:00+00:00 TriggerDagRunOperator 2023-04-07T05:13:29.746888+00:00 2023-04-07T05:13:30.297750+00:00 0:00:00.550862 365264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T05:13:27.369020+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T04:00:00+00:00 TriggerDagRunOperator 2023-04-07T05:13:29.735937+00:00 2023-04-07T05:13:30.257442+00:00 0:00:00.521505 365263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T05:13:27.369050+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-07T04:00:00+00:00 EmrJobFlowSensor 2023-04-07T05:03:20.324015+00:00 2023-04-07T05:13:22.128667+00:00 0:10:01.804652 365257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-07T05:03:18.131869+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-07T04:00:00+00:00 EmrCreateJobFlowOperator 2023-04-07T05:02:59.026721+00:00 2023-04-07T05:02:59.989177+00:00 0:00:00.962456 365255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-07T05:02:56.161976+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-07T04:00:00+00:00 PythonOperator 2023-04-07T05:00:17.413030+00:00 2023-04-07T05:00:21.469469+00:00 0:00:04.056439 365252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-07T05:00:15.266693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-07T03:00:00+00:00 TriggerDagRunOperator 2023-04-07T04:34:40.191489+00:00 2023-04-07T04:34:40.693809+00:00 0:00:00.502320 365245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-07T04:34:37.583011+00:00 2 default_pool