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-02T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T11:00:35.042109+00:00 2023-05-02T11:00:35.795571+00:00 0:00:00.753462 371685 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T11:00:32.719760+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T10:00:00+00:00 PythonOperator 2023-05-02T11:00:15.347501+00:00 2023-05-02T11:00:16.310248+00:00 0:00:00.962747 371683 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T11:00:12.698912+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T09:00:00+00:00 TriggerDagRunOperator 2023-05-02T10:16:37.587107+00:00 2023-05-02T10:16:38.025553+00:00 0:00:00.438446 371671 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T10:16:34.991844+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T09:00:00+00:00 TriggerDagRunOperator 2023-05-02T10:16:37.457193+00:00 2023-05-02T10:16:37.803119+00:00 0:00:00.345926 371670 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T10:16:34.991873+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T09:00:00+00:00 EmrJobFlowSensor 2023-05-02T10:06:30.355440+00:00 2023-05-02T10:16:32.536829+00:00 0:10:02.181389 371666 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T10:06:26.912210+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T10:06:07.138727+00:00 2023-05-02T10:06:07.971417+00:00 0:00:00.832690 371663 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T10:06:04.886740+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T09:00:00+00:00 PythonOperator 2023-05-02T10:05:47.353988+00:00 2023-05-02T10:05:49.546141+00:00 0:00:02.192153 371660 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T10:05:44.820629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T08:00:00+00:00 TriggerDagRunOperator 2023-05-02T09:16:48.203269+00:00 2023-05-02T09:16:48.968862+00:00 0:00:00.765593 371643 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T09:16:44.899393+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T08:00:00+00:00 TriggerDagRunOperator 2023-05-02T09:16:47.578166+00:00 2023-05-02T09:16:47.904286+00:00 0:00:00.326120 371642 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T09:16:44.899420+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T08:00:00+00:00 EmrJobFlowSensor 2023-05-02T09:01:00.712209+00:00 2023-05-02T09:11:02.518860+00:00 0:10:01.806651 371639 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T09:00:58.258847+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T09:00:38.545881+00:00 2023-05-02T09:00:39.437188+00:00 0:00:00.891307 371637 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T09:00:36.236634+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T08:00:00+00:00 PythonOperator 2023-05-02T09:00:17.045187+00:00 2023-05-02T09:00:18.002041+00:00 0:00:00.956854 371634 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T09:00:14.084289+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T07:00:00+00:00 TriggerDagRunOperator 2023-05-02T08:13:33.587284+00:00 2023-05-02T08:13:34.005908+00:00 0:00:00.418624 371622 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T08:13:30.862484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T07:00:00+00:00 TriggerDagRunOperator 2023-05-02T08:13:33.504004+00:00 2023-05-02T08:13:34.017516+00:00 0:00:00.513512 371621 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T08:13:30.862449+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T07:00:00+00:00 EmrJobFlowSensor 2023-05-02T08:01:08.873531+00:00 2023-05-02T08:11:10.634871+00:00 0:10:01.761340 371614 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T08:01:06.678700+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T08:00:48.785983+00:00 2023-05-02T08:00:49.647910+00:00 0:00:00.861927 371612 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T08:00:46.659912+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T07:00:00+00:00 PythonOperator 2023-05-02T08:00:27.244688+00:00 2023-05-02T08:00:28.229135+00:00 0:00:00.984447 371610 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T08:00:24.641843+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T06:00:00+00:00 TriggerDagRunOperator 2023-05-02T07:11:01.478994+00:00 2023-05-02T07:11:02.036521+00:00 0:00:00.557527 371596 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T07:10:56.330867+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T06:00:00+00:00 TriggerDagRunOperator 2023-05-02T07:11:01.332831+00:00 2023-05-02T07:11:01.889517+00:00 0:00:00.556686 371595 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T07:10:56.330885+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T06:00:00+00:00 EmrJobFlowSensor 2023-05-02T07:00:52.345032+00:00 2023-05-02T07:10:54.194432+00:00 0:10:01.849400 371591 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T07:00:50.143232+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T07:00:30.997398+00:00 2023-05-02T07:00:32.047605+00:00 0:00:01.050207 371589 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T07:00:28.123648+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T06:00:00+00:00 PythonOperator 2023-05-02T07:00:08.314824+00:00 2023-05-02T07:00:09.326485+00:00 0:00:01.011661 371587 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T07:00:06.103131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T05:00:00+00:00 TriggerDagRunOperator 2023-05-02T06:11:32.418290+00:00 2023-05-02T06:11:32.763856+00:00 0:00:00.345566 371572 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T06:11:30.232466+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T05:00:00+00:00 TriggerDagRunOperator 2023-05-02T06:11:32.406881+00:00 2023-05-02T06:11:32.857962+00:00 0:00:00.451081 371571 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T06:11:30.232497+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T05:00:00+00:00 EmrJobFlowSensor 2023-05-02T06:01:07.796498+00:00 2023-05-02T06:11:09.549269+00:00 0:10:01.752771 371565 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T06:01:05.195221+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T06:00:47.479064+00:00 2023-05-02T06:00:48.217692+00:00 0:00:00.738628 371563 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T06:00:45.188155+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T05:00:00+00:00 PythonOperator 2023-05-02T06:00:25.607802+00:00 2023-05-02T06:00:26.566409+00:00 0:00:00.958607 371561 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T06:00:23.206190+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T04:00:00+00:00 TriggerDagRunOperator 2023-05-02T05:12:01.898207+00:00 2023-05-02T05:12:02.349597+00:00 0:00:00.451390 371546 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T05:11:59.641422+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T04:00:00+00:00 TriggerDagRunOperator 2023-05-02T05:12:01.840957+00:00 2023-05-02T05:12:02.203680+00:00 0:00:00.362723 371545 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T05:11:59.641459+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T04:00:00+00:00 EmrJobFlowSensor 2023-05-02T05:00:48.783823+00:00 2023-05-02T05:11:50.817755+00:00 0:11:02.033932 371538 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T05:00:46.412082+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T05:00:26.676271+00:00 2023-05-02T05:00:27.629519+00:00 0:00:00.953248 371536 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T05:00:24.312180+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T04:00:00+00:00 PythonOperator 2023-05-02T05:00:06.863733+00:00 2023-05-02T05:00:07.771000+00:00 0:00:00.907267 371534 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T05:00:04.302556+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T03:00:00+00:00 TriggerDagRunOperator 2023-05-02T04:15:06.604141+00:00 2023-05-02T04:15:06.949556+00:00 0:00:00.345415 371522 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T04:15:04.191958+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T03:00:00+00:00 TriggerDagRunOperator 2023-05-02T04:15:06.481310+00:00 2023-05-02T04:15:06.982405+00:00 0:00:00.501095 371521 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T04:15:04.191986+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T03:00:00+00:00 EmrJobFlowSensor 2023-05-02T04:04:53.451622+00:00 2023-05-02T04:14:55.251579+00:00 0:10:01.799957 371515 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T04:04:51.326919+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T04:04:31.497743+00:00 2023-05-02T04:04:32.273270+00:00 0:00:00.775527 371513 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T04:04:29.308665+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T03:00:00+00:00 PythonOperator 2023-05-02T04:04:11.453406+00:00 2023-05-02T04:04:12.379821+00:00 0:00:00.926415 371511 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T04:04:09.288213+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T02:00:00+00:00 TriggerDagRunOperator 2023-05-02T03:13:51.450774+00:00 2023-05-02T03:13:51.796088+00:00 0:00:00.345314 371496 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T03:13:49.016037+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T02:00:00+00:00 TriggerDagRunOperator 2023-05-02T03:13:51.414839+00:00 2023-05-02T03:13:51.849898+00:00 0:00:00.435059 371495 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T03:13:49.016066+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T02:00:00+00:00 EmrJobFlowSensor 2023-05-02T03:01:26.149327+00:00 2023-05-02T03:11:27.901417+00:00 0:10:01.752090 371488 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T03:01:23.909960+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T03:01:06.269015+00:00 2023-05-02T03:01:07.561770+00:00 0:00:01.292755 371486 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T03:01:03.908061+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T02:00:00+00:00 PythonOperator 2023-05-02T03:00:44.165493+00:00 2023-05-02T03:00:45.204517+00:00 0:00:01.039024 371484 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T03:00:41.824186+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T01:00:00+00:00 TriggerDagRunOperator 2023-05-02T02:26:22.128850+00:00 2023-05-02T02:26:22.467415+00:00 0:00:00.338565 371474 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T02:26:19.483485+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T01:00:00+00:00 TriggerDagRunOperator 2023-05-02T02:26:22.114117+00:00 2023-05-02T02:26:22.579154+00:00 0:00:00.465037 371473 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T02:26:19.483514+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T01:00:00+00:00 EmrJobFlowSensor 2023-05-02T02:08:36.111482+00:00 2023-05-02T02:18:37.894613+00:00 0:10:01.783131 371470 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T02:08:33.889792+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T02:08:13.994923+00:00 2023-05-02T02:08:14.792107+00:00 0:00:00.797184 371467 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T02:08:11.815147+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T01:00:00+00:00 PythonOperator 2023-05-02T02:07:54.380559+00:00 2023-05-02T02:07:55.304965+00:00 0:00:00.924406 371464 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T02:07:51.793703+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-02T00:00:00+00:00 TriggerDagRunOperator 2023-05-02T01:13:43.678041+00:00 2023-05-02T01:13:44.067080+00:00 0:00:00.389039 371442 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T01:13:40.612139+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-02T00:00:00+00:00 TriggerDagRunOperator 2023-05-02T01:13:43.673012+00:00 2023-05-02T01:13:44.129231+00:00 0:00:00.456219 371441 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T01:13:40.612095+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-02T00:00:00+00:00 EmrJobFlowSensor 2023-05-02T01:03:24.461626+00:00 2023-05-02T01:13:26.263405+00:00 0:10:01.801779 371435 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T01:03:22.191927+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-02T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T01:03:04.317923+00:00 2023-05-02T01:03:05.090780+00:00 0:00:00.772857 371433 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T01:03:02.115754+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-02T00:00:00+00:00 PythonOperator 2023-05-02T01:02:42.279388+00:00 2023-05-02T01:02:43.184416+00:00 0:00:00.905028 371431 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T01:02:40.098384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T23:00:00+00:00 TriggerDagRunOperator 2023-05-02T00:52:05.563938+00:00 2023-05-02T00:52:05.900324+00:00 0:00:00.336386 371422 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T00:52:02.991985+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T23:00:00+00:00 TriggerDagRunOperator 2023-05-02T00:52:05.583940+00:00 2023-05-02T00:52:06.046795+00:00 0:00:00.462855 371421 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-02T00:52:02.991941+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T23:00:00+00:00 EmrJobFlowSensor 2023-05-02T00:41:44.439911+00:00 2023-05-02T00:51:46.473902+00:00 0:10:02.033991 371417 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-02T00:41:42.117638+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-02T00:41:23.600797+00:00 2023-05-02T00:41:24.422227+00:00 0:00:00.821430 371414 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-02T00:41:20.083613+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T23:00:00+00:00 PythonOperator 2023-05-02T00:41:04.382298+00:00 2023-05-02T00:41:05.973133+00:00 0:00:01.590835 371411 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-02T00:41:00.218025+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T22:00:00+00:00 TriggerDagRunOperator 2023-05-01T23:11:13.656805+00:00 2023-05-01T23:11:14.119824+00:00 0:00:00.463019 371399 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T23:11:10.986798+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T22:00:00+00:00 TriggerDagRunOperator 2023-05-01T23:11:13.565302+00:00 2023-05-01T23:11:14.009720+00:00 0:00:00.444418 371398 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T23:11:10.986747+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T22:00:00+00:00 EmrJobFlowSensor 2023-05-01T23:08:01.585357+00:00 2023-05-01T23:11:02.470820+00:00 0:03:00.885463 371393 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T23:07:58.782060+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T23:00:46.644504+00:00 2023-05-01T23:00:47.505967+00:00 0:00:00.861463 371389 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T23:00:43.792112+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T22:00:00+00:00 PythonOperator 2023-05-01T23:00:24.070580+00:00 2023-05-01T23:00:24.965856+00:00 0:00:00.895276 371386 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T23:00:21.799739+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T21:00:00+00:00 TriggerDagRunOperator 2023-05-01T22:10:59.575121+00:00 2023-05-01T22:11:00.187486+00:00 0:00:00.612365 371372 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T22:10:56.894568+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T21:00:00+00:00 TriggerDagRunOperator 2023-05-01T22:10:59.527807+00:00 2023-05-01T22:11:00.234602+00:00 0:00:00.706795 371371 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T22:10:56.894620+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T21:00:00+00:00 EmrJobFlowSensor 2023-05-01T22:00:51.138215+00:00 2023-05-01T22:10:52.891338+00:00 0:10:01.753123 371364 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T22:00:48.786099+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T22:00:28.871023+00:00 2023-05-01T22:00:29.659359+00:00 0:00:00.788336 371362 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T22:00:26.693756+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T21:00:00+00:00 PythonOperator 2023-05-01T22:00:09.022921+00:00 2023-05-01T22:00:09.920002+00:00 0:00:00.897081 371360 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T22:00:06.675076+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T20:00:00+00:00 TriggerDagRunOperator 2023-05-01T21:11:13.820411+00:00 2023-05-01T21:11:14.195645+00:00 0:00:00.375234 371348 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T21:11:11.309087+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T20:00:00+00:00 TriggerDagRunOperator 2023-05-01T21:11:13.823078+00:00 2023-05-01T21:11:14.279634+00:00 0:00:00.456556 371347 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T21:11:11.309059+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T20:00:00+00:00 EmrJobFlowSensor 2023-05-01T21:00:55.862692+00:00 2023-05-01T21:10:58.108479+00:00 0:10:02.245787 371341 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T21:00:52.788911+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T21:00:32.778620+00:00 2023-05-01T21:00:33.688775+00:00 0:00:00.910155 371339 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T21:00:30.606081+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T20:00:00+00:00 PythonOperator 2023-05-01T21:00:12.726589+00:00 2023-05-01T21:00:13.648993+00:00 0:00:00.922404 371337 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T21:00:10.584633+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T19:00:00+00:00 TriggerDagRunOperator 2023-05-01T20:11:15.140474+00:00 2023-05-01T20:11:15.603701+00:00 0:00:00.463227 371322 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T20:11:12.608607+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T19:00:00+00:00 TriggerDagRunOperator 2023-05-01T20:11:15.126685+00:00 2023-05-01T20:11:15.482474+00:00 0:00:00.355789 371321 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T20:11:12.608634+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T19:00:00+00:00 EmrJobFlowSensor 2023-05-01T20:00:52.360699+00:00 2023-05-01T20:10:54.143688+00:00 0:10:01.782989 371314 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T20:00:50.219644+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T20:00:30.481257+00:00 2023-05-01T20:00:31.346029+00:00 0:00:00.864772 371312 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T20:00:28.200019+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T19:00:00+00:00 PythonOperator 2023-05-01T20:00:08.565222+00:00 2023-05-01T20:00:09.639132+00:00 0:00:01.073910 371310 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T20:00:06.179256+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T18:00:00+00:00 TriggerDagRunOperator 2023-05-01T19:16:37.050179+00:00 2023-05-01T19:16:37.525600+00:00 0:00:00.475421 371295 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T19:16:33.802762+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T18:00:00+00:00 TriggerDagRunOperator 2023-05-01T19:16:36.327993+00:00 2023-05-01T19:16:36.680259+00:00 0:00:00.352266 371294 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T19:16:33.802734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T18:00:00+00:00 EmrJobFlowSensor 2023-05-01T19:00:54.270569+00:00 2023-05-01T19:10:56.088291+00:00 0:10:01.817722 371287 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T19:00:52.118551+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T19:00:34.268305+00:00 2023-05-01T19:00:35.013254+00:00 0:00:00.744949 371286 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T19:00:32.090490+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T18:00:00+00:00 PythonOperator 2023-05-01T19:00:12.676688+00:00 2023-05-01T19:00:13.629882+00:00 0:00:00.953194 371284 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T19:00:10.070962+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T17:00:00+00:00 TriggerDagRunOperator 2023-05-01T18:11:24.354295+00:00 2023-05-01T18:11:24.702797+00:00 0:00:00.348502 371270 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T18:11:22.075235+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T17:00:00+00:00 TriggerDagRunOperator 2023-05-01T18:11:24.312411+00:00 2023-05-01T18:11:24.769876+00:00 0:00:00.457465 371269 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T18:11:22.075271+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T17:00:00+00:00 EmrJobFlowSensor 2023-05-01T18:00:59.715257+00:00 2023-05-01T18:11:01.827665+00:00 0:10:02.112408 371263 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T18:00:57.394089+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T18:00:37.724768+00:00 2023-05-01T18:00:38.611604+00:00 0:00:00.886836 371262 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T18:00:35.311126+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T17:00:00+00:00 PythonOperator 2023-05-01T18:00:17.838233+00:00 2023-05-01T18:00:18.725658+00:00 0:00:00.887425 371260 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T18:00:15.293182+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T16:00:00+00:00 TriggerDagRunOperator 2023-05-01T17:15:50.304180+00:00 2023-05-01T17:15:50.754682+00:00 0:00:00.450502 371243 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T17:15:48.003773+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T16:00:00+00:00 TriggerDagRunOperator 2023-05-01T17:15:50.214052+00:00 2023-05-01T17:15:50.582966+00:00 0:00:00.368914 371242 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T17:15:48.003807+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T16:00:00+00:00 EmrJobFlowSensor 2023-05-01T17:00:52.317123+00:00 2023-05-01T17:10:54.165403+00:00 0:10:01.848280 371238 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T17:00:50.136232+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T17:00:32.301052+00:00 2023-05-01T17:00:33.239276+00:00 0:00:00.938224 371237 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T17:00:30.132655+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T16:00:00+00:00 PythonOperator 2023-05-01T17:00:10.918392+00:00 2023-05-01T17:00:11.876984+00:00 0:00:00.958592 371236 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T17:00:08.031051+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T15:00:00+00:00 TriggerDagRunOperator 2023-05-01T16:24:23.309572+00:00 2023-05-01T16:24:23.706274+00:00 0:00:00.396702 371224 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T16:24:20.335423+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T15:00:00+00:00 TriggerDagRunOperator 2023-05-01T16:24:23.318902+00:00 2023-05-01T16:24:23.826568+00:00 0:00:00.507666 371223 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T16:24:20.335468+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T15:00:00+00:00 EmrJobFlowSensor 2023-05-01T16:14:14.212657+00:00 2023-05-01T16:24:15.993696+00:00 0:10:01.781039 371218 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T16:14:11.989800+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-01T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-01T16:13:54.152707+00:00 2023-05-01T16:13:54.890111+00:00 0:00:00.737404 371215 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-01T16:13:51.974492+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-01T15:00:00+00:00 PythonOperator 2023-05-01T16:13:32.695736+00:00 2023-05-01T16:13:33.628522+00:00 0:00:00.932786 371212 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-01T16:13:29.967912+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-01T14:00:00+00:00 TriggerDagRunOperator 2023-05-01T15:18:46.654770+00:00 2023-05-01T15:18:47.079385+00:00 0:00:00.424615 371193 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T15:18:43.782904+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-01T14:00:00+00:00 TriggerDagRunOperator 2023-05-01T15:18:46.581446+00:00 2023-05-01T15:18:46.930442+00:00 0:00:00.348996 371192 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-01T15:18:43.782940+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-01T14:00:00+00:00 EmrJobFlowSensor 2023-05-01T15:00:47.785067+00:00 2023-05-01T15:10:49.525597+00:00 0:10:01.740530 371190 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-01T15:00:45.412481+00:00 2 default_pool