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-17T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T11:07:06.548306+00:00 2023-05-17T11:07:07.372043+00:00 0:00:00.823737 380825 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T11:07:04.303278+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T10:00:00+00:00 PythonOperator 2023-05-17T11:06:44.907458+00:00 2023-05-17T11:06:46.025448+00:00 0:00:01.117990 380822 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T11:06:42.286036+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T09:00:00+00:00 TriggerDagRunOperator 2023-05-17T10:11:15.925842+00:00 2023-05-17T10:11:16.358998+00:00 0:00:00.433156 380808 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T10:11:13.157099+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T09:00:00+00:00 TriggerDagRunOperator 2023-05-17T10:11:15.810070+00:00 2023-05-17T10:11:16.147245+00:00 0:00:00.337175 380807 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T10:11:13.157127+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T09:00:00+00:00 EmrJobFlowSensor 2023-05-17T10:01:07.525028+00:00 2023-05-17T10:11:09.364250+00:00 0:10:01.839222 380801 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T10:01:05.011094+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T10:00:45.290054+00:00 2023-05-17T10:00:46.091823+00:00 0:00:00.801769 380798 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T10:00:43.008825+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T09:00:00+00:00 PythonOperator 2023-05-17T10:00:25.658700+00:00 2023-05-17T10:00:26.731041+00:00 0:00:01.072341 380797 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T10:00:22.966427+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T08:00:00+00:00 TriggerDagRunOperator 2023-05-17T09:11:38.660395+00:00 2023-05-17T09:11:39.124418+00:00 0:00:00.464023 380782 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T09:11:35.490084+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T08:00:00+00:00 TriggerDagRunOperator 2023-05-17T09:11:38.308568+00:00 2023-05-17T09:11:38.747494+00:00 0:00:00.438926 380781 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T09:11:35.490036+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T08:00:00+00:00 EmrJobFlowSensor 2023-05-17T09:01:12.023429+00:00 2023-05-17T09:11:13.834903+00:00 0:10:01.811474 380774 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T09:01:09.890842+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T09:00:51.953097+00:00 2023-05-17T09:00:52.941276+00:00 0:00:00.988179 380772 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T09:00:49.810281+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T08:00:00+00:00 PythonOperator 2023-05-17T09:00:30.271579+00:00 2023-05-17T09:00:31.325252+00:00 0:00:01.053673 380770 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T09:00:27.790933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T07:00:00+00:00 TriggerDagRunOperator 2023-05-17T08:12:03.169590+00:00 2023-05-17T08:12:03.801295+00:00 0:00:00.631705 380755 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T08:11:59.936050+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T07:00:00+00:00 TriggerDagRunOperator 2023-05-17T08:12:03.115430+00:00 2023-05-17T08:12:03.478555+00:00 0:00:00.363125 380754 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T08:11:59.936103+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T07:00:00+00:00 EmrJobFlowSensor 2023-05-17T08:00:51.242451+00:00 2023-05-17T08:10:52.933314+00:00 0:10:01.690863 380750 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T08:00:49.095155+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T08:00:31.220020+00:00 2023-05-17T08:00:32.054162+00:00 0:00:00.834142 380748 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T08:00:29.076712+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T07:00:00+00:00 PythonOperator 2023-05-17T08:00:09.687065+00:00 2023-05-17T08:00:10.775332+00:00 0:00:01.088267 380746 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T08:00:07.057972+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T06:00:00+00:00 TriggerDagRunOperator 2023-05-17T07:18:45.666776+00:00 2023-05-17T07:18:46.116036+00:00 0:00:00.449260 380734 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T07:18:42.912570+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T06:00:00+00:00 TriggerDagRunOperator 2023-05-17T07:18:45.639512+00:00 2023-05-17T07:18:45.980581+00:00 0:00:00.341069 380733 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T07:18:42.912612+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T06:00:00+00:00 EmrJobFlowSensor 2023-05-17T07:08:34.694767+00:00 2023-05-17T07:18:36.645816+00:00 0:10:01.951049 380728 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T07:08:32.307061+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T07:08:14.641488+00:00 2023-05-17T07:08:15.620878+00:00 0:00:00.979390 380726 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T07:08:12.268518+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T06:00:00+00:00 PythonOperator 2023-05-17T07:07:52.899855+00:00 2023-05-17T07:07:54.059159+00:00 0:00:01.159304 380722 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T07:07:50.252520+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T05:00:00+00:00 TriggerDagRunOperator 2023-05-17T06:11:26.519552+00:00 2023-05-17T06:11:27.203644+00:00 0:00:00.684092 380708 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T06:11:23.710081+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T05:00:00+00:00 TriggerDagRunOperator 2023-05-17T06:11:26.391831+00:00 2023-05-17T06:11:26.870940+00:00 0:00:00.479109 380707 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T06:11:23.710110+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T05:00:00+00:00 EmrJobFlowSensor 2023-05-17T06:01:02.040349+00:00 2023-05-17T06:11:03.914289+00:00 0:10:01.873940 380704 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T06:00:59.692326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T06:00:41.943960+00:00 2023-05-17T06:00:42.774066+00:00 0:00:00.830106 380702 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T06:00:39.604679+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T05:00:00+00:00 PythonOperator 2023-05-17T06:00:19.834930+00:00 2023-05-17T06:00:20.858421+00:00 0:00:01.023491 380700 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T06:00:17.589527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T04:00:00+00:00 TriggerDagRunOperator 2023-05-17T05:11:43.016337+00:00 2023-05-17T05:11:43.504738+00:00 0:00:00.488401 380687 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T05:11:39.314971+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T04:00:00+00:00 TriggerDagRunOperator 2023-05-17T05:11:42.438954+00:00 2023-05-17T05:11:42.911278+00:00 0:00:00.472324 380686 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T05:11:39.314926+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T04:00:00+00:00 EmrJobFlowSensor 2023-05-17T05:02:16.090732+00:00 2023-05-17T05:11:17.877127+00:00 0:09:01.786395 380681 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T05:02:13.601830+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T05:00:48.430671+00:00 2023-05-17T05:00:49.517437+00:00 0:00:01.086766 380677 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T05:00:43.986578+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T04:00:00+00:00 PythonOperator 2023-05-17T05:00:24.094877+00:00 2023-05-17T05:00:25.170559+00:00 0:00:01.075682 380675 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T05:00:21.911122+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T03:00:00+00:00 TriggerDagRunOperator 2023-05-17T04:12:11.235809+00:00 2023-05-17T04:12:11.710890+00:00 0:00:00.475081 380662 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T04:12:08.307315+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T03:00:00+00:00 TriggerDagRunOperator 2023-05-17T04:12:11.200933+00:00 2023-05-17T04:12:11.541430+00:00 0:00:00.340497 380661 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T04:12:08.307277+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T03:00:00+00:00 EmrJobFlowSensor 2023-05-17T04:00:54.650390+00:00 2023-05-17T04:11:56.616999+00:00 0:11:01.966609 380654 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T04:00:52.469178+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T04:00:35.050622+00:00 2023-05-17T04:00:35.994077+00:00 0:00:00.943455 380652 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T04:00:32.400561+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T03:00:00+00:00 PythonOperator 2023-05-17T04:00:12.613382+00:00 2023-05-17T04:00:13.720617+00:00 0:00:01.107235 380650 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T04:00:10.380297+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T02:00:00+00:00 TriggerDagRunOperator 2023-05-17T03:13:09.914426+00:00 2023-05-17T03:13:10.261654+00:00 0:00:00.347228 380634 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T03:13:07.209748+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T02:00:00+00:00 TriggerDagRunOperator 2023-05-17T03:13:09.927397+00:00 2023-05-17T03:13:10.369164+00:00 0:00:00.441767 380633 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T03:13:07.209777+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T02:00:00+00:00 EmrJobFlowSensor 2023-05-17T03:01:04.417012+00:00 2023-05-17T03:11:06.204387+00:00 0:10:01.787375 380630 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T03:01:02.110105+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T03:00:44.257214+00:00 2023-05-17T03:00:45.197107+00:00 0:00:00.939893 380628 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T03:00:42.013581+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T02:00:00+00:00 PythonOperator 2023-05-17T03:00:22.397725+00:00 2023-05-17T03:00:23.494228+00:00 0:00:01.096503 380626 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T03:00:19.998984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T01:00:00+00:00 TriggerDagRunOperator 2023-05-17T02:11:33.115116+00:00 2023-05-17T02:11:33.607142+00:00 0:00:00.492026 380611 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T02:11:30.297690+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T01:00:00+00:00 TriggerDagRunOperator 2023-05-17T02:11:33.007206+00:00 2023-05-17T02:11:33.342943+00:00 0:00:00.335737 380610 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T02:11:30.297762+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T01:00:00+00:00 EmrJobFlowSensor 2023-05-17T02:01:10.532368+00:00 2023-05-17T02:11:12.269498+00:00 0:10:01.737130 380604 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T02:01:08.329938+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T02:00:48.607304+00:00 2023-05-17T02:00:49.546219+00:00 0:00:00.938915 380602 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T02:00:46.308807+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T01:00:00+00:00 PythonOperator 2023-05-17T02:00:28.575763+00:00 2023-05-17T02:00:29.660114+00:00 0:00:01.084351 380600 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T02:00:26.255313+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-17T00:00:00+00:00 TriggerDagRunOperator 2023-05-17T01:11:11.576477+00:00 2023-05-17T01:11:11.939166+00:00 0:00:00.362689 380579 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T01:11:09.072057+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-17T00:00:00+00:00 TriggerDagRunOperator 2023-05-17T01:11:11.580864+00:00 2023-05-17T01:11:12.039213+00:00 0:00:00.458349 380578 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T01:11:09.072027+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-17T00:00:00+00:00 EmrJobFlowSensor 2023-05-17T01:00:54.004767+00:00 2023-05-17T01:10:56.008324+00:00 0:10:02.003557 380568 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T01:00:51.758742+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-17T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T01:00:32.008030+00:00 2023-05-17T01:00:32.890410+00:00 0:00:00.882380 380567 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T01:00:29.751004+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-17T00:00:00+00:00 PythonOperator 2023-05-17T01:00:12.461375+00:00 2023-05-17T01:00:13.550873+00:00 0:00:01.089498 380565 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T01:00:09.788812+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T23:00:00+00:00 TriggerDagRunOperator 2023-05-17T00:13:23.269905+00:00 2023-05-17T00:13:23.789853+00:00 0:00:00.519948 380552 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T00:13:20.701869+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T23:00:00+00:00 TriggerDagRunOperator 2023-05-17T00:13:23.100258+00:00 2023-05-17T00:13:23.565119+00:00 0:00:00.464861 380551 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-17T00:13:20.701840+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T23:00:00+00:00 EmrJobFlowSensor 2023-05-17T00:01:07.548916+00:00 2023-05-17T00:11:09.527547+00:00 0:10:01.978631 380544 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-17T00:01:05.236928+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-17T00:00:45.514075+00:00 2023-05-17T00:00:46.437449+00:00 0:00:00.923374 380542 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-17T00:00:43.216457+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T23:00:00+00:00 PythonOperator 2023-05-17T00:00:26.003476+00:00 2023-05-17T00:00:27.097713+00:00 0:00:01.094237 380540 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-17T00:00:23.149706+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T22:00:00+00:00 TriggerDagRunOperator 2023-05-16T23:12:10.411010+00:00 2023-05-16T23:12:10.751948+00:00 0:00:00.340938 380525 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T23:12:07.685565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T22:00:00+00:00 TriggerDagRunOperator 2023-05-16T23:12:10.429615+00:00 2023-05-16T23:12:10.892502+00:00 0:00:00.462887 380524 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T23:12:07.685538+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T22:00:00+00:00 EmrJobFlowSensor 2023-05-16T23:01:06.532324+00:00 2023-05-16T23:11:08.454445+00:00 0:10:01.922121 380517 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T23:01:04.187949+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T23:00:44.287373+00:00 2023-05-16T23:00:45.161057+00:00 0:00:00.873684 380514 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T23:00:42.104577+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T22:00:00+00:00 PythonOperator 2023-05-16T23:00:22.337403+00:00 2023-05-16T23:00:23.393920+00:00 0:00:01.056517 380511 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T23:00:20.099418+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T21:00:00+00:00 TriggerDagRunOperator 2023-05-16T22:11:00.575552+00:00 2023-05-16T22:11:01.005488+00:00 0:00:00.429936 380495 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T22:10:57.917250+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T21:00:00+00:00 TriggerDagRunOperator 2023-05-16T22:11:00.464629+00:00 2023-05-16T22:11:00.830524+00:00 0:00:00.365895 380494 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T22:10:57.917301+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T21:00:00+00:00 EmrJobFlowSensor 2023-05-16T22:00:47.457993+00:00 2023-05-16T22:10:49.339913+00:00 0:10:01.881920 380487 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T22:00:45.229780+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T22:00:27.561887+00:00 2023-05-16T22:00:28.567720+00:00 0:00:01.005833 380485 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T22:00:25.280077+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T21:00:00+00:00 PythonOperator 2023-05-16T22:00:05.530371+00:00 2023-05-16T22:00:06.607095+00:00 0:00:01.076724 380483 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T22:00:03.162107+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T20:00:00+00:00 TriggerDagRunOperator 2023-05-16T21:11:56.121742+00:00 2023-05-16T21:11:56.570882+00:00 0:00:00.449140 380470 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T21:11:53.278607+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T20:00:00+00:00 TriggerDagRunOperator 2023-05-16T21:11:56.034952+00:00 2023-05-16T21:11:56.365899+00:00 0:00:00.330947 380469 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T21:11:53.278579+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T20:00:00+00:00 EmrJobFlowSensor 2023-05-16T21:01:00.931746+00:00 2023-05-16T21:11:02.932038+00:00 0:10:02.000292 380462 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T21:00:58.587432+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T21:00:38.978823+00:00 2023-05-16T21:00:39.865039+00:00 0:00:00.886216 380460 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T21:00:36.494603+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T20:00:00+00:00 PythonOperator 2023-05-16T21:00:18.929611+00:00 2023-05-16T21:00:19.956901+00:00 0:00:01.027290 380458 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T21:00:16.406318+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T19:00:00+00:00 TriggerDagRunOperator 2023-05-16T20:11:05.193209+00:00 2023-05-16T20:11:05.628791+00:00 0:00:00.435582 380441 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T20:11:02.212661+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T19:00:00+00:00 TriggerDagRunOperator 2023-05-16T20:11:04.588389+00:00 2023-05-16T20:11:04.939736+00:00 0:00:00.351347 380440 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T20:11:02.212705+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T19:00:00+00:00 EmrJobFlowSensor 2023-05-16T20:00:59.153453+00:00 2023-05-16T20:11:01.237958+00:00 0:10:02.084505 380434 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T20:00:56.834645+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T20:00:37.169549+00:00 2023-05-16T20:00:38.018962+00:00 0:00:00.849413 380432 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T20:00:34.884739+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T19:00:00+00:00 PythonOperator 2023-05-16T20:00:16.920105+00:00 2023-05-16T20:00:17.962440+00:00 0:00:01.042335 380430 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T20:00:14.724060+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T18:00:00+00:00 TriggerDagRunOperator 2023-05-16T19:11:49.530828+00:00 2023-05-16T19:11:49.979177+00:00 0:00:00.448349 380414 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T19:11:46.741006+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T18:00:00+00:00 TriggerDagRunOperator 2023-05-16T19:11:49.340598+00:00 2023-05-16T19:11:49.690971+00:00 0:00:00.350373 380413 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T19:11:46.741035+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T18:00:00+00:00 EmrJobFlowSensor 2023-05-16T19:00:47.622020+00:00 2023-05-16T19:10:49.401167+00:00 0:10:01.779147 380405 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T19:00:45.416365+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T19:00:27.704145+00:00 2023-05-16T19:00:28.601865+00:00 0:00:00.897720 380404 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T19:00:25.410919+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T18:00:00+00:00 PythonOperator 2023-05-16T19:00:05.621347+00:00 2023-05-16T19:00:06.679044+00:00 0:00:01.057697 380402 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T19:00:03.322742+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T17:00:00+00:00 TriggerDagRunOperator 2023-05-16T18:11:33.413424+00:00 2023-05-16T18:11:33.752663+00:00 0:00:00.339239 380387 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T18:11:30.141236+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T17:00:00+00:00 TriggerDagRunOperator 2023-05-16T18:11:33.066674+00:00 2023-05-16T18:11:33.575576+00:00 0:00:00.508902 380386 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T18:11:30.141265+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T17:00:00+00:00 EmrJobFlowSensor 2023-05-16T18:01:01.115969+00:00 2023-05-16T18:11:03.180510+00:00 0:10:02.064541 380378 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T18:00:58.935638+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T18:00:39.167728+00:00 2023-05-16T18:00:40.113315+00:00 0:00:00.945587 380377 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T18:00:36.911792+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T17:00:00+00:00 PythonOperator 2023-05-16T18:00:19.312104+00:00 2023-05-16T18:00:20.328804+00:00 0:00:01.016700 380376 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T18:00:16.843686+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T16:00:00+00:00 TriggerDagRunOperator 2023-05-16T17:12:02.435872+00:00 2023-05-16T17:12:02.911516+00:00 0:00:00.475644 380362 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T17:11:59.606613+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T16:00:00+00:00 TriggerDagRunOperator 2023-05-16T17:12:02.336604+00:00 2023-05-16T17:12:02.684135+00:00 0:00:00.347531 380361 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T17:11:59.606643+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T16:00:00+00:00 EmrJobFlowSensor 2023-05-16T17:00:49.934281+00:00 2023-05-16T17:10:51.819286+00:00 0:10:01.885005 380351 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T17:00:47.714904+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T17:00:27.838829+00:00 2023-05-16T17:00:28.653236+00:00 0:00:00.814407 380350 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T17:00:25.668202+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T16:00:00+00:00 PythonOperator 2023-05-16T17:00:08.319753+00:00 2023-05-16T17:00:09.571908+00:00 0:00:01.252155 380349 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T17:00:05.576133+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T15:00:00+00:00 TriggerDagRunOperator 2023-05-16T16:22:42.682063+00:00 2023-05-16T16:22:43.186510+00:00 0:00:00.504447 380337 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T16:22:40.131304+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T15:00:00+00:00 TriggerDagRunOperator 2023-05-16T16:22:42.571874+00:00 2023-05-16T16:22:42.948493+00:00 0:00:00.376619 380336 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T16:22:40.131275+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T15:00:00+00:00 EmrJobFlowSensor 2023-05-16T16:12:18.691578+00:00 2023-05-16T16:22:20.595726+00:00 0:10:01.904148 380333 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T16:12:16.510597+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T16:11:58.629859+00:00 2023-05-16T16:11:59.521967+00:00 0:00:00.892108 380330 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T16:11:56.431347+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T15:00:00+00:00 PythonOperator 2023-05-16T16:11:36.841459+00:00 2023-05-16T16:11:37.864015+00:00 0:00:01.022556 380327 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T16:11:34.410702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T14:00:00+00:00 TriggerDagRunOperator 2023-05-16T15:14:29.172403+00:00 2023-05-16T15:14:29.614432+00:00 0:00:00.442029 380313 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T15:14:26.395714+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T14:00:00+00:00 TriggerDagRunOperator 2023-05-16T15:14:29.081454+00:00 2023-05-16T15:14:29.400437+00:00 0:00:00.318983 380312 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T15:14:26.395671+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T14:00:00+00:00 EmrJobFlowSensor 2023-05-16T15:04:13.681351+00:00 2023-05-16T15:14:15.569162+00:00 0:10:01.887811 380306 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T15:04:11.217592+00:00 2 default_pool