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-16T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T15:03:51.539561+00:00 2023-05-16T15:03:52.508183+00:00 0:00:00.968622 380304 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T15:03:49.205234+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T14:00:00+00:00 PythonOperator 2023-05-16T15:03:31.489015+00:00 2023-05-16T15:03:32.586161+00:00 0:00:01.097146 380302 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T15:03:29.168697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T13:00:00+00:00 TriggerDagRunOperator 2023-05-16T14:11:06.706472+00:00 2023-05-16T14:11:07.138351+00:00 0:00:00.431879 380290 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T14:11:04.423026+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T13:00:00+00:00 TriggerDagRunOperator 2023-05-16T14:11:06.650096+00:00 2023-05-16T14:11:06.982593+00:00 0:00:00.332497 380289 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T14:11:04.422994+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T13:00:00+00:00 EmrJobFlowSensor 2023-05-16T14:00:57.757503+00:00 2023-05-16T14:10:59.675557+00:00 0:10:01.918054 380283 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T14:00:55.522914+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T14:00:36.136059+00:00 2023-05-16T14:00:37.083487+00:00 0:00:00.947428 380281 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T14:00:33.597906+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T13:00:00+00:00 PythonOperator 2023-05-16T14:00:15.619894+00:00 2023-05-16T14:00:16.717867+00:00 0:00:01.097973 380279 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T14:00:13.425841+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T12:00:00+00:00 TriggerDagRunOperator 2023-05-16T13:10:45.398737+00:00 2023-05-16T13:10:45.835381+00:00 0:00:00.436644 380266 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T13:10:43.111571+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T12:00:00+00:00 TriggerDagRunOperator 2023-05-16T13:10:45.352121+00:00 2023-05-16T13:10:45.673156+00:00 0:00:00.321035 380265 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T13:10:43.111607+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T12:00:00+00:00 EmrJobFlowSensor 2023-05-16T13:07:35.223683+00:00 2023-05-16T13:10:36.090616+00:00 0:03:00.866933 380260 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T13:07:32.842939+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T13:00:30.650248+00:00 2023-05-16T13:00:31.481196+00:00 0:00:00.830948 380256 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T13:00:28.296824+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T12:00:00+00:00 PythonOperator 2023-05-16T13:00:08.852637+00:00 2023-05-16T13:00:09.966099+00:00 0:00:01.113462 380254 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T13:00:06.280459+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T11:00:00+00:00 TriggerDagRunOperator 2023-05-16T12:25:47.300021+00:00 2023-05-16T12:25:47.746180+00:00 0:00:00.446159 380244 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T12:25:44.310895+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T11:00:00+00:00 TriggerDagRunOperator 2023-05-16T12:25:47.197061+00:00 2023-05-16T12:25:47.538644+00:00 0:00:00.341583 380243 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T12:25:44.310853+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T11:00:00+00:00 EmrJobFlowSensor 2023-05-16T12:01:01.953357+00:00 2023-05-16T12:11:03.890655+00:00 0:10:01.937298 380236 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T12:00:59.837892+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T12:00:41.968250+00:00 2023-05-16T12:00:42.742300+00:00 0:00:00.774050 380234 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T12:00:39.804046+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T11:00:00+00:00 PythonOperator 2023-05-16T12:00:19.945572+00:00 2023-05-16T12:00:21.006370+00:00 0:00:01.060798 380232 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T12:00:17.779605+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T10:00:00+00:00 TriggerDagRunOperator 2023-05-16T11:19:02.092072+00:00 2023-05-16T11:19:02.527224+00:00 0:00:00.435152 380219 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T11:18:58.508777+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T10:00:00+00:00 TriggerDagRunOperator 2023-05-16T11:19:01.525191+00:00 2023-05-16T11:19:01.972952+00:00 0:00:00.447761 380218 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T11:18:58.508813+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T10:00:00+00:00 EmrJobFlowSensor 2023-05-16T11:07:54.049849+00:00 2023-05-16T11:18:56.051129+00:00 0:11:02.001280 380215 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T11:07:51.312307+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T11:07:35.062964+00:00 2023-05-16T11:07:35.962124+00:00 0:00:00.899160 380212 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T11:07:31.234820+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T10:00:00+00:00 PythonOperator 2023-05-16T11:07:11.905474+00:00 2023-05-16T11:07:12.906888+00:00 0:00:01.001414 380209 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T11:07:09.219014+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T09:00:00+00:00 TriggerDagRunOperator 2023-05-16T10:11:19.515477+00:00 2023-05-16T10:11:19.892781+00:00 0:00:00.377304 380195 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T10:11:17.241671+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T09:00:00+00:00 TriggerDagRunOperator 2023-05-16T10:11:19.515375+00:00 2023-05-16T10:11:19.951884+00:00 0:00:00.436509 380194 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T10:11:17.241624+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T09:00:00+00:00 EmrJobFlowSensor 2023-05-16T10:00:54.812235+00:00 2023-05-16T10:10:56.741986+00:00 0:10:01.929751 380187 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T10:00:51.798725+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T10:00:32.391978+00:00 2023-05-16T10:00:33.215045+00:00 0:00:00.823067 380185 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T10:00:29.802557+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T09:00:00+00:00 PythonOperator 2023-05-16T10:00:10.483912+00:00 2023-05-16T10:00:11.562835+00:00 0:00:01.078923 380183 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T10:00:07.781904+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T08:00:00+00:00 TriggerDagRunOperator 2023-05-16T09:11:28.010815+00:00 2023-05-16T09:11:28.461812+00:00 0:00:00.450997 380171 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T09:11:25.072103+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T08:00:00+00:00 TriggerDagRunOperator 2023-05-16T09:11:27.906456+00:00 2023-05-16T09:11:28.246340+00:00 0:00:00.339884 380170 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T09:11:25.072132+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T08:00:00+00:00 EmrJobFlowSensor 2023-05-16T09:01:10.834308+00:00 2023-05-16T09:11:12.667646+00:00 0:10:01.833338 380162 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T09:01:08.672546+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T09:00:51.217741+00:00 2023-05-16T09:00:52.025709+00:00 0:00:00.807968 380160 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T09:00:48.635264+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T08:00:00+00:00 PythonOperator 2023-05-16T09:00:03.860167+00:00 2023-05-16T09:00:04.968490+00:00 0:00:01.108323 380158 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T09:00:01.529830+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T07:00:00+00:00 TriggerDagRunOperator 2023-05-16T08:12:13.008758+00:00 2023-05-16T08:12:13.440768+00:00 0:00:00.432010 380145 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T08:12:10.752589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T07:00:00+00:00 TriggerDagRunOperator 2023-05-16T08:12:12.954538+00:00 2023-05-16T08:12:13.279916+00:00 0:00:00.325378 380144 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T08:12:10.752554+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T07:00:00+00:00 EmrJobFlowSensor 2023-05-16T08:01:03.309861+00:00 2023-05-16T08:12:05.227622+00:00 0:11:01.917761 380137 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T08:01:01.159723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T08:00:41.525447+00:00 2023-05-16T08:00:42.359500+00:00 0:00:00.834053 380135 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T08:00:39.195108+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T07:00:00+00:00 PythonOperator 2023-05-16T08:00:20.112079+00:00 2023-05-16T08:00:22.028997+00:00 0:00:01.916918 380133 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T08:00:17.119674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T06:00:00+00:00 TriggerDagRunOperator 2023-05-16T07:12:48.282165+00:00 2023-05-16T07:12:48.770117+00:00 0:00:00.487952 380121 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T07:12:45.534615+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T06:00:00+00:00 TriggerDagRunOperator 2023-05-16T07:12:48.230700+00:00 2023-05-16T07:12:48.632241+00:00 0:00:00.401541 380120 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T07:12:45.534650+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T06:00:00+00:00 EmrJobFlowSensor 2023-05-16T07:01:04.928484+00:00 2023-05-16T07:12:06.941237+00:00 0:11:02.012753 380112 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T07:01:02.668328+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T07:00:43.022526+00:00 2023-05-16T07:00:44.172461+00:00 0:00:01.149935 380110 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T07:00:40.708038+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T06:00:00+00:00 PythonOperator 2023-05-16T07:00:23.553026+00:00 2023-05-16T07:00:24.650913+00:00 0:00:01.097887 380109 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T07:00:20.512462+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T05:00:00+00:00 TriggerDagRunOperator 2023-05-16T06:23:19.798309+00:00 2023-05-16T06:23:20.227950+00:00 0:00:00.429641 380098 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T06:23:16.696293+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T05:00:00+00:00 TriggerDagRunOperator 2023-05-16T06:23:19.398517+00:00 2023-05-16T06:23:19.848128+00:00 0:00:00.449611 380097 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T06:23:16.696322+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T05:00:00+00:00 EmrJobFlowSensor 2023-05-16T06:12:51.422862+00:00 2023-05-16T06:22:53.230522+00:00 0:10:01.807660 380092 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T06:12:49.244046+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T06:12:31.386869+00:00 2023-05-16T06:12:32.194351+00:00 0:00:00.807482 380089 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T06:12:29.227254+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T05:00:00+00:00 PythonOperator 2023-05-16T06:12:10.081754+00:00 2023-05-16T06:12:11.150149+00:00 0:00:01.068395 380086 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T06:12:07.098367+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T04:00:00+00:00 TriggerDagRunOperator 2023-05-16T05:12:11.789007+00:00 2023-05-16T05:12:12.200026+00:00 0:00:00.411019 380073 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T05:12:08.800191+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T04:00:00+00:00 TriggerDagRunOperator 2023-05-16T05:12:11.809575+00:00 2023-05-16T05:12:12.294856+00:00 0:00:00.485281 380072 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T05:12:08.800235+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T04:00:00+00:00 EmrJobFlowSensor 2023-05-16T05:00:59.706298+00:00 2023-05-16T05:12:01.967397+00:00 0:11:02.261099 380066 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T05:00:57.307635+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T05:00:39.542527+00:00 2023-05-16T05:00:40.351591+00:00 0:00:00.809064 380064 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T05:00:37.229221+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T04:00:00+00:00 PythonOperator 2023-05-16T05:00:17.320142+00:00 2023-05-16T05:00:18.411282+00:00 0:00:01.091140 380062 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T05:00:15.206080+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T03:00:00+00:00 TriggerDagRunOperator 2023-05-16T04:12:03.577386+00:00 2023-05-16T04:12:04.053306+00:00 0:00:00.475920 380045 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T04:12:00.780602+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T03:00:00+00:00 TriggerDagRunOperator 2023-05-16T04:12:03.411173+00:00 2023-05-16T04:12:03.810623+00:00 0:00:00.399450 380044 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T04:12:00.780652+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T03:00:00+00:00 EmrJobFlowSensor 2023-05-16T04:00:49.169837+00:00 2023-05-16T04:11:51.111182+00:00 0:11:01.941345 380037 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T04:00:47.005884+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T04:00:27.614455+00:00 2023-05-16T04:00:28.549168+00:00 0:00:00.934713 380035 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T04:00:24.918446+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T03:00:00+00:00 PythonOperator 2023-05-16T04:00:07.155392+00:00 2023-05-16T04:00:08.193432+00:00 0:00:01.038040 380033 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T04:00:04.898015+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T02:00:00+00:00 TriggerDagRunOperator 2023-05-16T03:11:15.740846+00:00 2023-05-16T03:11:16.174591+00:00 0:00:00.433745 380018 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T03:11:13.231320+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T02:00:00+00:00 TriggerDagRunOperator 2023-05-16T03:11:15.632835+00:00 2023-05-16T03:11:15.971805+00:00 0:00:00.338970 380017 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T03:11:13.231350+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T02:00:00+00:00 EmrJobFlowSensor 2023-05-16T03:00:55.340125+00:00 2023-05-16T03:10:57.216640+00:00 0:10:01.876515 380010 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T03:00:53.082620+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T03:00:33.230762+00:00 2023-05-16T03:00:34.299602+00:00 0:00:01.068840 380008 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T03:00:30.935641+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T02:00:00+00:00 PythonOperator 2023-05-16T03:00:13.113497+00:00 2023-05-16T03:00:14.232854+00:00 0:00:01.119357 380006 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T03:00:10.918606+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T01:00:00+00:00 TriggerDagRunOperator 2023-05-16T02:16:39.351813+00:00 2023-05-16T02:16:39.788546+00:00 0:00:00.436733 379994 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T02:16:36.234203+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T01:00:00+00:00 TriggerDagRunOperator 2023-05-16T02:16:39.122830+00:00 2023-05-16T02:16:39.492463+00:00 0:00:00.369633 379993 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T02:16:36.234242+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T01:00:00+00:00 EmrJobFlowSensor 2023-05-16T02:01:09.398532+00:00 2023-05-16T02:11:11.096589+00:00 0:10:01.698057 379986 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T02:01:07.234224+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T02:00:45.452358+00:00 2023-05-16T02:00:46.207774+00:00 0:00:00.755416 379984 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T02:00:43.212453+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T01:00:00+00:00 PythonOperator 2023-05-16T02:00:23.542045+00:00 2023-05-16T02:00:24.622766+00:00 0:00:01.080721 379982 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T02:00:21.183387+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-16T00:00:00+00:00 TriggerDagRunOperator 2023-05-16T01:11:06.142151+00:00 2023-05-16T01:11:06.491281+00:00 0:00:00.349130 379961 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T01:11:03.759447+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-16T00:00:00+00:00 TriggerDagRunOperator 2023-05-16T01:11:06.163843+00:00 2023-05-16T01:11:06.623920+00:00 0:00:00.460077 379960 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T01:11:03.759417+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-16T00:00:00+00:00 EmrJobFlowSensor 2023-05-16T01:00:46.342665+00:00 2023-05-16T01:10:48.361279+00:00 0:10:02.018614 379952 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T01:00:43.990688+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-16T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T01:00:26.207597+00:00 2023-05-16T01:00:27.167767+00:00 0:00:00.960170 379950 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T01:00:23.914400+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-16T00:00:00+00:00 PythonOperator 2023-05-16T01:00:04.532590+00:00 2023-05-16T01:00:05.578588+00:00 0:00:01.045998 379948 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T01:00:01.895947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T23:00:00+00:00 TriggerDagRunOperator 2023-05-16T00:12:24.624267+00:00 2023-05-16T00:12:25.042399+00:00 0:00:00.418132 379934 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T00:12:20.998928+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T23:00:00+00:00 TriggerDagRunOperator 2023-05-16T00:12:24.083852+00:00 2023-05-16T00:12:24.530358+00:00 0:00:00.446506 379933 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-16T00:12:20.998967+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T23:00:00+00:00 EmrJobFlowSensor 2023-05-16T00:01:00.948195+00:00 2023-05-16T00:12:03.082480+00:00 0:11:02.134285 379926 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-16T00:00:58.719605+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-16T00:00:40.923713+00:00 2023-05-16T00:00:41.631074+00:00 0:00:00.707361 379924 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-16T00:00:38.691157+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T23:00:00+00:00 PythonOperator 2023-05-16T00:00:17.892000+00:00 2023-05-16T00:00:18.936565+00:00 0:00:01.044565 379922 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-16T00:00:14.609074+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T22:00:00+00:00 TriggerDagRunOperator 2023-05-15T23:11:12.480158+00:00 2023-05-15T23:11:12.967518+00:00 0:00:00.487360 379907 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T23:11:10.011569+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T22:00:00+00:00 TriggerDagRunOperator 2023-05-15T23:11:12.374424+00:00 2023-05-15T23:11:12.812249+00:00 0:00:00.437825 379906 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T23:11:10.011600+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T22:00:00+00:00 EmrJobFlowSensor 2023-05-15T23:00:52.976653+00:00 2023-05-15T23:10:54.933508+00:00 0:10:01.956855 379898 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T23:00:50.662437+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T23:00:32.364553+00:00 2023-05-15T23:00:33.192463+00:00 0:00:00.827910 379896 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T23:00:28.705122+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T22:00:00+00:00 PythonOperator 2023-05-15T23:00:12.066612+00:00 2023-05-15T23:00:13.834028+00:00 0:00:01.767416 379893 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T23:00:06.597416+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T21:00:00+00:00 TriggerDagRunOperator 2023-05-15T22:11:22.038185+00:00 2023-05-15T22:11:22.539285+00:00 0:00:00.501100 379877 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T22:11:19.304006+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T21:00:00+00:00 TriggerDagRunOperator 2023-05-15T22:11:21.899857+00:00 2023-05-15T22:11:22.384267+00:00 0:00:00.484410 379876 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T22:11:19.303978+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T21:00:00+00:00 EmrJobFlowSensor 2023-05-15T22:01:08.015661+00:00 2023-05-15T22:11:09.821989+00:00 0:10:01.806328 379869 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T22:01:05.501512+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T22:00:45.593292+00:00 2023-05-15T22:00:46.452570+00:00 0:00:00.859278 379867 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T22:00:43.347766+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T21:00:00+00:00 PythonOperator 2023-05-15T22:00:25.391238+00:00 2023-05-15T22:00:26.437484+00:00 0:00:01.046246 379865 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T22:00:21.323127+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T20:00:00+00:00 TriggerDagRunOperator 2023-05-15T21:11:14.880865+00:00 2023-05-15T21:11:15.307041+00:00 0:00:00.426176 379851 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T21:11:12.082772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T20:00:00+00:00 TriggerDagRunOperator 2023-05-15T21:11:14.698176+00:00 2023-05-15T21:11:15.110464+00:00 0:00:00.412288 379850 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T21:11:12.082727+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T20:00:00+00:00 EmrJobFlowSensor 2023-05-15T21:00:57.108340+00:00 2023-05-15T21:10:58.893999+00:00 0:10:01.785659 379842 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T21:00:54.992774+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T21:00:37.113651+00:00 2023-05-15T21:00:37.932481+00:00 0:00:00.818830 379840 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T21:00:34.968327+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T20:00:00+00:00 PythonOperator 2023-05-15T21:00:15.537838+00:00 2023-05-15T21:00:16.578741+00:00 0:00:01.040903 379838 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T21:00:12.951035+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T19:00:00+00:00 TriggerDagRunOperator 2023-05-15T20:11:13.237390+00:00 2023-05-15T20:11:13.690638+00:00 0:00:00.453248 379825 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T20:11:10.395382+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T19:00:00+00:00 TriggerDagRunOperator 2023-05-15T20:11:13.103927+00:00 2023-05-15T20:11:13.737257+00:00 0:00:00.633330 379824 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T20:11:10.395330+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T19:00:00+00:00 EmrJobFlowSensor 2023-05-15T20:00:56.766589+00:00 2023-05-15T20:10:58.652427+00:00 0:10:01.885838 379817 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T20:00:54.553607+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T20:00:36.789559+00:00 2023-05-15T20:00:37.666872+00:00 0:00:00.877313 379815 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T20:00:34.546293+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T19:00:00+00:00 PythonOperator 2023-05-15T20:00:15.489306+00:00 2023-05-15T20:00:16.523236+00:00 0:00:01.033930 379813 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T20:00:12.520416+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T18:00:00+00:00 TriggerDagRunOperator 2023-05-15T19:11:09.930423+00:00 2023-05-15T19:11:10.367176+00:00 0:00:00.436753 379795 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T19:11:07.410560+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T18:00:00+00:00 TriggerDagRunOperator 2023-05-15T19:11:09.868033+00:00 2023-05-15T19:11:10.234624+00:00 0:00:00.366591 379794 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T19:11:07.410531+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T18:00:00+00:00 EmrJobFlowSensor 2023-05-15T19:00:56.808423+00:00 2023-05-15T19:10:58.644085+00:00 0:10:01.835662 379786 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T19:00:54.713037+00:00 2 default_pool