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-04-29T02:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T03:00:26.145698+00:00 2023-04-29T03:00:26.972807+00:00 0:00:00.827109 369745 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T03:00:23.881818+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T02:00:00+00:00 PythonOperator 2023-04-29T03:00:06.584876+00:00 2023-04-29T03:00:07.460963+00:00 0:00:00.876087 369743 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T03:00:03.385476+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T01:00:00+00:00 TriggerDagRunOperator 2023-04-29T02:11:22.498669+00:00 2023-04-29T02:11:23.035611+00:00 0:00:00.536942 369733 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T02:11:19.716688+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T01:00:00+00:00 TriggerDagRunOperator 2023-04-29T02:11:21.884585+00:00 2023-04-29T02:11:22.317472+00:00 0:00:00.432887 369732 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T02:11:19.716656+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T01:00:00+00:00 EmrJobFlowSensor 2023-04-29T02:00:57.051929+00:00 2023-04-29T02:10:58.845949+00:00 0:10:01.794020 369723 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T02:00:54.808898+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T01:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T02:00:35.498699+00:00 2023-04-29T02:00:36.234664+00:00 0:00:00.735965 369722 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T02:00:32.890624+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T01:00:00+00:00 PythonOperator 2023-04-29T02:00:15.123937+00:00 2023-04-29T02:00:16.068742+00:00 0:00:00.944805 369721 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T02:00:12.716239+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-29T00:00:00+00:00 TriggerDagRunOperator 2023-04-29T01:11:28.307120+00:00 2023-04-29T01:11:28.700807+00:00 0:00:00.393687 369703 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T01:11:25.827970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-29T00:00:00+00:00 TriggerDagRunOperator 2023-04-29T01:11:28.295615+00:00 2023-04-29T01:11:28.797396+00:00 0:00:00.501781 369702 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T01:11:25.827930+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-29T00:00:00+00:00 EmrJobFlowSensor 2023-04-29T01:01:03.660188+00:00 2023-04-29T01:11:05.543003+00:00 0:10:01.882815 369695 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T01:01:01.393995+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-29T00:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T01:00:43.573427+00:00 2023-04-29T01:00:44.430119+00:00 0:00:00.856692 369693 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T01:00:41.302820+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-29T00:00:00+00:00 PythonOperator 2023-04-29T01:00:21.562650+00:00 2023-04-29T01:00:22.423762+00:00 0:00:00.861112 369691 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T01:00:19.241449+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T23:00:00+00:00 TriggerDagRunOperator 2023-04-29T00:13:11.973874+00:00 2023-04-29T00:13:12.426999+00:00 0:00:00.453125 369678 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T00:13:09.286264+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T23:00:00+00:00 TriggerDagRunOperator 2023-04-29T00:13:11.900846+00:00 2023-04-29T00:13:12.258482+00:00 0:00:00.357636 369677 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-29T00:13:09.286309+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T23:00:00+00:00 EmrJobFlowSensor 2023-04-29T00:02:58.833562+00:00 2023-04-29T00:13:00.682648+00:00 0:10:01.849086 369671 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-29T00:02:56.732010+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-29T00:02:37.641773+00:00 2023-04-29T00:02:38.677087+00:00 0:00:01.035314 369669 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-29T00:02:34.883352+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T23:00:00+00:00 PythonOperator 2023-04-29T00:02:14.871562+00:00 2023-04-29T00:02:15.756722+00:00 0:00:00.885160 369667 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-29T00:02:12.643960+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T22:00:00+00:00 TriggerDagRunOperator 2023-04-28T23:16:59.039293+00:00 2023-04-28T23:16:59.493815+00:00 0:00:00.454522 369654 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T23:16:56.395276+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T22:00:00+00:00 TriggerDagRunOperator 2023-04-28T23:16:58.968922+00:00 2023-04-28T23:16:59.392069+00:00 0:00:00.423147 369653 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T23:16:56.395247+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T22:00:00+00:00 EmrJobFlowSensor 2023-04-28T23:06:41.914168+00:00 2023-04-28T23:16:43.849884+00:00 0:10:01.935716 369648 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T23:06:39.482628+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T22:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T23:06:22.779922+00:00 2023-04-28T23:06:23.727233+00:00 0:00:00.947311 369644 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-28T23:06:19.334135+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T22:00:00+00:00 PythonOperator 2023-04-28T23:06:00.175718+00:00 2023-04-28T23:06:01.168359+00:00 0:00:00.992641 369640 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-28T23:05:57.143944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T21:00:00+00:00 TriggerDagRunOperator 2023-04-28T22:11:27.817997+00:00 2023-04-28T22:11:28.245757+00:00 0:00:00.427760 369627 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T22:11:25.430399+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T21:00:00+00:00 TriggerDagRunOperator 2023-04-28T22:11:27.772752+00:00 2023-04-28T22:11:28.102029+00:00 0:00:00.329277 369626 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T22:11:25.430371+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T21:00:00+00:00 EmrJobFlowSensor 2023-04-28T22:00:59.716013+00:00 2023-04-28T22:11:01.812332+00:00 0:10:02.096319 369619 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T22:00:56.933454+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T21:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T22:00:37.398508+00:00 2023-04-28T22:00:38.157256+00:00 0:00:00.758748 369617 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-28T22:00:34.912604+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T21:00:00+00:00 PythonOperator 2023-04-28T22:00:15.259716+00:00 2023-04-28T22:00:16.300690+00:00 0:00:01.040974 369615 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-28T22:00:12.811470+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T20:00:00+00:00 TriggerDagRunOperator 2023-04-28T21:21:17.993336+00:00 2023-04-28T21:21:18.427269+00:00 0:00:00.433933 369603 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T21:21:15.599059+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T20:00:00+00:00 TriggerDagRunOperator 2023-04-28T21:21:17.944522+00:00 2023-04-28T21:21:18.278354+00:00 0:00:00.333832 369602 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T21:21:15.599012+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T20:00:00+00:00 EmrJobFlowSensor 2023-04-28T21:20:56.039966+00:00 2023-04-28T21:20:56.583318+00:00 0:00:00.543352 369600 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T21:20:53.509575+00:00 3 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T20:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T21:06:52.820272+00:00 2023-04-28T21:06:53.643764+00:00 0:00:00.823492 369594 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-28T21:06:50.406140+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T20:00:00+00:00 PythonOperator 2023-04-28T21:06:30.579441+00:00 2023-04-28T21:06:31.607332+00:00 0:00:01.027891 369590 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-28T21:06:28.323201+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T19:00:00+00:00 TriggerDagRunOperator 2023-04-28T20:11:12.205853+00:00 2023-04-28T20:11:12.642837+00:00 0:00:00.436984 369574 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T20:11:09.590687+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T19:00:00+00:00 TriggerDagRunOperator 2023-04-28T20:11:12.157148+00:00 2023-04-28T20:11:12.510350+00:00 0:00:00.353202 369573 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T20:11:09.590644+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T19:00:00+00:00 EmrJobFlowSensor 2023-04-28T20:00:48.573170+00:00 2023-04-28T20:10:50.380937+00:00 0:10:01.807767 369565 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T20:00:46.468344+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T19:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T20:00:26.649016+00:00 2023-04-28T20:00:27.415156+00:00 0:00:00.766140 369563 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-28T20:00:24.447608+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T19:00:00+00:00 PythonOperator 2023-04-28T20:00:07.199261+00:00 2023-04-28T20:00:08.072828+00:00 0:00:00.873567 369561 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-28T20:00:04.087182+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T18:00:00+00:00 TriggerDagRunOperator 2023-04-28T19:11:14.636368+00:00 2023-04-28T19:11:15.144032+00:00 0:00:00.507664 369545 airflow-worker-4.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T19:11:12.114570+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T18:00:00+00:00 TriggerDagRunOperator 2023-04-28T19:11:14.584578+00:00 2023-04-28T19:11:15.040491+00:00 0:00:00.455913 369544 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T19:11:12.114604+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T18:00:00+00:00 EmrJobFlowSensor 2023-04-28T19:00:49.366530+00:00 2023-04-28T19:10:51.123755+00:00 0:10:01.757225 369537 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T19:00:47.091349+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T18:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T19:00:27.222229+00:00 2023-04-28T19:00:27.957515+00:00 0:00:00.735286 369536 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-28T19:00:25.013077+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T18:00:00+00:00 PythonOperator 2023-04-28T19:00:07.462653+00:00 2023-04-28T19:00:08.369057+00:00 0:00:00.906404 369534 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-28T19:00:04.950220+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T17:00:00+00:00 TriggerDagRunOperator 2023-04-28T18:11:04.169986+00:00 2023-04-28T18:11:04.505031+00:00 0:00:00.335045 369521 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T18:11:01.992102+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T17:00:00+00:00 TriggerDagRunOperator 2023-04-28T18:11:04.176176+00:00 2023-04-28T18:11:04.648087+00:00 0:00:00.471911 369520 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T18:11:01.992143+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T17:00:00+00:00 EmrJobFlowSensor 2023-04-28T18:00:49.078814+00:00 2023-04-28T18:10:50.880473+00:00 0:10:01.801659 369512 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T18:00:46.916255+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T17:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T18:00:27.214303+00:00 2023-04-28T18:00:27.971866+00:00 0:00:00.757563 369511 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-28T18:00:24.913164+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T17:00:00+00:00 PythonOperator 2023-04-28T18:00:07.520746+00:00 2023-04-28T18:00:08.375412+00:00 0:00:00.854666 369509 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-28T18:00:04.888315+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T16:00:00+00:00 TriggerDagRunOperator 2023-04-28T17:15:07.437899+00:00 2023-04-28T17:15:07.794060+00:00 0:00:00.356161 369496 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T17:15:05.013524+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T16:00:00+00:00 TriggerDagRunOperator 2023-04-28T17:15:07.418794+00:00 2023-04-28T17:15:07.869181+00:00 0:00:00.450387 369495 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T17:15:05.013492+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T16:00:00+00:00 EmrJobFlowSensor 2023-04-28T17:04:58.440318+00:00 2023-04-28T17:15:00.304488+00:00 0:10:01.864170 369488 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T17:04:55.995114+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T16:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T17:04:36.063911+00:00 2023-04-28T17:04:36.883014+00:00 0:00:00.819103 369486 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-28T17:04:33.828539+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T16:00:00+00:00 PythonOperator 2023-04-28T17:04:16.264730+00:00 2023-04-28T17:04:17.244740+00:00 0:00:00.980010 369485 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-28T17:04:13.804233+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T15:00:00+00:00 TriggerDagRunOperator 2023-04-28T16:14:59.731523+00:00 2023-04-28T16:15:00.408497+00:00 0:00:00.676974 369472 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T16:14:57.160104+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T15:00:00+00:00 TriggerDagRunOperator 2023-04-28T16:14:59.669308+00:00 2023-04-28T16:15:00.221367+00:00 0:00:00.552059 369471 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T16:14:57.160075+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T15:00:00+00:00 EmrJobFlowSensor 2023-04-28T16:01:57.677545+00:00 2023-04-28T16:10:59.347864+00:00 0:09:01.670319 369464 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T16:01:55.026816+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T15:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T16:00:26.952037+00:00 2023-04-28T16:00:27.915468+00:00 0:00:00.963431 369461 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-28T16:00:24.127342+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T15:00:00+00:00 PythonOperator 2023-04-28T16:00:04.422230+00:00 2023-04-28T16:00:05.302592+00:00 0:00:00.880362 369459 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-28T16:00:02.074425+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T14:00:00+00:00 TriggerDagRunOperator 2023-04-28T15:18:11.211592+00:00 2023-04-28T15:18:11.564120+00:00 0:00:00.352528 369449 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T15:18:08.693323+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T14:00:00+00:00 TriggerDagRunOperator 2023-04-28T15:18:11.237068+00:00 2023-04-28T15:18:11.710037+00:00 0:00:00.472969 369448 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T15:18:08.693365+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T14:00:00+00:00 EmrJobFlowSensor 2023-04-28T15:08:01.135956+00:00 2023-04-28T15:18:02.964491+00:00 0:10:01.828535 369443 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T15:07:58.944254+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T14:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T15:07:41.205877+00:00 2023-04-28T15:07:42.366797+00:00 0:00:01.160920 369440 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-28T15:07:38.924690+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T14:00:00+00:00 PythonOperator 2023-04-28T15:07:19.185250+00:00 2023-04-28T15:07:20.053831+00:00 0:00:00.868581 369437 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-28T15:07:16.904006+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T13:00:00+00:00 TriggerDagRunOperator 2023-04-28T14:20:19.419402+00:00 2023-04-28T14:20:19.760576+00:00 0:00:00.341174 369426 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T14:20:16.502846+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T13:00:00+00:00 TriggerDagRunOperator 2023-04-28T14:20:19.432905+00:00 2023-04-28T14:20:19.869926+00:00 0:00:00.437021 369425 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T14:20:16.502799+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T13:00:00+00:00 EmrJobFlowSensor 2023-04-28T14:07:43.837951+00:00 2023-04-28T14:17:46.098995+00:00 0:10:02.261044 369420 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T14:07:41.516350+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T13:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T14:07:21.745281+00:00 2023-04-28T14:07:22.603678+00:00 0:00:00.858397 369417 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-28T14:07:19.495483+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T13:00:00+00:00 PythonOperator 2023-04-28T14:07:01.845101+00:00 2023-04-28T14:07:03.296446+00:00 0:00:01.451345 369414 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-28T14:06:59.453128+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T12:00:00+00:00 TriggerDagRunOperator 2023-04-28T13:18:04.762593+00:00 2023-04-28T13:18:05.211741+00:00 0:00:00.449148 369401 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T13:18:01.813419+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T12:00:00+00:00 TriggerDagRunOperator 2023-04-28T13:18:04.752646+00:00 2023-04-28T13:18:05.221479+00:00 0:00:00.468833 369400 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T13:18:01.813374+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T12:00:00+00:00 EmrJobFlowSensor 2023-04-28T13:07:40.279333+00:00 2023-04-28T13:17:42.139281+00:00 0:10:01.859948 369397 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T13:07:37.908588+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T12:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T13:07:18.157534+00:00 2023-04-28T13:07:19.075155+00:00 0:00:00.917621 369393 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-28T13:07:15.889443+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T12:00:00+00:00 PythonOperator 2023-04-28T13:06:58.601811+00:00 2023-04-28T13:06:59.508771+00:00 0:00:00.906960 369391 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-28T13:06:55.821805+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T11:00:00+00:00 TriggerDagRunOperator 2023-04-28T12:21:31.599884+00:00 2023-04-28T12:21:32.150648+00:00 0:00:00.550764 369378 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T12:21:28.298116+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T11:00:00+00:00 TriggerDagRunOperator 2023-04-28T12:21:30.943092+00:00 2023-04-28T12:21:31.283064+00:00 0:00:00.339972 369377 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T12:21:28.298162+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T11:00:00+00:00 EmrJobFlowSensor 2023-04-28T12:11:16.625613+00:00 2023-04-28T12:21:18.365921+00:00 0:10:01.740308 369374 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T12:11:14.395167+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T11:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T12:10:55.681059+00:00 2023-04-28T12:10:56.532578+00:00 0:00:00.851519 369371 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-28T12:10:52.311337+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T11:00:00+00:00 PythonOperator 2023-04-28T12:10:34.455389+00:00 2023-04-28T12:10:35.299721+00:00 0:00:00.844332 369368 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-28T12:10:32.291005+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T10:00:00+00:00 TriggerDagRunOperator 2023-04-28T11:22:39.304329+00:00 2023-04-28T11:22:39.655426+00:00 0:00:00.351097 369356 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T11:22:36.788331+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T10:00:00+00:00 TriggerDagRunOperator 2023-04-28T11:22:39.225780+00:00 2023-04-28T11:22:39.714083+00:00 0:00:00.488303 369355 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T11:22:36.788375+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T10:00:00+00:00 EmrJobFlowSensor 2023-04-28T11:12:16.842758+00:00 2023-04-28T11:22:18.671710+00:00 0:10:01.828952 369352 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T11:12:14.493900+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T10:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T11:11:56.696807+00:00 2023-04-28T11:11:57.629413+00:00 0:00:00.932606 369349 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-28T11:11:54.423022+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T10:00:00+00:00 PythonOperator 2023-04-28T11:11:34.790262+00:00 2023-04-28T11:11:35.849493+00:00 0:00:01.059231 369346 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-28T11:11:32.402324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T09:00:00+00:00 TriggerDagRunOperator 2023-04-28T10:18:29.368025+00:00 2023-04-28T10:18:29.895525+00:00 0:00:00.527500 369331 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T10:18:26.911042+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T09:00:00+00:00 TriggerDagRunOperator 2023-04-28T10:18:29.276136+00:00 2023-04-28T10:18:29.606255+00:00 0:00:00.330119 369330 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T10:18:26.911072+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T09:00:00+00:00 EmrJobFlowSensor 2023-04-28T10:08:21.929091+00:00 2023-04-28T10:18:23.737139+00:00 0:10:01.808048 369326 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T10:08:19.749679+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T09:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T10:08:00.092851+00:00 2023-04-28T10:08:01.075847+00:00 0:00:00.982996 369323 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-28T10:07:57.736206+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T09:00:00+00:00 PythonOperator 2023-04-28T10:00:20.658722+00:00 2023-04-28T10:00:21.529635+00:00 0:00:00.870913 369319 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-28T10:00:18.343388+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T08:00:00+00:00 TriggerDagRunOperator 2023-04-28T09:15:04.170728+00:00 2023-04-28T09:15:04.596754+00:00 0:00:00.426026 369306 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T09:15:01.724268+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T08:00:00+00:00 TriggerDagRunOperator 2023-04-28T09:15:04.021627+00:00 2023-04-28T09:15:04.381553+00:00 0:00:00.359926 369305 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T09:15:01.724296+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T08:00:00+00:00 EmrJobFlowSensor 2023-04-28T09:04:46.820822+00:00 2023-04-28T09:14:48.585106+00:00 0:10:01.764284 369299 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T09:04:44.692841+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T08:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T09:04:27.362236+00:00 2023-04-28T09:04:28.138871+00:00 0:00:00.776635 369297 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-28T09:04:24.619903+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T08:00:00+00:00 PythonOperator 2023-04-28T09:04:04.608090+00:00 2023-04-28T09:04:05.495949+00:00 0:00:00.887859 369295 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-28T09:04:02.552839+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T07:00:00+00:00 TriggerDagRunOperator 2023-04-28T08:18:16.613083+00:00 2023-04-28T08:18:17.028944+00:00 0:00:00.415861 369282 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T08:18:14.006079+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T07:00:00+00:00 TriggerDagRunOperator 2023-04-28T08:18:16.489670+00:00 2023-04-28T08:18:16.818143+00:00 0:00:00.328473 369281 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T08:18:14.006124+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T07:00:00+00:00 EmrJobFlowSensor 2023-04-28T08:07:53.933235+00:00 2023-04-28T08:17:55.892976+00:00 0:10:01.959741 369276 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T08:07:50.996555+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-28T07:00:00+00:00 EmrCreateJobFlowOperator 2023-04-28T08:07:33.549145+00:00 2023-04-28T08:07:34.448435+00:00 0:00:00.899290 369273 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-04-28T08:07:30.980278+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-28T07:00:00+00:00 PythonOperator 2023-04-28T08:00:18.014588+00:00 2023-04-28T08:00:18.925971+00:00 0:00:00.911383 369270 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-04-28T08:00:15.715086+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-28T06:00:00+00:00 TriggerDagRunOperator 2023-04-28T07:16:34.164738+00:00 2023-04-28T07:16:34.663262+00:00 0:00:00.498524 369258 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T07:16:31.697839+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-28T06:00:00+00:00 TriggerDagRunOperator 2023-04-28T07:16:34.117483+00:00 2023-04-28T07:16:34.473576+00:00 0:00:00.356093 369257 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-04-28T07:16:31.697810+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-28T06:00:00+00:00 EmrJobFlowSensor 2023-04-28T07:06:17.116436+00:00 2023-04-28T07:16:18.889996+00:00 0:10:01.773560 369254 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-04-28T07:06:15.013219+00:00 2 default_pool