Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 check_cluster_status 2023-03-18T23:00:00+00:00 EmrJobFlowSensor 2023-03-19T00:01:07.092081+00:00 2023-03-19T00:11:08.951445+00:00 0:10:01.859364 355777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-19T00:01:04.893364+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-19T00:00:45.159768+00:00 2023-03-19T00:00:46.033788+00:00 0:00:00.874020 355775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-19T00:00:42.851223+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T23:00:00+00:00 PythonOperator 2023-03-19T00:00:24.941156+00:00 2023-03-19T00:00:28.980798+00:00 0:00:04.039642 355773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-19T00:00:22.785056+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T22:00:00+00:00 TriggerDagRunOperator 2023-03-18T23:15:06.373135+00:00 2023-03-18T23:15:06.870879+00:00 0:00:00.497744 355763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T23:15:03.300007+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T22:00:00+00:00 TriggerDagRunOperator 2023-03-18T23:15:05.828526+00:00 2023-03-18T23:15:06.349340+00:00 0:00:00.520814 355762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T23:15:03.299978+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T22:00:00+00:00 EmrJobFlowSensor 2023-03-18T23:04:52.643447+00:00 2023-03-18T23:14:54.555848+00:00 0:10:01.912401 355754 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T23:04:50.367683+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T23:04:33.033245+00:00 2023-03-18T23:04:34.313378+00:00 0:00:01.280133 355751 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T23:04:30.350236+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T22:00:00+00:00 PythonOperator 2023-03-18T23:04:11.267828+00:00 2023-03-18T23:04:15.165030+00:00 0:00:03.897202 355748 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T23:04:08.335011+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T21:00:00+00:00 TriggerDagRunOperator 2023-03-18T22:11:00.460524+00:00 2023-03-18T22:11:00.987254+00:00 0:00:00.526730 355737 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T22:10:57.897215+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T21:00:00+00:00 TriggerDagRunOperator 2023-03-18T22:11:00.314842+00:00 2023-03-18T22:11:00.786565+00:00 0:00:00.471723 355736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T22:10:57.897185+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T21:00:00+00:00 EmrJobFlowSensor 2023-03-18T22:00:53.696169+00:00 2023-03-18T22:10:55.603882+00:00 0:10:01.907713 355729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T22:00:51.401200+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T22:00:31.761139+00:00 2023-03-18T22:00:33.149568+00:00 0:00:01.388429 355727 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T22:00:29.414151+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T21:00:00+00:00 PythonOperator 2023-03-18T22:00:11.644665+00:00 2023-03-18T22:00:15.114891+00:00 0:00:03.470226 355725 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T22:00:09.324480+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T20:00:00+00:00 TriggerDagRunOperator 2023-03-18T21:11:21.485632+00:00 2023-03-18T21:11:22.046091+00:00 0:00:00.560459 355714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T21:11:18.510599+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T20:00:00+00:00 TriggerDagRunOperator 2023-03-18T21:11:21.330312+00:00 2023-03-18T21:11:21.795424+00:00 0:00:00.465112 355713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T21:11:18.510571+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T20:00:00+00:00 EmrJobFlowSensor 2023-03-18T21:01:01.569542+00:00 2023-03-18T21:11:03.466320+00:00 0:10:01.896778 355706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T21:00:59.139990+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T21:00:39.290557+00:00 2023-03-18T21:00:40.153717+00:00 0:00:00.863160 355704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T21:00:37.027716+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T20:00:00+00:00 PythonOperator 2023-03-18T21:00:17.409952+00:00 2023-03-18T21:00:20.433982+00:00 0:00:03.024030 355702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T21:00:14.943047+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T19:00:00+00:00 TriggerDagRunOperator 2023-03-18T20:11:21.322430+00:00 2023-03-18T20:11:21.812271+00:00 0:00:00.489841 355690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T20:11:18.728078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T19:00:00+00:00 TriggerDagRunOperator 2023-03-18T20:11:21.208397+00:00 2023-03-18T20:11:21.699585+00:00 0:00:00.491188 355689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T20:11:18.728106+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T19:00:00+00:00 EmrJobFlowSensor 2023-03-18T20:00:56.687286+00:00 2023-03-18T20:10:58.557637+00:00 0:10:01.870351 355682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T20:00:54.207518+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T20:00:34.551042+00:00 2023-03-18T20:00:35.494276+00:00 0:00:00.943234 355680 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T20:00:32.121178+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T19:00:00+00:00 PythonOperator 2023-03-18T20:00:14.598620+00:00 2023-03-18T20:00:20.626381+00:00 0:00:06.027761 355678 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T20:00:12.094449+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T18:00:00+00:00 TriggerDagRunOperator 2023-03-18T19:27:56.347487+00:00 2023-03-18T19:27:56.823825+00:00 0:00:00.476338 355670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T19:27:53.571690+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T18:00:00+00:00 TriggerDagRunOperator 2023-03-18T19:27:56.202336+00:00 2023-03-18T19:27:56.682634+00:00 0:00:00.480298 355669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T19:27:53.571734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T18:00:00+00:00 EmrJobFlowSensor 2023-03-18T19:17:42.003903+00:00 2023-03-18T19:27:43.783896+00:00 0:10:01.779993 355664 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T19:17:39.777142+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T19:17:22.140808+00:00 2023-03-18T19:17:23.467190+00:00 0:00:01.326382 355661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T19:17:19.754478+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T18:00:00+00:00 PythonOperator 2023-03-18T19:17:00.697259+00:00 2023-03-18T19:17:04.220643+00:00 0:00:03.523384 355658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T19:16:57.737726+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T17:00:00+00:00 TriggerDagRunOperator 2023-03-18T18:20:53.160448+00:00 2023-03-18T18:20:53.649174+00:00 0:00:00.488726 355652 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T18:20:50.596749+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T17:00:00+00:00 TriggerDagRunOperator 2023-03-18T18:20:53.111244+00:00 2023-03-18T18:20:53.619669+00:00 0:00:00.508425 355651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T18:20:50.596722+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T17:00:00+00:00 EmrJobFlowSensor 2023-03-18T18:08:12.086459+00:00 2023-03-18T18:18:13.856266+00:00 0:10:01.769807 355646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T18:08:09.864609+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T18:07:50.291950+00:00 2023-03-18T18:07:51.215295+00:00 0:00:00.923345 355643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T18:07:47.842843+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T17:00:00+00:00 PythonOperator 2023-03-18T18:07:30.669551+00:00 2023-03-18T18:07:34.243153+00:00 0:00:03.573602 355640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T18:07:27.808143+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T16:00:00+00:00 TriggerDagRunOperator 2023-03-18T17:11:27.447891+00:00 2023-03-18T17:11:28.088937+00:00 0:00:00.641046 355632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T17:11:22.765499+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T16:00:00+00:00 TriggerDagRunOperator 2023-03-18T17:11:25.016812+00:00 2023-03-18T17:11:25.516531+00:00 0:00:00.499719 355631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T17:11:22.765485+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T16:00:00+00:00 EmrJobFlowSensor 2023-03-18T17:01:07.267786+00:00 2023-03-18T17:11:09.183215+00:00 0:10:01.915429 355626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T17:01:04.480164+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T17:00:44.794242+00:00 2023-03-18T17:00:45.750375+00:00 0:00:00.956133 355623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T17:00:42.498784+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T16:00:00+00:00 PythonOperator 2023-03-18T17:00:23.153270+00:00 2023-03-18T17:00:26.329904+00:00 0:00:03.176634 355622 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T17:00:20.438600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T15:00:00+00:00 TriggerDagRunOperator 2023-03-18T16:27:42.039092+00:00 2023-03-18T16:27:42.545770+00:00 0:00:00.506678 355616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T16:27:39.189135+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T15:00:00+00:00 TriggerDagRunOperator 2023-03-18T16:27:41.929454+00:00 2023-03-18T16:27:42.404599+00:00 0:00:00.475145 355615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T16:27:39.189173+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T15:00:00+00:00 EmrJobFlowSensor 2023-03-18T16:14:33.251832+00:00 2023-03-18T16:24:35.069995+00:00 0:10:01.818163 355609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T16:14:30.913996+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T16:14:16.537069+00:00 2023-03-18T16:14:17.372572+00:00 0:00:00.835503 355607 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T16:14:10.909652+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T15:00:00+00:00 PythonOperator 2023-03-18T16:00:24.364207+00:00 2023-03-18T16:00:27.768771+00:00 0:00:03.404564 355603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T16:00:21.740912+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T14:00:00+00:00 TriggerDagRunOperator 2023-03-18T15:34:02.785117+00:00 2023-03-18T15:34:03.290284+00:00 0:00:00.505167 355595 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T15:33:59.854438+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T14:00:00+00:00 TriggerDagRunOperator 2023-03-18T15:34:02.630122+00:00 2023-03-18T15:34:03.122378+00:00 0:00:00.492256 355594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T15:33:59.854410+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T14:00:00+00:00 EmrJobFlowSensor 2023-03-18T15:20:34.099454+00:00 2023-03-18T15:30:36.247514+00:00 0:10:02.148060 355590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T15:20:31.333601+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T15:20:11.604274+00:00 2023-03-18T15:20:12.546402+00:00 0:00:00.942128 355587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T15:20:09.312331+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T14:00:00+00:00 PythonOperator 2023-03-18T15:19:51.608083+00:00 2023-03-18T15:19:55.629183+00:00 0:00:04.021100 355585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T15:19:49.269301+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T13:00:00+00:00 TriggerDagRunOperator 2023-03-18T14:40:47.208781+00:00 2023-03-18T14:40:47.693617+00:00 0:00:00.484836 355577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T14:40:44.210157+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T13:00:00+00:00 TriggerDagRunOperator 2023-03-18T14:40:47.000920+00:00 2023-03-18T14:40:47.455634+00:00 0:00:00.454714 355576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T14:40:44.210199+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T13:00:00+00:00 EmrJobFlowSensor 2023-03-18T14:04:14.275131+00:00 2023-03-18T14:14:16.129772+00:00 0:10:01.854641 355570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T14:04:11.475931+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T14:03:51.665042+00:00 2023-03-18T14:03:52.556578+00:00 0:00:00.891536 355568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T14:03:49.462592+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T13:00:00+00:00 PythonOperator 2023-03-18T14:03:31.634301+00:00 2023-03-18T14:03:34.778871+00:00 0:00:03.144570 355566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T14:03:29.433215+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T12:00:00+00:00 TriggerDagRunOperator 2023-03-18T13:11:28.379159+00:00 2023-03-18T13:11:28.868878+00:00 0:00:00.489719 355556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T13:11:25.787735+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T12:00:00+00:00 TriggerDagRunOperator 2023-03-18T13:11:28.327758+00:00 2023-03-18T13:11:28.847208+00:00 0:00:00.519450 355555 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T13:11:25.787786+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T12:00:00+00:00 EmrJobFlowSensor 2023-03-18T13:01:06.890662+00:00 2023-03-18T13:11:08.772827+00:00 0:10:01.882165 355549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T13:01:04.655439+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T13:00:44.854498+00:00 2023-03-18T13:00:46.208969+00:00 0:00:01.354471 355546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T13:00:42.639031+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T12:00:00+00:00 PythonOperator 2023-03-18T13:00:25.027728+00:00 2023-03-18T13:00:29.200909+00:00 0:00:04.173181 355544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T13:00:22.618054+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T11:00:00+00:00 TriggerDagRunOperator 2023-03-18T12:25:14.977268+00:00 2023-03-18T12:25:15.516948+00:00 0:00:00.539680 355539 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T12:25:11.928582+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T11:00:00+00:00 TriggerDagRunOperator 2023-03-18T12:25:14.766234+00:00 2023-03-18T12:25:15.305163+00:00 0:00:00.538929 355538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T12:25:11.928541+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T11:00:00+00:00 EmrJobFlowSensor 2023-03-18T12:08:12.607495+00:00 2023-03-18T12:18:15.596463+00:00 0:10:02.988968 355532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T12:08:09.947460+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T12:07:53.914212+00:00 2023-03-18T12:07:56.897635+00:00 0:00:02.983423 355528 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T12:07:47.895171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T10:00:00+00:00 TriggerDagRunOperator 2023-03-18T12:07:33.750179+00:00 2023-03-18T12:07:34.461419+00:00 0:00:00.711240 355525 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T12:07:27.871105+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T10:00:00+00:00 TriggerDagRunOperator 2023-03-18T12:07:32.226200+00:00 2023-03-18T12:07:32.834435+00:00 0:00:00.608235 355524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T12:07:27.871119+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T11:00:00+00:00 PythonOperator 2023-03-18T12:07:32.180882+00:00 2023-03-18T12:07:36.266784+00:00 0:00:04.085902 355523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T12:07:27.871131+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T10:00:00+00:00 EmrJobFlowSensor 2023-03-18T11:25:56.668704+00:00 2023-03-18T11:35:58.408650+00:00 0:10:01.739946 355518 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T11:25:53.545515+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T11:25:35.000123+00:00 2023-03-18T11:25:35.927280+00:00 0:00:00.927157 355515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T11:25:31.512060+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T10:00:00+00:00 PythonOperator 2023-03-18T11:25:11.880360+00:00 2023-03-18T11:25:17.440044+00:00 0:00:05.559684 355512 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T11:25:09.445656+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T09:00:00+00:00 TriggerDagRunOperator 2023-03-18T10:29:50.477026+00:00 2023-03-18T10:29:51.066268+00:00 0:00:00.589242 355506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T10:29:47.546488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T09:00:00+00:00 TriggerDagRunOperator 2023-03-18T10:29:50.212596+00:00 2023-03-18T10:29:50.693669+00:00 0:00:00.481073 355505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T10:29:47.546542+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T09:00:00+00:00 EmrJobFlowSensor 2023-03-18T10:04:14.117496+00:00 2023-03-18T10:14:15.889073+00:00 0:10:01.771577 355498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T10:04:11.898336+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T10:03:52.065364+00:00 2023-03-18T10:03:52.919482+00:00 0:00:00.854118 355496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T10:03:49.877654+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T09:00:00+00:00 PythonOperator 2023-03-18T10:03:32.906728+00:00 2023-03-18T10:03:36.129807+00:00 0:00:03.223079 355494 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T10:03:29.913753+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T08:00:00+00:00 TriggerDagRunOperator 2023-03-18T09:30:10.753929+00:00 2023-03-18T09:30:11.278954+00:00 0:00:00.525025 355487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T09:30:08.330810+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T08:00:00+00:00 TriggerDagRunOperator 2023-03-18T09:30:10.605190+00:00 2023-03-18T09:30:11.172905+00:00 0:00:00.567715 355486 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T09:30:08.330837+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T08:00:00+00:00 EmrJobFlowSensor 2023-03-18T09:17:35.810103+00:00 2023-03-18T09:27:37.566528+00:00 0:10:01.756425 355482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T09:17:33.516162+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T09:17:15.842457+00:00 2023-03-18T09:17:16.729818+00:00 0:00:00.887361 355479 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T09:17:13.482573+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T08:00:00+00:00 PythonOperator 2023-03-18T09:16:57.221565+00:00 2023-03-18T09:17:00.312207+00:00 0:00:03.090642 355476 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T09:16:51.458515+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T07:00:00+00:00 TriggerDagRunOperator 2023-03-18T08:11:34.006104+00:00 2023-03-18T08:11:34.528670+00:00 0:00:00.522566 355465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T08:11:31.131944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T07:00:00+00:00 TriggerDagRunOperator 2023-03-18T08:11:33.701793+00:00 2023-03-18T08:11:34.166296+00:00 0:00:00.464503 355464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T08:11:31.131982+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T07:00:00+00:00 EmrJobFlowSensor 2023-03-18T08:01:00.357551+00:00 2023-03-18T08:11:02.710153+00:00 0:10:02.352602 355460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T08:00:58.020195+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T08:00:40.383390+00:00 2023-03-18T08:00:41.399224+00:00 0:00:01.015834 355458 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T08:00:38.002387+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T07:00:00+00:00 PythonOperator 2023-03-18T08:00:18.363776+00:00 2023-03-18T08:00:24.344226+00:00 0:00:05.980450 355456 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T08:00:15.945716+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T06:00:00+00:00 TriggerDagRunOperator 2023-03-18T07:37:11.890935+00:00 2023-03-18T07:37:12.410404+00:00 0:00:00.519469 355449 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T07:37:09.294333+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T06:00:00+00:00 TriggerDagRunOperator 2023-03-18T07:37:11.728860+00:00 2023-03-18T07:37:12.199633+00:00 0:00:00.470773 355448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T07:37:09.294305+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T06:00:00+00:00 EmrJobFlowSensor 2023-03-18T07:26:56.824636+00:00 2023-03-18T07:36:58.927193+00:00 0:10:02.102557 355444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T07:26:50.471339+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T07:26:30.694366+00:00 2023-03-18T07:26:31.638371+00:00 0:00:00.944005 355440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T07:26:28.447470+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T06:00:00+00:00 PythonOperator 2023-03-18T07:26:10.925425+00:00 2023-03-18T07:26:15.113407+00:00 0:00:04.187982 355438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T07:26:08.500938+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T05:00:00+00:00 TriggerDagRunOperator 2023-03-18T06:16:18.800243+00:00 2023-03-18T06:16:19.270385+00:00 0:00:00.470142 355430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T06:16:15.834532+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T05:00:00+00:00 TriggerDagRunOperator 2023-03-18T06:16:18.525560+00:00 2023-03-18T06:16:18.978917+00:00 0:00:00.453357 355429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T06:16:15.834566+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T05:00:00+00:00 EmrJobFlowSensor 2023-03-18T06:03:40.098271+00:00 2023-03-18T06:13:41.756884+00:00 0:10:01.658613 355423 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T06:03:37.773463+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T06:03:18.672716+00:00 2023-03-18T06:03:19.488187+00:00 0:00:00.815471 355421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T06:03:15.804055+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T05:00:00+00:00 PythonOperator 2023-03-18T06:02:56.538995+00:00 2023-03-18T06:02:59.589231+00:00 0:00:03.050236 355419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T06:02:53.733654+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T04:00:00+00:00 TriggerDagRunOperator 2023-03-18T05:37:53.700388+00:00 2023-03-18T05:37:54.145793+00:00 0:00:00.445405 355410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T05:37:50.457202+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T04:00:00+00:00 TriggerDagRunOperator 2023-03-18T05:37:52.831385+00:00 2023-03-18T05:37:53.337454+00:00 0:00:00.506069 355409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T05:37:50.457237+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T04:00:00+00:00 EmrJobFlowSensor 2023-03-18T05:00:55.504335+00:00 2023-03-18T05:10:57.609374+00:00 0:10:02.105039 355404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T05:00:52.713127+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T05:00:33.237215+00:00 2023-03-18T05:00:34.047073+00:00 0:00:00.809858 355402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T05:00:30.698872+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T04:00:00+00:00 PythonOperator 2023-03-18T05:00:10.932678+00:00 2023-03-18T05:00:14.594090+00:00 0:00:03.661412 355400 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T05:00:08.546668+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T03:00:00+00:00 TriggerDagRunOperator 2023-03-18T04:11:26.136635+00:00 2023-03-18T04:11:26.672898+00:00 0:00:00.536263 355391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T04:11:23.570330+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T03:00:00+00:00 TriggerDagRunOperator 2023-03-18T04:11:25.988444+00:00 2023-03-18T04:11:26.597198+00:00 0:00:00.608754 355390 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T04:11:23.570363+00:00 2 default_pool