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-30T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T19:00:40.397863+00:00 2023-05-30T19:00:41.340845+00:00 0:00:00.942982 388464 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T19:00:38.258897+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T18:00:00+00:00 PythonOperator 2023-05-30T19:00:20.320731+00:00 2023-05-30T19:00:21.237859+00:00 0:00:00.917128 388463 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T19:00:18.241465+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T17:00:00+00:00 TriggerDagRunOperator 2023-05-30T18:11:21.516216+00:00 2023-05-30T18:11:21.952948+00:00 0:00:00.436732 388449 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T18:11:19.291231+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T17:00:00+00:00 TriggerDagRunOperator 2023-05-30T18:11:21.531074+00:00 2023-05-30T18:11:21.984931+00:00 0:00:00.453857 388448 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T18:11:19.291201+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T17:00:00+00:00 EmrJobFlowSensor 2023-05-30T18:01:07.106885+00:00 2023-05-30T18:11:08.949703+00:00 0:10:01.842818 388441 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T18:01:04.980482+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T18:00:45.280990+00:00 2023-05-30T18:00:46.277274+00:00 0:00:00.996284 388440 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T18:00:42.959823+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T17:00:00+00:00 PythonOperator 2023-05-30T18:00:23.053211+00:00 2023-05-30T18:00:23.990988+00:00 0:00:00.937777 388439 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T18:00:20.961271+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T16:00:00+00:00 TriggerDagRunOperator 2023-05-30T17:11:03.186950+00:00 2023-05-30T17:11:03.601393+00:00 0:00:00.414443 388427 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T17:11:00.876529+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T16:00:00+00:00 TriggerDagRunOperator 2023-05-30T17:11:03.081956+00:00 2023-05-30T17:11:03.512728+00:00 0:00:00.430772 388426 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T17:11:00.876501+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T16:00:00+00:00 EmrJobFlowSensor 2023-05-30T17:00:50.301529+00:00 2023-05-30T17:10:51.955302+00:00 0:10:01.653773 388417 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T17:00:48.194985+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T17:00:28.251725+00:00 2023-05-30T17:00:29.077968+00:00 0:00:00.826243 388416 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T17:00:26.173598+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T16:00:00+00:00 PythonOperator 2023-05-30T17:00:06.690759+00:00 2023-05-30T17:00:07.644925+00:00 0:00:00.954166 388415 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T17:00:04.209427+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T15:00:00+00:00 TriggerDagRunOperator 2023-05-30T16:11:01.037700+00:00 2023-05-30T16:11:01.473253+00:00 0:00:00.435553 388405 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T16:10:58.906425+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T15:00:00+00:00 TriggerDagRunOperator 2023-05-30T16:11:01.012780+00:00 2023-05-30T16:11:01.472520+00:00 0:00:00.459740 388404 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T16:10:58.906390+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T15:00:00+00:00 EmrJobFlowSensor 2023-05-30T16:00:52.896824+00:00 2023-05-30T16:10:54.675554+00:00 0:10:01.778730 388397 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T16:00:50.894877+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T16:00:33.014332+00:00 2023-05-30T16:00:33.895592+00:00 0:00:00.881260 388395 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T16:00:30.872450+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T15:00:00+00:00 PythonOperator 2023-05-30T16:00:11.211918+00:00 2023-05-30T16:00:12.164938+00:00 0:00:00.953020 388393 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T16:00:08.852017+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T14:00:00+00:00 TriggerDagRunOperator 2023-05-30T15:11:14.214014+00:00 2023-05-30T15:11:14.786355+00:00 0:00:00.572341 388384 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T15:11:12.095601+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T14:00:00+00:00 TriggerDagRunOperator 2023-05-30T15:11:14.182931+00:00 2023-05-30T15:11:14.832092+00:00 0:00:00.649161 388383 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T15:11:12.095631+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T14:00:00+00:00 EmrJobFlowSensor 2023-05-30T15:01:01.018388+00:00 2023-05-30T15:11:02.983445+00:00 0:10:01.965057 388377 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T15:00:58.962658+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T15:00:41.039883+00:00 2023-05-30T15:00:42.166922+00:00 0:00:01.127039 388375 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T15:00:38.945953+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T14:00:00+00:00 PythonOperator 2023-05-30T15:00:18.999201+00:00 2023-05-30T15:00:19.889288+00:00 0:00:00.890087 388373 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T15:00:16.928101+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T13:00:00+00:00 TriggerDagRunOperator 2023-05-30T14:11:26.846344+00:00 2023-05-30T14:11:27.279110+00:00 0:00:00.432766 388363 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T14:11:24.706380+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T13:00:00+00:00 TriggerDagRunOperator 2023-05-30T14:11:26.780147+00:00 2023-05-30T14:11:27.221549+00:00 0:00:00.441402 388362 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T14:11:24.706410+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T13:00:00+00:00 EmrJobFlowSensor 2023-05-30T14:01:06.176498+00:00 2023-05-30T14:11:08.108355+00:00 0:10:01.931857 388356 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T14:01:04.104620+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T14:00:46.156483+00:00 2023-05-30T14:00:47.022905+00:00 0:00:00.866422 388354 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T14:00:44.085537+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T13:00:00+00:00 PythonOperator 2023-05-30T14:00:24.170783+00:00 2023-05-30T14:00:25.166665+00:00 0:00:00.995882 388352 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T14:00:22.064527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T12:00:00+00:00 TriggerDagRunOperator 2023-05-30T13:20:53.526194+00:00 2023-05-30T13:20:53.972073+00:00 0:00:00.445879 388345 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T13:20:50.994203+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T12:00:00+00:00 TriggerDagRunOperator 2023-05-30T13:20:53.445991+00:00 2023-05-30T13:20:53.857724+00:00 0:00:00.411733 388344 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T13:20:50.994235+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T12:00:00+00:00 EmrJobFlowSensor 2023-05-30T13:08:01.656800+00:00 2023-05-30T13:18:03.420760+00:00 0:10:01.763960 388340 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T13:07:59.370288+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T13:07:39.416579+00:00 2023-05-30T13:07:40.546881+00:00 0:00:01.130302 388337 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T13:07:37.348558+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T12:00:00+00:00 PythonOperator 2023-05-30T13:07:19.334069+00:00 2023-05-30T13:07:20.687417+00:00 0:00:01.353348 388334 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T13:07:17.330984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T11:00:00+00:00 TriggerDagRunOperator 2023-05-30T12:11:03.737857+00:00 2023-05-30T12:11:04.172471+00:00 0:00:00.434614 388324 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T12:11:01.647371+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T11:00:00+00:00 TriggerDagRunOperator 2023-05-30T12:11:03.715650+00:00 2023-05-30T12:11:04.164551+00:00 0:00:00.448901 388323 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T12:11:01.647337+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T11:00:00+00:00 EmrJobFlowSensor 2023-05-30T12:00:49.670463+00:00 2023-05-30T12:10:51.449054+00:00 0:10:01.778591 388316 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T12:00:47.556648+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T12:00:27.679352+00:00 2023-05-30T12:00:28.544056+00:00 0:00:00.864704 388314 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T12:00:25.537112+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T11:00:00+00:00 PythonOperator 2023-05-30T12:00:07.874324+00:00 2023-05-30T12:00:08.764703+00:00 0:00:00.890379 388313 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T12:00:05.519486+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T10:00:00+00:00 TriggerDagRunOperator 2023-05-30T11:11:54.626731+00:00 2023-05-30T11:11:55.170796+00:00 0:00:00.544065 388302 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T11:11:52.312366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T10:00:00+00:00 TriggerDagRunOperator 2023-05-30T11:11:54.609963+00:00 2023-05-30T11:11:55.141614+00:00 0:00:00.531651 388301 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T11:11:52.312337+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T10:00:00+00:00 EmrJobFlowSensor 2023-05-30T11:01:33.163543+00:00 2023-05-30T11:11:34.980493+00:00 0:10:01.816950 388295 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T11:01:31.091308+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T11:01:11.236922+00:00 2023-05-30T11:01:12.159809+00:00 0:00:00.922887 388293 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T11:01:09.063796+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T10:00:00+00:00 PythonOperator 2023-05-30T11:00:51.332272+00:00 2023-05-30T11:00:52.400696+00:00 0:00:01.068424 388291 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T11:00:49.044594+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T09:00:00+00:00 TriggerDagRunOperator 2023-05-30T10:11:20.023137+00:00 2023-05-30T10:11:20.450521+00:00 0:00:00.427384 388281 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T10:11:17.887513+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T09:00:00+00:00 TriggerDagRunOperator 2023-05-30T10:11:19.949051+00:00 2023-05-30T10:11:20.401702+00:00 0:00:00.452651 388280 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T10:11:17.887480+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T09:00:00+00:00 EmrJobFlowSensor 2023-05-30T10:01:01.184067+00:00 2023-05-30T10:11:02.988841+00:00 0:10:01.804774 388274 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T10:00:59.032488+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T10:00:39.188766+00:00 2023-05-30T10:00:40.077356+00:00 0:00:00.888590 388272 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T10:00:37.022236+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T09:00:00+00:00 PythonOperator 2023-05-30T10:00:17.592078+00:00 2023-05-30T10:00:19.132237+00:00 0:00:01.540159 388269 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T10:00:15.000278+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T08:00:00+00:00 TriggerDagRunOperator 2023-05-30T09:10:53.054915+00:00 2023-05-30T09:10:53.469128+00:00 0:00:00.414213 388258 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T09:10:50.719397+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T08:00:00+00:00 TriggerDagRunOperator 2023-05-30T09:10:52.879936+00:00 2023-05-30T09:10:53.371659+00:00 0:00:00.491723 388257 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T09:10:50.719363+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T08:00:00+00:00 EmrJobFlowSensor 2023-05-30T09:00:46.148391+00:00 2023-05-30T09:10:48.050615+00:00 0:10:01.902224 388250 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T09:00:44.001823+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T09:00:26.176012+00:00 2023-05-30T09:00:27.096732+00:00 0:00:00.920720 388248 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T09:00:24.003036+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T08:00:00+00:00 PythonOperator 2023-05-30T09:00:04.413707+00:00 2023-05-30T09:00:05.334368+00:00 0:00:00.920661 388246 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T09:00:01.987717+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T07:00:00+00:00 TriggerDagRunOperator 2023-05-30T08:11:20.038435+00:00 2023-05-30T08:11:20.471700+00:00 0:00:00.433265 388236 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T08:11:17.968729+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T07:00:00+00:00 TriggerDagRunOperator 2023-05-30T08:11:19.968839+00:00 2023-05-30T08:11:20.415566+00:00 0:00:00.446727 388235 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T08:11:17.968696+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T07:00:00+00:00 EmrJobFlowSensor 2023-05-30T08:00:58.977183+00:00 2023-05-30T08:11:00.671038+00:00 0:10:01.693855 388229 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T08:00:56.871922+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T08:00:36.960174+00:00 2023-05-30T08:00:37.823923+00:00 0:00:00.863749 388227 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T08:00:34.853065+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T07:00:00+00:00 PythonOperator 2023-05-30T08:00:16.826108+00:00 2023-05-30T08:00:17.823068+00:00 0:00:00.996960 388225 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T08:00:14.832375+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T06:00:00+00:00 TriggerDagRunOperator 2023-05-30T07:11:56.152385+00:00 2023-05-30T07:11:56.634653+00:00 0:00:00.482268 388215 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T07:11:53.707494+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T06:00:00+00:00 TriggerDagRunOperator 2023-05-30T07:11:56.176810+00:00 2023-05-30T07:11:56.687694+00:00 0:00:00.510884 388214 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T07:11:53.707459+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T06:00:00+00:00 EmrJobFlowSensor 2023-05-30T07:00:49.845434+00:00 2023-05-30T07:10:51.593180+00:00 0:10:01.747746 388206 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T07:00:47.831342+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T07:00:28.257252+00:00 2023-05-30T07:00:29.169443+00:00 0:00:00.912191 388204 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T07:00:25.812188+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T06:00:00+00:00 PythonOperator 2023-05-30T07:00:07.861911+00:00 2023-05-30T07:00:08.725615+00:00 0:00:00.863704 388202 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T07:00:05.792638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T05:00:00+00:00 TriggerDagRunOperator 2023-05-30T06:12:22.658191+00:00 2023-05-30T06:12:23.118560+00:00 0:00:00.460369 388193 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T06:12:20.188964+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T05:00:00+00:00 TriggerDagRunOperator 2023-05-30T06:12:22.596560+00:00 2023-05-30T06:12:23.028717+00:00 0:00:00.432157 388192 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T06:12:20.188936+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T05:00:00+00:00 EmrJobFlowSensor 2023-05-30T06:02:02.843792+00:00 2023-05-30T06:12:04.664318+00:00 0:10:01.820526 388185 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T06:02:00.836173+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T06:01:42.868257+00:00 2023-05-30T06:01:43.809407+00:00 0:00:00.941150 388183 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T06:01:40.818369+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T05:00:00+00:00 PythonOperator 2023-05-30T06:01:21.180488+00:00 2023-05-30T06:01:22.104539+00:00 0:00:00.924051 388181 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T06:01:18.802408+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T04:00:00+00:00 TriggerDagRunOperator 2023-05-30T05:11:42.607900+00:00 2023-05-30T05:11:43.148400+00:00 0:00:00.540500 388170 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T05:11:39.977999+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T04:00:00+00:00 TriggerDagRunOperator 2023-05-30T05:11:42.597788+00:00 2023-05-30T05:11:43.116435+00:00 0:00:00.518647 388169 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T05:11:39.977970+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T04:00:00+00:00 EmrJobFlowSensor 2023-05-30T05:01:15.468162+00:00 2023-05-30T05:11:17.229490+00:00 0:10:01.761328 388162 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T05:01:13.419782+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T05:00:55.463396+00:00 2023-05-30T05:00:56.324219+00:00 0:00:00.860823 388160 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T05:00:53.400099+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T04:00:00+00:00 PythonOperator 2023-05-30T05:00:33.846326+00:00 2023-05-30T05:00:34.799999+00:00 0:00:00.953673 388158 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T05:00:31.383204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T03:00:00+00:00 TriggerDagRunOperator 2023-05-30T04:11:03.857033+00:00 2023-05-30T04:11:04.322976+00:00 0:00:00.465943 388147 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T04:11:01.762992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T03:00:00+00:00 TriggerDagRunOperator 2023-05-30T04:11:03.791060+00:00 2023-05-30T04:11:04.244303+00:00 0:00:00.453243 388146 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T04:11:01.763027+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T03:00:00+00:00 EmrJobFlowSensor 2023-05-30T04:00:47.986858+00:00 2023-05-30T04:10:49.533681+00:00 0:10:01.546823 388139 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T04:00:45.876962+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T04:00:27.981960+00:00 2023-05-30T04:00:28.849844+00:00 0:00:00.867884 388137 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T04:00:25.857592+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T03:00:00+00:00 PythonOperator 2023-05-30T04:00:06.245084+00:00 2023-05-30T04:00:07.116492+00:00 0:00:00.871408 388135 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T04:00:03.835467+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T02:00:00+00:00 TriggerDagRunOperator 2023-05-30T03:13:50.643290+00:00 2023-05-30T03:13:51.456312+00:00 0:00:00.813022 388125 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T03:13:48.418092+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T02:00:00+00:00 TriggerDagRunOperator 2023-05-30T03:13:50.621882+00:00 2023-05-30T03:13:51.468363+00:00 0:00:00.846481 388124 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T03:13:48.418121+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T02:00:00+00:00 EmrJobFlowSensor 2023-05-30T03:03:24.662794+00:00 2023-05-30T03:13:26.378102+00:00 0:10:01.715308 388117 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T03:03:22.634529+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T03:03:04.696838+00:00 2023-05-30T03:03:05.611956+00:00 0:00:00.915118 388115 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T03:03:02.616164+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T02:00:00+00:00 PythonOperator 2023-05-30T03:02:43.094765+00:00 2023-05-30T03:02:44.249646+00:00 0:00:01.154881 388113 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T03:02:40.601218+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T01:00:00+00:00 TriggerDagRunOperator 2023-05-30T02:15:28.815738+00:00 2023-05-30T02:15:29.337903+00:00 0:00:00.522165 388103 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T02:15:26.309905+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T01:00:00+00:00 TriggerDagRunOperator 2023-05-30T02:15:28.655335+00:00 2023-05-30T02:15:29.187031+00:00 0:00:00.531696 388102 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T02:15:26.309878+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T01:00:00+00:00 EmrJobFlowSensor 2023-05-30T02:05:03.957083+00:00 2023-05-30T02:15:05.820747+00:00 0:10:01.863664 388095 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T02:05:01.882137+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T02:04:44.089824+00:00 2023-05-30T02:04:44.971862+00:00 0:00:00.882038 388093 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T02:04:41.969070+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T01:00:00+00:00 PythonOperator 2023-05-30T02:04:22.358653+00:00 2023-05-30T02:04:23.278521+00:00 0:00:00.919868 388091 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T02:04:19.850256+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-30T00:00:00+00:00 TriggerDagRunOperator 2023-05-30T01:11:31.857568+00:00 2023-05-30T01:11:32.290365+00:00 0:00:00.432797 388071 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T01:11:29.505810+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-30T00:00:00+00:00 TriggerDagRunOperator 2023-05-30T01:11:31.766782+00:00 2023-05-30T01:11:32.231156+00:00 0:00:00.464374 388070 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T01:11:29.505839+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-30T00:00:00+00:00 EmrJobFlowSensor 2023-05-30T01:01:24.928868+00:00 2023-05-30T01:11:26.709407+00:00 0:10:01.780539 388064 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T01:01:22.867203+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-30T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T01:01:04.957153+00:00 2023-05-30T01:01:05.839394+00:00 0:00:00.882241 388062 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T01:01:02.842640+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-30T00:00:00+00:00 PythonOperator 2023-05-30T01:00:43.262252+00:00 2023-05-30T01:00:44.210877+00:00 0:00:00.948625 388060 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T01:00:40.821296+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T23:00:00+00:00 TriggerDagRunOperator 2023-05-30T00:11:12.841852+00:00 2023-05-30T00:11:13.344107+00:00 0:00:00.502255 388048 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T00:11:10.498290+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T23:00:00+00:00 TriggerDagRunOperator 2023-05-30T00:11:12.742379+00:00 2023-05-30T00:11:13.281743+00:00 0:00:00.539364 388047 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-30T00:11:10.498262+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T23:00:00+00:00 EmrJobFlowSensor 2023-05-30T00:00:57.264660+00:00 2023-05-30T00:10:58.996609+00:00 0:10:01.731949 388041 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-30T00:00:55.144961+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-29T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-30T00:00:37.246581+00:00 2023-05-30T00:00:38.188306+00:00 0:00:00.941725 388039 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-30T00:00:35.124735+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-29T23:00:00+00:00 PythonOperator 2023-05-30T00:00:15.190287+00:00 2023-05-30T00:00:16.084856+00:00 0:00:00.894569 388037 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-30T00:00:13.104091+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-29T22:00:00+00:00 TriggerDagRunOperator 2023-05-29T23:11:05.424744+00:00 2023-05-29T23:11:06.143357+00:00 0:00:00.718613 388025 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T23:11:03.070556+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-29T22:00:00+00:00 TriggerDagRunOperator 2023-05-29T23:11:05.332869+00:00 2023-05-29T23:11:06.013246+00:00 0:00:00.680377 388024 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-29T23:11:03.070528+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-29T22:00:00+00:00 EmrJobFlowSensor 2023-05-29T23:00:51.654338+00:00 2023-05-29T23:10:53.376196+00:00 0:10:01.721858 388017 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-29T23:00:49.652982+00:00 2 default_pool