Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T19:00:35.227116+00:00 2023-05-25T19:00:36.149725+00:00 0:00:00.922609 385759 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T19:00:33.103635+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T18:00:00+00:00 PythonOperator 2023-05-25T19:00:13.170111+00:00 2023-05-25T19:00:14.110110+00:00 0:00:00.939999 385758 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T19:00:11.081309+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T17:00:00+00:00 TriggerDagRunOperator 2023-05-25T18:11:08.774442+00:00 2023-05-25T18:11:09.398786+00:00 0:00:00.624344 385745 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T18:11:06.710867+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T17:00:00+00:00 TriggerDagRunOperator 2023-05-25T18:11:08.771352+00:00 2023-05-25T18:11:09.401494+00:00 0:00:00.630142 385744 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T18:11:06.710840+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T17:00:00+00:00 EmrJobFlowSensor 2023-05-25T18:00:50.646473+00:00 2023-05-25T18:10:52.399943+00:00 0:10:01.753470 385736 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T18:00:48.643588+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T18:00:30.653340+00:00 2023-05-25T18:00:31.511100+00:00 0:00:00.857760 385735 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T18:00:28.615394+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T17:00:00+00:00 PythonOperator 2023-05-25T18:00:08.736665+00:00 2023-05-25T18:00:10.042074+00:00 0:00:01.305409 385733 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T18:00:06.595823+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T16:00:00+00:00 TriggerDagRunOperator 2023-05-25T17:11:08.096809+00:00 2023-05-25T17:11:08.614008+00:00 0:00:00.517199 385723 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T17:11:05.708979+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T16:00:00+00:00 TriggerDagRunOperator 2023-05-25T17:11:08.064172+00:00 2023-05-25T17:11:08.556602+00:00 0:00:00.492430 385722 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T17:11:05.709006+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T16:00:00+00:00 EmrJobFlowSensor 2023-05-25T17:00:52.591467+00:00 2023-05-25T17:10:54.361331+00:00 0:10:01.769864 385712 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T17:00:50.489345+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T17:00:32.563672+00:00 2023-05-25T17:00:33.613673+00:00 0:00:01.050001 385711 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T17:00:30.470641+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T16:00:00+00:00 PythonOperator 2023-05-25T17:00:10.614722+00:00 2023-05-25T17:00:11.541970+00:00 0:00:00.927248 385709 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T17:00:08.449869+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T15:00:00+00:00 TriggerDagRunOperator 2023-05-25T16:40:12.919588+00:00 2023-05-25T16:40:13.361378+00:00 0:00:00.441790 385701 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T16:40:10.823650+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T15:00:00+00:00 TriggerDagRunOperator 2023-05-25T16:40:12.842443+00:00 2023-05-25T16:40:13.298080+00:00 0:00:00.455637 385700 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T16:40:10.823681+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T15:00:00+00:00 EmrJobFlowSensor 2023-05-25T16:39:53.016714+00:00 2023-05-25T16:39:53.587877+00:00 0:00:00.571163 385699 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T16:39:50.813490+00:00 3 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T16:02:45.828457+00:00 2023-05-25T16:02:46.750866+00:00 0:00:00.922409 385690 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T16:02:42.806470+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T15:00:00+00:00 PythonOperator 2023-05-25T16:02:23.114380+00:00 2023-05-25T16:02:24.550044+00:00 0:00:01.435664 385688 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T16:02:20.720895+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T14:00:00+00:00 TriggerDagRunOperator 2023-05-25T15:11:01.193281+00:00 2023-05-25T15:11:01.702937+00:00 0:00:00.509656 385679 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T15:10:58.685639+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T14:00:00+00:00 TriggerDagRunOperator 2023-05-25T15:11:01.122501+00:00 2023-05-25T15:11:01.583193+00:00 0:00:00.460692 385678 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T15:10:58.685682+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T14:00:00+00:00 EmrJobFlowSensor 2023-05-25T15:00:51.603129+00:00 2023-05-25T15:10:53.790646+00:00 0:10:02.187517 385671 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T15:00:49.114915+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T15:00:31.694656+00:00 2023-05-25T15:00:32.779156+00:00 0:00:01.084500 385670 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T15:00:29.101182+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T14:00:00+00:00 PythonOperator 2023-05-25T15:00:10.101453+00:00 2023-05-25T15:00:12.268398+00:00 0:00:02.166945 385667 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T15:00:07.085805+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T13:00:00+00:00 TriggerDagRunOperator 2023-05-25T14:11:44.013932+00:00 2023-05-25T14:11:44.459931+00:00 0:00:00.445999 385659 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T14:11:41.094939+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T13:00:00+00:00 TriggerDagRunOperator 2023-05-25T14:11:43.996887+00:00 2023-05-25T14:11:44.451558+00:00 0:00:00.454671 385658 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T14:11:41.094980+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T13:00:00+00:00 EmrJobFlowSensor 2023-05-25T14:00:55.851639+00:00 2023-05-25T14:10:57.753350+00:00 0:10:01.901711 385651 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T14:00:53.416477+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T14:00:33.693615+00:00 2023-05-25T14:00:34.681492+00:00 0:00:00.987877 385649 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T14:00:31.395914+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T13:00:00+00:00 PythonOperator 2023-05-25T14:00:13.668187+00:00 2023-05-25T14:00:14.809406+00:00 0:00:01.141219 385647 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T14:00:11.334052+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T12:00:00+00:00 TriggerDagRunOperator 2023-05-25T13:14:59.176165+00:00 2023-05-25T13:14:59.736404+00:00 0:00:00.560239 385635 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T13:14:56.358927+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T12:00:00+00:00 TriggerDagRunOperator 2023-05-25T13:14:59.146843+00:00 2023-05-25T13:14:59.744799+00:00 0:00:00.597956 385634 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T13:14:56.358896+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T12:00:00+00:00 EmrJobFlowSensor 2023-05-25T13:00:52.582063+00:00 2023-05-25T13:10:54.466676+00:00 0:10:01.884613 385630 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T13:00:50.091545+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T13:00:30.548417+00:00 2023-05-25T13:00:31.412995+00:00 0:00:00.864578 385628 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T13:00:27.997305+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T12:00:00+00:00 PythonOperator 2023-05-25T13:00:10.722255+00:00 2023-05-25T13:00:11.903751+00:00 0:00:01.181496 385626 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T13:00:07.998182+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T11:00:00+00:00 TriggerDagRunOperator 2023-05-25T12:11:35.099281+00:00 2023-05-25T12:11:35.554508+00:00 0:00:00.455227 385618 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T12:11:32.485028+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T11:00:00+00:00 TriggerDagRunOperator 2023-05-25T12:11:35.089776+00:00 2023-05-25T12:11:35.579104+00:00 0:00:00.489328 385617 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T12:11:32.484981+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T11:00:00+00:00 EmrJobFlowSensor 2023-05-25T12:01:09.560579+00:00 2023-05-25T12:11:11.493966+00:00 0:10:01.933387 385611 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T12:01:07.215879+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T12:00:49.429685+00:00 2023-05-25T12:00:50.411540+00:00 0:00:00.981855 385609 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T12:00:47.157093+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T11:00:00+00:00 PythonOperator 2023-05-25T12:00:27.362823+00:00 2023-05-25T12:00:28.561532+00:00 0:00:01.198709 385607 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T12:00:25.139762+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T10:00:00+00:00 TriggerDagRunOperator 2023-05-25T11:11:11.997824+00:00 2023-05-25T11:11:12.447295+00:00 0:00:00.449471 385596 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T11:11:09.408125+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T10:00:00+00:00 TriggerDagRunOperator 2023-05-25T11:11:11.906554+00:00 2023-05-25T11:11:12.373909+00:00 0:00:00.467355 385595 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T11:11:09.408095+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T10:00:00+00:00 EmrJobFlowSensor 2023-05-25T11:01:04.456106+00:00 2023-05-25T11:11:06.410267+00:00 0:10:01.954161 385588 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T11:01:01.989360+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T11:00:42.374362+00:00 2023-05-25T11:00:43.296417+00:00 0:00:00.922055 385586 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T11:00:39.987845+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T10:00:00+00:00 PythonOperator 2023-05-25T11:00:20.108788+00:00 2023-05-25T11:00:21.278785+00:00 0:00:01.169997 385584 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T11:00:17.870318+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T09:00:00+00:00 TriggerDagRunOperator 2023-05-25T10:11:14.059222+00:00 2023-05-25T10:11:14.553213+00:00 0:00:00.493991 385574 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T10:11:11.614539+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T09:00:00+00:00 TriggerDagRunOperator 2023-05-25T10:11:13.995157+00:00 2023-05-25T10:11:14.495897+00:00 0:00:00.500740 385573 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T10:11:11.614504+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T09:00:00+00:00 EmrJobFlowSensor 2023-05-25T10:01:01.322366+00:00 2023-05-25T10:11:03.335861+00:00 0:10:02.013495 385567 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T10:00:59.052965+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T10:00:41.483233+00:00 2023-05-25T10:00:42.448485+00:00 0:00:00.965252 385565 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T10:00:39.101322+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T09:00:00+00:00 PythonOperator 2023-05-25T10:00:19.451306+00:00 2023-05-25T10:00:20.661980+00:00 0:00:01.210674 385563 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T10:00:17.081993+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T08:00:00+00:00 TriggerDagRunOperator 2023-05-25T09:11:10.661675+00:00 2023-05-25T09:11:11.175090+00:00 0:00:00.513415 385552 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T09:11:07.758163+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T08:00:00+00:00 TriggerDagRunOperator 2023-05-25T09:11:10.618900+00:00 2023-05-25T09:11:11.180460+00:00 0:00:00.561560 385551 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T09:11:07.758135+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T08:00:00+00:00 EmrJobFlowSensor 2023-05-25T09:00:54.440385+00:00 2023-05-25T09:10:56.341550+00:00 0:10:01.901165 385545 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T09:00:51.626486+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T09:00:31.867067+00:00 2023-05-25T09:00:32.855493+00:00 0:00:00.988426 385543 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T09:00:29.609077+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T08:00:00+00:00 PythonOperator 2023-05-25T09:00:11.749134+00:00 2023-05-25T09:00:12.934610+00:00 0:00:01.185476 385541 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T09:00:09.550297+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T07:00:00+00:00 TriggerDagRunOperator 2023-05-25T08:11:53.746019+00:00 2023-05-25T08:11:54.266665+00:00 0:00:00.520646 385529 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T08:11:51.006770+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T07:00:00+00:00 TriggerDagRunOperator 2023-05-25T08:11:53.522253+00:00 2023-05-25T08:11:54.010656+00:00 0:00:00.488403 385528 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T08:11:51.006743+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T07:00:00+00:00 EmrJobFlowSensor 2023-05-25T08:01:27.660660+00:00 2023-05-25T08:11:29.631800+00:00 0:10:01.971140 385521 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T08:01:25.422557+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T08:01:05.938325+00:00 2023-05-25T08:01:07.182682+00:00 0:00:01.244357 385519 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T08:01:03.409819+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T07:00:00+00:00 PythonOperator 2023-05-25T08:00:44.300942+00:00 2023-05-25T08:00:46.326952+00:00 0:00:02.026010 385517 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T08:00:41.382691+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T06:00:00+00:00 TriggerDagRunOperator 2023-05-25T07:23:15.754983+00:00 2023-05-25T07:23:16.219650+00:00 0:00:00.464667 385508 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T07:23:13.261904+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T06:00:00+00:00 TriggerDagRunOperator 2023-05-25T07:23:15.636989+00:00 2023-05-25T07:23:16.089600+00:00 0:00:00.452611 385507 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T07:23:13.261933+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T06:00:00+00:00 EmrJobFlowSensor 2023-05-25T07:01:07.110271+00:00 2023-05-25T07:11:09.053408+00:00 0:10:01.943137 385500 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T07:01:04.804347+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T07:00:45.333219+00:00 2023-05-25T07:00:46.257130+00:00 0:00:00.923911 385498 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T07:00:42.804997+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T06:00:00+00:00 PythonOperator 2023-05-25T07:00:25.185212+00:00 2023-05-25T07:00:26.317661+00:00 0:00:01.132449 385496 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T07:00:22.732574+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T05:00:00+00:00 TriggerDagRunOperator 2023-05-25T06:11:02.712204+00:00 2023-05-25T06:11:03.182001+00:00 0:00:00.469797 385485 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T06:11:00.255398+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T05:00:00+00:00 TriggerDagRunOperator 2023-05-25T06:11:02.635817+00:00 2023-05-25T06:11:03.126654+00:00 0:00:00.490837 385484 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T06:11:00.255424+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T05:00:00+00:00 EmrJobFlowSensor 2023-05-25T06:00:47.302740+00:00 2023-05-25T06:10:49.282007+00:00 0:10:01.979267 385477 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T06:00:44.809510+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T06:00:26.987868+00:00 2023-05-25T06:00:27.986804+00:00 0:00:00.998936 385475 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T06:00:24.735281+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T05:00:00+00:00 PythonOperator 2023-05-25T06:00:05.351026+00:00 2023-05-25T06:00:06.466291+00:00 0:00:01.115265 385473 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T06:00:02.790036+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T04:00:00+00:00 TriggerDagRunOperator 2023-05-25T05:11:22.849200+00:00 2023-05-25T05:11:23.339516+00:00 0:00:00.490316 385462 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T05:11:20.318771+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T04:00:00+00:00 TriggerDagRunOperator 2023-05-25T05:11:22.859860+00:00 2023-05-25T05:11:23.321702+00:00 0:00:00.461842 385461 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T05:11:20.318734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T04:00:00+00:00 EmrJobFlowSensor 2023-05-25T05:00:59.803617+00:00 2023-05-25T05:11:02.220317+00:00 0:10:02.416700 385454 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T05:00:57.335969+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T05:00:37.577079+00:00 2023-05-25T05:00:38.577294+00:00 0:00:01.000215 385452 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T05:00:35.315508+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T04:00:00+00:00 PythonOperator 2023-05-25T05:00:15.656654+00:00 2023-05-25T05:00:16.847899+00:00 0:00:01.191245 385450 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T05:00:13.257061+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T03:00:00+00:00 TriggerDagRunOperator 2023-05-25T04:16:14.295761+00:00 2023-05-25T04:16:14.741909+00:00 0:00:00.446148 385441 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T04:16:11.457546+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T03:00:00+00:00 TriggerDagRunOperator 2023-05-25T04:16:14.169207+00:00 2023-05-25T04:16:14.659742+00:00 0:00:00.490535 385440 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T04:16:11.457516+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T03:00:00+00:00 EmrJobFlowSensor 2023-05-25T04:00:59.086587+00:00 2023-05-25T04:11:01.098506+00:00 0:10:02.011919 385433 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T04:00:56.529188+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T04:00:39.910676+00:00 2023-05-25T04:00:40.857058+00:00 0:00:00.946382 385431 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T04:00:36.411391+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T03:00:00+00:00 PythonOperator 2023-05-25T04:00:16.617724+00:00 2023-05-25T04:00:17.648391+00:00 0:00:01.030667 385429 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T04:00:14.318335+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T02:00:00+00:00 TriggerDagRunOperator 2023-05-25T03:11:15.355435+00:00 2023-05-25T03:11:15.878447+00:00 0:00:00.523012 385418 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T03:11:12.543736+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T02:00:00+00:00 TriggerDagRunOperator 2023-05-25T03:11:15.025214+00:00 2023-05-25T03:11:15.494457+00:00 0:00:00.469243 385417 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T03:11:12.543707+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T02:00:00+00:00 EmrJobFlowSensor 2023-05-25T03:00:48.777906+00:00 2023-05-25T03:10:50.666861+00:00 0:10:01.888955 385409 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T03:00:46.455735+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T03:00:26.748443+00:00 2023-05-25T03:00:27.674356+00:00 0:00:00.925913 385408 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T03:00:24.443417+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T02:00:00+00:00 PythonOperator 2023-05-25T03:00:06.900706+00:00 2023-05-25T03:00:08.086502+00:00 0:00:01.185796 385406 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T03:00:04.489334+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T01:00:00+00:00 TriggerDagRunOperator 2023-05-25T02:11:08.606555+00:00 2023-05-25T02:11:09.100757+00:00 0:00:00.494202 385395 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T02:11:06.044869+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T01:00:00+00:00 TriggerDagRunOperator 2023-05-25T02:11:08.458666+00:00 2023-05-25T02:11:09.021897+00:00 0:00:00.563231 385394 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T02:11:06.044840+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T01:00:00+00:00 EmrJobFlowSensor 2023-05-25T02:01:02.095002+00:00 2023-05-25T02:11:04.068668+00:00 0:10:01.973666 385386 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T02:00:59.838167+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T02:00:42.069434+00:00 2023-05-25T02:00:43.142325+00:00 0:00:01.072891 385384 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T02:00:39.807639+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T01:00:00+00:00 PythonOperator 2023-05-25T02:00:18.366192+00:00 2023-05-25T02:00:19.556042+00:00 0:00:01.189850 385382 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T02:00:15.748225+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-25T00:00:00+00:00 TriggerDagRunOperator 2023-05-25T01:11:07.156772+00:00 2023-05-25T01:11:07.616485+00:00 0:00:00.459713 385362 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T01:11:04.527108+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-25T00:00:00+00:00 TriggerDagRunOperator 2023-05-25T01:11:07.141300+00:00 2023-05-25T01:11:07.618658+00:00 0:00:00.477358 385361 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T01:11:04.527063+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-25T00:00:00+00:00 EmrJobFlowSensor 2023-05-25T01:00:56.340590+00:00 2023-05-25T01:10:58.203425+00:00 0:10:01.862835 385354 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T01:00:54.106524+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-25T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T01:00:34.302683+00:00 2023-05-25T01:00:35.274421+00:00 0:00:00.971738 385352 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T01:00:31.977056+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-25T00:00:00+00:00 PythonOperator 2023-05-25T01:00:14.194161+00:00 2023-05-25T01:00:15.260143+00:00 0:00:01.065982 385350 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T01:00:11.960416+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T23:00:00+00:00 TriggerDagRunOperator 2023-05-25T00:11:16.729461+00:00 2023-05-25T00:11:17.195658+00:00 0:00:00.466197 385339 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T00:11:14.223121+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T23:00:00+00:00 TriggerDagRunOperator 2023-05-25T00:11:16.707313+00:00 2023-05-25T00:11:17.209038+00:00 0:00:00.501725 385338 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-25T00:11:14.223150+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T23:00:00+00:00 EmrJobFlowSensor 2023-05-25T00:01:00.368303+00:00 2023-05-25T00:11:02.786173+00:00 0:10:02.417870 385330 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-25T00:00:57.795650+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-24T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-25T00:00:38.197826+00:00 2023-05-25T00:00:39.231850+00:00 0:00:01.034024 385328 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-25T00:00:35.793911+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-24T23:00:00+00:00 PythonOperator 2023-05-25T00:00:16.568008+00:00 2023-05-25T00:00:17.608111+00:00 0:00:01.040103 385326 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-25T00:00:13.703194+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-24T22:00:00+00:00 TriggerDagRunOperator 2023-05-24T23:11:02.067925+00:00 2023-05-24T23:11:02.530249+00:00 0:00:00.462324 385316 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T23:10:59.508561+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-24T22:00:00+00:00 TriggerDagRunOperator 2023-05-24T23:11:01.933622+00:00 2023-05-24T23:11:02.416372+00:00 0:00:00.482750 385315 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-24T23:10:59.508590+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-24T22:00:00+00:00 EmrJobFlowSensor 2023-05-24T23:00:51.875959+00:00 2023-05-24T23:10:53.761365+00:00 0:10:01.885406 385306 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-24T23:00:49.616456+00:00 2 default_pool