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-10T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T19:00:47.760300+00:00 2023-05-10T19:00:48.599729+00:00 0:00:00.839429 376757 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T19:00:45.608487+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T18:00:00+00:00 PythonOperator 2023-05-10T19:00:28.140452+00:00 2023-05-10T19:00:29.238545+00:00 0:00:01.098093 376755 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T19:00:25.642083+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T17:00:00+00:00 TriggerDagRunOperator 2023-05-10T18:11:19.460456+00:00 2023-05-10T18:11:19.922208+00:00 0:00:00.461752 376737 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T18:11:17.125831+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T17:00:00+00:00 TriggerDagRunOperator 2023-05-10T18:11:19.377117+00:00 2023-05-10T18:11:19.719015+00:00 0:00:00.341898 376736 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T18:11:17.125859+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T17:00:00+00:00 EmrJobFlowSensor 2023-05-10T18:01:03.233577+00:00 2023-05-10T18:11:05.191328+00:00 0:10:01.957751 376729 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T18:01:01.003355+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T18:00:41.116187+00:00 2023-05-10T18:00:41.943023+00:00 0:00:00.826836 376728 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T18:00:38.949944+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T17:00:00+00:00 PythonOperator 2023-05-10T18:00:21.137844+00:00 2023-05-10T18:00:22.191323+00:00 0:00:01.053479 376727 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T18:00:18.927548+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T16:00:00+00:00 TriggerDagRunOperator 2023-05-10T17:11:07.970958+00:00 2023-05-10T17:11:08.413129+00:00 0:00:00.442171 376713 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T17:11:05.300828+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T16:00:00+00:00 TriggerDagRunOperator 2023-05-10T17:11:07.858544+00:00 2023-05-10T17:11:08.196666+00:00 0:00:00.338122 376712 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T17:11:05.300797+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T16:00:00+00:00 EmrJobFlowSensor 2023-05-10T17:00:55.550943+00:00 2023-05-10T17:10:57.465908+00:00 0:10:01.914965 376704 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T17:00:53.088947+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T17:00:33.105109+00:00 2023-05-10T17:00:33.945931+00:00 0:00:00.840822 376702 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T17:00:30.975363+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T16:00:00+00:00 PythonOperator 2023-05-10T17:00:13.216760+00:00 2023-05-10T17:00:14.257945+00:00 0:00:01.041185 376700 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T17:00:10.956652+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T15:00:00+00:00 TriggerDagRunOperator 2023-05-10T16:12:24.613330+00:00 2023-05-10T16:12:25.080638+00:00 0:00:00.467308 376688 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T16:12:21.731200+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T15:00:00+00:00 TriggerDagRunOperator 2023-05-10T16:12:24.580338+00:00 2023-05-10T16:12:24.944685+00:00 0:00:00.364347 376687 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T16:12:21.731168+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T15:00:00+00:00 EmrJobFlowSensor 2023-05-10T16:01:05.135991+00:00 2023-05-10T16:11:07.044502+00:00 0:10:01.908511 376680 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T16:01:02.846269+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T16:00:43.139669+00:00 2023-05-10T16:00:44.009605+00:00 0:00:00.869936 376678 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T16:00:40.829784+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T15:00:00+00:00 PythonOperator 2023-05-10T16:00:23.007063+00:00 2023-05-10T16:00:24.034070+00:00 0:00:01.027007 376676 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T16:00:20.810404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T14:00:00+00:00 TriggerDagRunOperator 2023-05-10T15:11:17.649839+00:00 2023-05-10T15:11:18.114879+00:00 0:00:00.465040 376663 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T15:11:15.309890+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T14:00:00+00:00 TriggerDagRunOperator 2023-05-10T15:11:17.347155+00:00 2023-05-10T15:11:17.809204+00:00 0:00:00.462049 376662 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T15:11:15.309863+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T14:00:00+00:00 EmrJobFlowSensor 2023-05-10T15:00:56.661121+00:00 2023-05-10T15:10:58.639892+00:00 0:10:01.978771 376656 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T15:00:54.266793+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T15:00:34.673150+00:00 2023-05-10T15:00:35.461332+00:00 0:00:00.788182 376653 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T15:00:32.254462+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T14:00:00+00:00 PythonOperator 2023-05-10T15:00:15.077633+00:00 2023-05-10T15:00:16.049891+00:00 0:00:00.972258 376651 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T15:00:12.016827+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T13:00:00+00:00 TriggerDagRunOperator 2023-05-10T14:13:10.646111+00:00 2023-05-10T14:13:11.131509+00:00 0:00:00.485398 376641 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T14:13:08.026683+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T13:00:00+00:00 TriggerDagRunOperator 2023-05-10T14:13:10.448491+00:00 2023-05-10T14:13:10.802517+00:00 0:00:00.354026 376640 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T14:13:08.026642+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T13:00:00+00:00 EmrJobFlowSensor 2023-05-10T14:03:04.202633+00:00 2023-05-10T14:13:06.226204+00:00 0:10:02.023571 376633 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T14:03:01.915498+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T14:02:42.013375+00:00 2023-05-10T14:02:42.871538+00:00 0:00:00.858163 376631 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T14:02:39.876766+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T13:00:00+00:00 PythonOperator 2023-05-10T14:02:22.657525+00:00 2023-05-10T14:02:23.706125+00:00 0:00:01.048600 376629 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T14:02:19.858271+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T12:00:00+00:00 TriggerDagRunOperator 2023-05-10T13:12:49.219728+00:00 2023-05-10T13:12:49.675429+00:00 0:00:00.455701 376618 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T13:12:46.282056+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T12:00:00+00:00 TriggerDagRunOperator 2023-05-10T13:12:49.065257+00:00 2023-05-10T13:12:49.400385+00:00 0:00:00.335128 376617 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T13:12:46.282086+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T12:00:00+00:00 EmrJobFlowSensor 2023-05-10T13:01:40.303381+00:00 2023-05-10T13:12:42.216908+00:00 0:11:01.913527 376610 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T13:01:38.093038+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T13:01:18.123515+00:00 2023-05-10T13:01:19.046288+00:00 0:00:00.922773 376608 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T13:01:16.010826+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T12:00:00+00:00 PythonOperator 2023-05-10T13:00:58.779728+00:00 2023-05-10T13:00:59.830568+00:00 0:00:01.050840 376606 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T13:00:55.992869+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T11:00:00+00:00 TriggerDagRunOperator 2023-05-10T12:23:18.686641+00:00 2023-05-10T12:23:19.127404+00:00 0:00:00.440763 376595 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T12:23:16.163997+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T11:00:00+00:00 TriggerDagRunOperator 2023-05-10T12:23:18.600189+00:00 2023-05-10T12:23:18.953626+00:00 0:00:00.353437 376594 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T12:23:16.163967+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T11:00:00+00:00 EmrJobFlowSensor 2023-05-10T12:13:01.779555+00:00 2023-05-10T12:23:03.620845+00:00 0:10:01.841290 376589 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T12:12:59.582388+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T12:12:41.905567+00:00 2023-05-10T12:12:42.874747+00:00 0:00:00.969180 376586 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T12:12:39.566148+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T11:00:00+00:00 PythonOperator 2023-05-10T12:12:20.870826+00:00 2023-05-10T12:12:22.877643+00:00 0:00:02.006817 376583 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T12:12:17.325214+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T10:00:00+00:00 TriggerDagRunOperator 2023-05-10T11:10:41.733813+00:00 2023-05-10T11:10:42.179638+00:00 0:00:00.445825 376570 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T11:10:38.601144+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T10:00:00+00:00 TriggerDagRunOperator 2023-05-10T11:10:41.610436+00:00 2023-05-10T11:10:41.950240+00:00 0:00:00.339804 376569 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T11:10:38.601190+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T10:00:00+00:00 EmrJobFlowSensor 2023-05-10T11:01:34.932428+00:00 2023-05-10T11:10:36.622525+00:00 0:09:01.690097 376563 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T11:01:32.780253+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T11:00:33.390969+00:00 2023-05-10T11:00:34.367002+00:00 0:00:00.976033 376559 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T11:00:31.097438+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T10:00:00+00:00 PythonOperator 2023-05-10T11:00:11.457184+00:00 2023-05-10T11:00:13.184038+00:00 0:00:01.726854 376557 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T11:00:09.018895+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T09:00:00+00:00 TriggerDagRunOperator 2023-05-10T10:11:15.932857+00:00 2023-05-10T10:11:16.387791+00:00 0:00:00.454934 376545 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T10:11:13.417364+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T09:00:00+00:00 TriggerDagRunOperator 2023-05-10T10:11:15.835692+00:00 2023-05-10T10:11:16.171623+00:00 0:00:00.335931 376544 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T10:11:13.417334+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T09:00:00+00:00 EmrJobFlowSensor 2023-05-10T10:00:59.520751+00:00 2023-05-10T10:11:01.576837+00:00 0:10:02.056086 376537 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T10:00:57.024797+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T10:00:39.367941+00:00 2023-05-10T10:00:40.357710+00:00 0:00:00.989769 376535 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T10:00:37.006900+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T09:00:00+00:00 PythonOperator 2023-05-10T10:00:16.424518+00:00 2023-05-10T10:00:17.397227+00:00 0:00:00.972709 376533 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T10:00:13.004283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T08:00:00+00:00 TriggerDagRunOperator 2023-05-10T09:11:16.696942+00:00 2023-05-10T09:11:17.154789+00:00 0:00:00.457847 376520 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T09:11:13.635345+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T08:00:00+00:00 TriggerDagRunOperator 2023-05-10T09:11:16.127995+00:00 2023-05-10T09:11:16.611812+00:00 0:00:00.483817 376519 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T09:11:13.635317+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T08:00:00+00:00 EmrJobFlowSensor 2023-05-10T09:01:01.500730+00:00 2023-05-10T09:11:03.726653+00:00 0:10:02.225923 376511 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T09:00:59.221087+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T09:00:41.828892+00:00 2023-05-10T09:00:42.925718+00:00 0:00:01.096826 376509 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T09:00:39.104360+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T08:00:00+00:00 PythonOperator 2023-05-10T09:00:04.592340+00:00 2023-05-10T09:00:05.548429+00:00 0:00:00.956089 376507 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T09:00:01.916602+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T07:00:00+00:00 TriggerDagRunOperator 2023-05-10T08:13:11.346288+00:00 2023-05-10T08:13:11.810983+00:00 0:00:00.464695 376495 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T08:13:08.728712+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T07:00:00+00:00 TriggerDagRunOperator 2023-05-10T08:13:11.230099+00:00 2023-05-10T08:13:11.569830+00:00 0:00:00.339731 376494 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T08:13:08.728667+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T07:00:00+00:00 EmrJobFlowSensor 2023-05-10T08:02:53.971661+00:00 2023-05-10T08:12:56.167169+00:00 0:10:02.195508 376487 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T08:02:51.725179+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T08:02:34.054463+00:00 2023-05-10T08:02:35.354554+00:00 0:00:01.300091 376485 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T08:02:31.668141+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T07:00:00+00:00 PythonOperator 2023-05-10T08:02:12.598058+00:00 2023-05-10T08:02:14.479065+00:00 0:00:01.881007 376483 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T08:02:09.652239+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T06:00:00+00:00 TriggerDagRunOperator 2023-05-10T07:11:40.846249+00:00 2023-05-10T07:11:41.290325+00:00 0:00:00.444076 376470 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T07:11:38.103292+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T06:00:00+00:00 TriggerDagRunOperator 2023-05-10T07:11:40.762824+00:00 2023-05-10T07:11:41.098039+00:00 0:00:00.335215 376469 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T07:11:38.103253+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T06:00:00+00:00 EmrJobFlowSensor 2023-05-10T07:01:06.134708+00:00 2023-05-10T07:11:07.999664+00:00 0:10:01.864956 376462 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T07:01:03.896107+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T07:00:44.375285+00:00 2023-05-10T07:00:45.215636+00:00 0:00:00.840351 376460 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T07:00:41.905872+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T06:00:00+00:00 PythonOperator 2023-05-10T07:00:24.242744+00:00 2023-05-10T07:00:25.294353+00:00 0:00:01.051609 376458 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T07:00:21.922379+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T05:00:00+00:00 TriggerDagRunOperator 2023-05-10T06:13:42.040212+00:00 2023-05-10T06:13:42.476475+00:00 0:00:00.436263 376447 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T06:13:39.248480+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T05:00:00+00:00 TriggerDagRunOperator 2023-05-10T06:13:41.819436+00:00 2023-05-10T06:13:42.262089+00:00 0:00:00.442653 376446 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T06:13:39.248452+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T05:00:00+00:00 EmrJobFlowSensor 2023-05-10T06:02:29.585186+00:00 2023-05-10T06:13:31.585399+00:00 0:11:02.000213 376440 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T06:02:27.406922+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T06:02:09.550681+00:00 2023-05-10T06:02:10.396061+00:00 0:00:00.845380 376438 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T06:02:07.343393+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T05:00:00+00:00 PythonOperator 2023-05-10T06:01:45.571391+00:00 2023-05-10T06:01:46.522738+00:00 0:00:00.951347 376436 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T06:01:43.309558+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T04:00:00+00:00 TriggerDagRunOperator 2023-05-10T05:11:45.279334+00:00 2023-05-10T05:11:45.737213+00:00 0:00:00.457879 376422 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T05:11:42.316242+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T04:00:00+00:00 TriggerDagRunOperator 2023-05-10T05:11:45.062791+00:00 2023-05-10T05:11:45.502429+00:00 0:00:00.439638 376421 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T05:11:42.316271+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T04:00:00+00:00 EmrJobFlowSensor 2023-05-10T05:00:48.395477+00:00 2023-05-10T05:10:50.251154+00:00 0:10:01.855677 376413 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T05:00:46.095415+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T05:00:26.847199+00:00 2023-05-10T05:00:27.647786+00:00 0:00:00.800587 376411 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T05:00:24.009233+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T04:00:00+00:00 PythonOperator 2023-05-10T05:00:06.542313+00:00 2023-05-10T05:00:07.465391+00:00 0:00:00.923078 376409 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T05:00:04.010511+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T03:00:00+00:00 TriggerDagRunOperator 2023-05-10T04:11:24.478333+00:00 2023-05-10T04:11:24.998802+00:00 0:00:00.520469 376396 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T04:11:21.993353+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T03:00:00+00:00 TriggerDagRunOperator 2023-05-10T04:11:24.441580+00:00 2023-05-10T04:11:24.886937+00:00 0:00:00.445357 376395 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T04:11:21.993305+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T03:00:00+00:00 EmrJobFlowSensor 2023-05-10T04:01:01.457147+00:00 2023-05-10T04:11:03.523595+00:00 0:10:02.066448 376388 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T04:00:59.128519+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T04:00:41.424446+00:00 2023-05-10T04:00:42.248011+00:00 0:00:00.823565 376386 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T04:00:39.185287+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T03:00:00+00:00 PythonOperator 2023-05-10T04:00:19.427551+00:00 2023-05-10T04:00:20.436243+00:00 0:00:01.008692 376384 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T04:00:17.072122+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T02:00:00+00:00 TriggerDagRunOperator 2023-05-10T03:11:22.927582+00:00 2023-05-10T03:11:23.397347+00:00 0:00:00.469765 376371 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T03:11:20.393411+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T02:00:00+00:00 TriggerDagRunOperator 2023-05-10T03:11:22.849121+00:00 2023-05-10T03:11:23.193961+00:00 0:00:00.344840 376370 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T03:11:20.393382+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T02:00:00+00:00 EmrJobFlowSensor 2023-05-10T03:00:57.352575+00:00 2023-05-10T03:10:59.273190+00:00 0:10:01.920615 376364 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T03:00:54.910294+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T03:00:37.006861+00:00 2023-05-10T03:00:37.971632+00:00 0:00:00.964771 376362 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T03:00:34.837937+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T02:00:00+00:00 PythonOperator 2023-05-10T03:00:15.151892+00:00 2023-05-10T03:00:16.096298+00:00 0:00:00.944406 376360 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T03:00:12.889116+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T01:00:00+00:00 TriggerDagRunOperator 2023-05-10T02:11:12.686018+00:00 2023-05-10T02:11:13.128896+00:00 0:00:00.442878 376347 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T02:11:10.012659+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T01:00:00+00:00 TriggerDagRunOperator 2023-05-10T02:11:12.651495+00:00 2023-05-10T02:11:12.991928+00:00 0:00:00.340433 376346 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T02:11:10.012700+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T01:00:00+00:00 EmrJobFlowSensor 2023-05-10T02:01:02.672604+00:00 2023-05-10T02:11:04.583756+00:00 0:10:01.911152 376338 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T02:01:00.292474+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T02:00:42.333014+00:00 2023-05-10T02:00:43.116595+00:00 0:00:00.783581 376336 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T02:00:40.109510+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T01:00:00+00:00 PythonOperator 2023-05-10T02:00:20.786369+00:00 2023-05-10T02:00:21.767623+00:00 0:00:00.981254 376334 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T02:00:18.107636+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T00:00:00+00:00 TriggerDagRunOperator 2023-05-10T01:11:13.737317+00:00 2023-05-10T01:11:14.177410+00:00 0:00:00.440093 376312 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T01:11:11.282661+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T00:00:00+00:00 TriggerDagRunOperator 2023-05-10T01:11:13.692142+00:00 2023-05-10T01:11:14.057270+00:00 0:00:00.365128 376311 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T01:11:11.282704+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T00:00:00+00:00 EmrJobFlowSensor 2023-05-10T01:00:59.063218+00:00 2023-05-10T01:11:01.138152+00:00 0:10:02.074934 376305 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T01:00:56.934707+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T01:00:39.150529+00:00 2023-05-10T01:00:39.994177+00:00 0:00:00.843648 376303 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T01:00:36.916655+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T00:00:00+00:00 PythonOperator 2023-05-10T01:00:17.028792+00:00 2023-05-10T01:00:18.022994+00:00 0:00:00.994202 376301 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T01:00:14.894578+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T23:00:00+00:00 TriggerDagRunOperator 2023-05-10T00:11:12.065977+00:00 2023-05-10T00:11:12.523773+00:00 0:00:00.457796 376285 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T00:11:09.516086+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T23:00:00+00:00 TriggerDagRunOperator 2023-05-10T00:11:11.934295+00:00 2023-05-10T00:11:12.273384+00:00 0:00:00.339089 376284 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T00:11:09.516125+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T23:00:00+00:00 EmrJobFlowSensor 2023-05-10T00:00:53.028361+00:00 2023-05-10T00:10:54.835850+00:00 0:10:01.807489 376278 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T00:00:50.923727+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-09T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T00:00:33.226980+00:00 2023-05-10T00:00:34.004216+00:00 0:00:00.777236 376276 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T00:00:30.988640+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-09T23:00:00+00:00 PythonOperator 2023-05-10T00:00:09.265562+00:00 2023-05-10T00:00:10.332667+00:00 0:00:01.067105 376274 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T00:00:06.821222+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-09T22:00:00+00:00 TriggerDagRunOperator 2023-05-09T23:11:13.720884+00:00 2023-05-09T23:11:14.165076+00:00 0:00:00.444192 376256 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T23:11:11.419820+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-09T22:00:00+00:00 TriggerDagRunOperator 2023-05-09T23:11:13.645682+00:00 2023-05-09T23:11:14.006174+00:00 0:00:00.360492 376255 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-09T23:11:11.419851+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-09T22:00:00+00:00 EmrJobFlowSensor 2023-05-09T23:01:06.260711+00:00 2023-05-09T23:11:08.126394+00:00 0:10:01.865683 376249 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-09T23:01:04.123157+00:00 2 default_pool