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-07T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T11:00:33.024987+00:00 2023-05-07T11:00:33.875352+00:00 0:00:00.850365 374691 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T11:00:30.756966+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T10:00:00+00:00 PythonOperator 2023-05-07T11:00:12.860193+00:00 2023-05-07T11:00:13.884889+00:00 0:00:01.024696 374689 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T11:00:10.624998+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T09:00:00+00:00 TriggerDagRunOperator 2023-05-07T10:10:59.146720+00:00 2023-05-07T10:10:59.784100+00:00 0:00:00.637380 374675 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T10:10:56.512200+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T09:00:00+00:00 TriggerDagRunOperator 2023-05-07T10:10:59.104136+00:00 2023-05-07T10:10:59.665455+00:00 0:00:00.561319 374674 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T10:10:56.512247+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T09:00:00+00:00 EmrJobFlowSensor 2023-05-07T10:00:49.440582+00:00 2023-05-07T10:10:51.394023+00:00 0:10:01.953441 374667 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T10:00:47.223695+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T10:00:29.545766+00:00 2023-05-07T10:00:30.666548+00:00 0:00:01.120782 374665 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T10:00:27.204753+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T09:00:00+00:00 PythonOperator 2023-05-07T10:00:07.585256+00:00 2023-05-07T10:00:08.647946+00:00 0:00:01.062690 374663 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T10:00:05.185816+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T08:00:00+00:00 TriggerDagRunOperator 2023-05-07T09:23:23.768139+00:00 2023-05-07T09:23:24.141161+00:00 0:00:00.373022 374653 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T09:23:21.234144+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T08:00:00+00:00 TriggerDagRunOperator 2023-05-07T09:23:23.739358+00:00 2023-05-07T09:23:24.238339+00:00 0:00:00.498981 374652 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T09:23:21.234173+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T08:00:00+00:00 EmrJobFlowSensor 2023-05-07T09:12:03.691691+00:00 2023-05-07T09:23:05.712746+00:00 0:11:02.021055 374648 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T09:12:01.452862+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T09:11:41.653995+00:00 2023-05-07T09:11:42.593016+00:00 0:00:00.939021 374645 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T09:11:39.432778+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T08:00:00+00:00 PythonOperator 2023-05-07T09:11:22.916676+00:00 2023-05-07T09:11:23.962343+00:00 0:00:01.045667 374642 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T09:11:19.418106+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T07:00:00+00:00 TriggerDagRunOperator 2023-05-07T08:22:59.214260+00:00 2023-05-07T08:22:59.663504+00:00 0:00:00.449244 374630 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T08:22:56.615066+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T07:00:00+00:00 TriggerDagRunOperator 2023-05-07T08:22:59.165598+00:00 2023-05-07T08:22:59.746302+00:00 0:00:00.580704 374629 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T08:22:56.615108+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T07:00:00+00:00 EmrJobFlowSensor 2023-05-07T08:12:41.124555+00:00 2023-05-07T08:22:42.934151+00:00 0:10:01.809596 374624 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T08:12:38.890704+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T08:12:21.160213+00:00 2023-05-07T08:12:21.982727+00:00 0:00:00.822514 374621 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T08:12:18.865323+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T07:00:00+00:00 PythonOperator 2023-05-07T08:11:59.808973+00:00 2023-05-07T08:12:00.935800+00:00 0:00:01.126827 374618 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T08:11:56.845195+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T06:00:00+00:00 TriggerDagRunOperator 2023-05-07T07:20:57.217667+00:00 2023-05-07T07:20:57.678577+00:00 0:00:00.460910 374608 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T07:20:54.413877+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T06:00:00+00:00 TriggerDagRunOperator 2023-05-07T07:20:57.170110+00:00 2023-05-07T07:20:57.545145+00:00 0:00:00.375035 374607 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T07:20:54.413908+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T06:00:00+00:00 EmrJobFlowSensor 2023-05-07T07:07:54.122641+00:00 2023-05-07T07:17:55.880146+00:00 0:10:01.757505 374603 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T07:07:51.799305+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T07:07:34.686835+00:00 2023-05-07T07:07:35.467915+00:00 0:00:00.781080 374600 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T07:07:31.758348+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T06:00:00+00:00 PythonOperator 2023-05-07T07:07:11.938485+00:00 2023-05-07T07:07:12.902923+00:00 0:00:00.964438 374597 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T07:07:09.742616+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T05:00:00+00:00 TriggerDagRunOperator 2023-05-07T06:20:15.745955+00:00 2023-05-07T06:20:16.198956+00:00 0:00:00.453001 374583 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T06:20:13.225608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T05:00:00+00:00 TriggerDagRunOperator 2023-05-07T06:20:15.676558+00:00 2023-05-07T06:20:16.008306+00:00 0:00:00.331748 374582 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T06:20:13.225579+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T05:00:00+00:00 EmrJobFlowSensor 2023-05-07T06:10:05.181728+00:00 2023-05-07T06:20:07.144549+00:00 0:10:01.962821 374577 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T06:10:02.810190+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T06:09:43.040158+00:00 2023-05-07T06:09:43.960323+00:00 0:00:00.920165 374574 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T06:09:40.755819+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T05:00:00+00:00 PythonOperator 2023-05-07T06:09:24.114132+00:00 2023-05-07T06:09:25.922287+00:00 0:00:01.808155 374572 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T06:09:20.681719+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T04:00:00+00:00 TriggerDagRunOperator 2023-05-07T05:11:40.493095+00:00 2023-05-07T05:11:40.999919+00:00 0:00:00.506824 374559 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T05:11:37.916925+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T04:00:00+00:00 TriggerDagRunOperator 2023-05-07T05:11:40.455118+00:00 2023-05-07T05:11:40.854583+00:00 0:00:00.399465 374558 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T05:11:37.916952+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T04:00:00+00:00 EmrJobFlowSensor 2023-05-07T05:01:26.383049+00:00 2023-05-07T05:11:28.280672+00:00 0:10:01.897623 374552 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T05:01:24.112004+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T05:01:06.364412+00:00 2023-05-07T05:01:07.245947+00:00 0:00:00.881535 374550 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T05:01:04.041652+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T04:00:00+00:00 PythonOperator 2023-05-07T05:00:44.488766+00:00 2023-05-07T05:00:45.576875+00:00 0:00:01.088109 374548 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T05:00:42.021157+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T03:00:00+00:00 TriggerDagRunOperator 2023-05-07T04:26:55.548205+00:00 2023-05-07T04:26:55.982877+00:00 0:00:00.434672 374535 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T04:26:52.696446+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T03:00:00+00:00 TriggerDagRunOperator 2023-05-07T04:26:55.441395+00:00 2023-05-07T04:26:55.803736+00:00 0:00:00.362341 374534 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T04:26:52.696402+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T03:00:00+00:00 EmrJobFlowSensor 2023-05-07T04:16:30.667134+00:00 2023-05-07T04:26:32.571422+00:00 0:10:01.904288 374529 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T04:16:28.278363+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T04:16:10.462444+00:00 2023-05-07T04:16:11.313980+00:00 0:00:00.851536 374526 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T04:16:08.259252+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T03:00:00+00:00 PythonOperator 2023-05-07T04:15:49.011263+00:00 2023-05-07T04:15:50.041160+00:00 0:00:01.029897 374523 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T04:15:46.239561+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T02:00:00+00:00 TriggerDagRunOperator 2023-05-07T03:19:09.371799+00:00 2023-05-07T03:19:09.729236+00:00 0:00:00.357437 374511 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T03:19:06.542041+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T02:00:00+00:00 TriggerDagRunOperator 2023-05-07T03:19:09.352639+00:00 2023-05-07T03:19:09.813002+00:00 0:00:00.460363 374510 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T03:19:06.542068+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T02:00:00+00:00 EmrJobFlowSensor 2023-05-07T03:08:41.340793+00:00 2023-05-07T03:18:43.179477+00:00 0:10:01.838684 374507 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T03:08:38.526476+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T03:08:18.644272+00:00 2023-05-07T03:08:19.493828+00:00 0:00:00.849556 374504 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T03:08:16.335920+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T02:00:00+00:00 PythonOperator 2023-05-07T03:08:00.162271+00:00 2023-05-07T03:08:01.208144+00:00 0:00:01.045873 374501 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T03:07:56.317831+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T01:00:00+00:00 TriggerDagRunOperator 2023-05-07T02:16:27.780455+00:00 2023-05-07T02:16:28.151258+00:00 0:00:00.370803 374488 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T02:16:24.877872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T01:00:00+00:00 TriggerDagRunOperator 2023-05-07T02:16:27.717211+00:00 2023-05-07T02:16:28.176370+00:00 0:00:00.459159 374487 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T02:16:24.877912+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T01:00:00+00:00 EmrJobFlowSensor 2023-05-07T02:03:59.039269+00:00 2023-05-07T02:15:01.277517+00:00 0:11:02.238248 374480 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T02:03:56.824580+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T02:03:39.096615+00:00 2023-05-07T02:03:40.031448+00:00 0:00:00.934833 374478 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T02:03:36.804276+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T01:00:00+00:00 PythonOperator 2023-05-07T02:03:17.657306+00:00 2023-05-07T02:03:18.662466+00:00 0:00:01.005160 374476 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T02:03:14.785940+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-07T00:00:00+00:00 TriggerDagRunOperator 2023-05-07T01:11:47.897814+00:00 2023-05-07T01:11:48.242880+00:00 0:00:00.345066 374450 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T01:11:44.833966+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-07T00:00:00+00:00 TriggerDagRunOperator 2023-05-07T01:11:47.843949+00:00 2023-05-07T01:11:48.299326+00:00 0:00:00.455377 374449 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T01:11:44.833921+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-07T00:00:00+00:00 EmrJobFlowSensor 2023-05-07T01:00:54.042666+00:00 2023-05-07T01:10:55.806874+00:00 0:10:01.764208 374447 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T01:00:51.755796+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-07T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T01:00:32.146666+00:00 2023-05-07T01:00:33.002039+00:00 0:00:00.855373 374446 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T01:00:29.794668+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-07T00:00:00+00:00 PythonOperator 2023-05-07T01:00:10.940653+00:00 2023-05-07T01:00:11.934735+00:00 0:00:00.994082 374445 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T01:00:07.710399+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T23:00:00+00:00 TriggerDagRunOperator 2023-05-07T00:11:01.549326+00:00 2023-05-07T00:11:02.006814+00:00 0:00:00.457488 374430 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T00:10:59.213029+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T23:00:00+00:00 TriggerDagRunOperator 2023-05-07T00:11:01.447123+00:00 2023-05-07T00:11:01.807556+00:00 0:00:00.360433 374429 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-07T00:10:59.212994+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T23:00:00+00:00 EmrJobFlowSensor 2023-05-07T00:00:50.090299+00:00 2023-05-07T00:10:52.058767+00:00 0:10:01.968468 374422 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-07T00:00:47.809826+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-07T00:00:28.057222+00:00 2023-05-07T00:00:28.999791+00:00 0:00:00.942569 374420 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-07T00:00:25.791342+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T23:00:00+00:00 PythonOperator 2023-05-07T00:00:06.806639+00:00 2023-05-07T00:00:07.779192+00:00 0:00:00.972553 374418 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-07T00:00:03.810099+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T22:00:00+00:00 TriggerDagRunOperator 2023-05-06T23:11:15.190774+00:00 2023-05-06T23:11:15.707447+00:00 0:00:00.516673 374401 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T23:11:12.816285+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T22:00:00+00:00 TriggerDagRunOperator 2023-05-06T23:11:15.052622+00:00 2023-05-06T23:11:15.439000+00:00 0:00:00.386378 374400 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T23:11:12.816254+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T22:00:00+00:00 EmrJobFlowSensor 2023-05-06T23:00:49.489853+00:00 2023-05-06T23:10:51.436182+00:00 0:10:01.946329 374393 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T23:00:47.195774+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T23:00:27.512578+00:00 2023-05-06T23:00:28.312706+00:00 0:00:00.800128 374390 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T23:00:25.176360+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T22:00:00+00:00 PythonOperator 2023-05-06T23:00:08.991568+00:00 2023-05-06T23:00:09.976733+00:00 0:00:00.985165 374387 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T23:00:05.162765+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T21:00:00+00:00 TriggerDagRunOperator 2023-05-06T22:11:02.954613+00:00 2023-05-06T22:11:03.400905+00:00 0:00:00.446292 374371 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T22:11:00.627384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T21:00:00+00:00 TriggerDagRunOperator 2023-05-06T22:11:02.899677+00:00 2023-05-06T22:11:03.254525+00:00 0:00:00.354848 374370 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T22:11:00.627411+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T21:00:00+00:00 EmrJobFlowSensor 2023-05-06T22:00:48.360876+00:00 2023-05-06T22:10:50.192893+00:00 0:10:01.832017 374363 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T22:00:46.104410+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T22:00:28.259166+00:00 2023-05-06T22:00:29.142697+00:00 0:00:00.883531 374361 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T22:00:26.068800+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T21:00:00+00:00 PythonOperator 2023-05-06T22:00:07.009385+00:00 2023-05-06T22:00:08.298921+00:00 0:00:01.289536 374359 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T22:00:04.049100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T20:00:00+00:00 TriggerDagRunOperator 2023-05-06T21:11:22.009586+00:00 2023-05-06T21:11:22.352566+00:00 0:00:00.342980 374345 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T21:11:19.515421+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T20:00:00+00:00 TriggerDagRunOperator 2023-05-06T21:11:22.004190+00:00 2023-05-06T21:11:22.590014+00:00 0:00:00.585824 374344 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T21:11:19.515460+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T20:00:00+00:00 EmrJobFlowSensor 2023-05-06T21:00:58.584735+00:00 2023-05-06T21:11:00.379358+00:00 0:10:01.794623 374337 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T21:00:56.202005+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T21:00:36.439584+00:00 2023-05-06T21:00:37.404709+00:00 0:00:00.965125 374335 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T21:00:34.127578+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T20:00:00+00:00 PythonOperator 2023-05-06T21:00:14.383020+00:00 2023-05-06T21:00:15.327734+00:00 0:00:00.944714 374333 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T21:00:12.063389+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T19:00:00+00:00 TriggerDagRunOperator 2023-05-06T20:11:11.445889+00:00 2023-05-06T20:11:11.900112+00:00 0:00:00.454223 374319 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T20:11:08.914220+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T19:00:00+00:00 TriggerDagRunOperator 2023-05-06T20:11:11.352953+00:00 2023-05-06T20:11:11.714396+00:00 0:00:00.361443 374318 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T20:11:08.914193+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T19:00:00+00:00 EmrJobFlowSensor 2023-05-06T20:01:05.058288+00:00 2023-05-06T20:11:07.015645+00:00 0:10:01.957357 374311 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T20:01:02.835903+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T20:00:43.053884+00:00 2023-05-06T20:00:43.888641+00:00 0:00:00.834757 374309 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T20:00:40.819773+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T19:00:00+00:00 PythonOperator 2023-05-06T20:00:22.981512+00:00 2023-05-06T20:00:23.948787+00:00 0:00:00.967275 374307 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T20:00:20.773102+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T18:00:00+00:00 TriggerDagRunOperator 2023-05-06T19:11:15.449941+00:00 2023-05-06T19:11:15.824555+00:00 0:00:00.374614 374288 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T19:11:12.988305+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T18:00:00+00:00 TriggerDagRunOperator 2023-05-06T19:11:15.463838+00:00 2023-05-06T19:11:15.932864+00:00 0:00:00.469026 374287 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T19:11:12.988354+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T18:00:00+00:00 EmrJobFlowSensor 2023-05-06T19:00:51.340617+00:00 2023-05-06T19:10:53.168926+00:00 0:10:01.828309 374280 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T19:00:48.913484+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T19:00:29.060412+00:00 2023-05-06T19:00:29.872684+00:00 0:00:00.812272 374279 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T19:00:26.891120+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T18:00:00+00:00 PythonOperator 2023-05-06T19:00:09.193548+00:00 2023-05-06T19:00:10.175111+00:00 0:00:00.981563 374278 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T19:00:06.876818+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T17:00:00+00:00 TriggerDagRunOperator 2023-05-06T18:10:56.334659+00:00 2023-05-06T18:10:56.854735+00:00 0:00:00.520076 374261 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T18:10:53.907668+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T17:00:00+00:00 TriggerDagRunOperator 2023-05-06T18:10:56.214424+00:00 2023-05-06T18:10:56.624136+00:00 0:00:00.409712 374260 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T18:10:53.907635+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T17:00:00+00:00 EmrJobFlowSensor 2023-05-06T18:00:47.642848+00:00 2023-05-06T18:10:49.403718+00:00 0:10:01.760870 374253 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T18:00:45.490188+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T18:00:25.609369+00:00 2023-05-06T18:00:26.354894+00:00 0:00:00.745525 374252 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T18:00:23.390214+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T17:00:00+00:00 PythonOperator 2023-05-06T18:00:05.850358+00:00 2023-05-06T18:00:06.763172+00:00 0:00:00.912814 374250 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T18:00:03.375791+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T16:00:00+00:00 TriggerDagRunOperator 2023-05-06T17:11:25.596809+00:00 2023-05-06T17:11:26.038934+00:00 0:00:00.442125 374236 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T17:11:23.082399+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T16:00:00+00:00 TriggerDagRunOperator 2023-05-06T17:11:25.411825+00:00 2023-05-06T17:11:25.771267+00:00 0:00:00.359442 374235 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T17:11:23.082340+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T16:00:00+00:00 EmrJobFlowSensor 2023-05-06T17:01:04.178856+00:00 2023-05-06T17:11:05.994897+00:00 0:10:01.816041 374226 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T17:01:01.424990+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T17:00:41.784969+00:00 2023-05-06T17:00:42.614297+00:00 0:00:00.829328 374225 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T17:00:39.410270+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T16:00:00+00:00 PythonOperator 2023-05-06T17:00:20.170574+00:00 2023-05-06T17:00:21.152809+00:00 0:00:00.982235 374223 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T17:00:17.185443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T15:00:00+00:00 TriggerDagRunOperator 2023-05-06T16:12:07.550224+00:00 2023-05-06T16:12:07.991490+00:00 0:00:00.441266 374211 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T16:12:04.888053+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T15:00:00+00:00 TriggerDagRunOperator 2023-05-06T16:12:07.386923+00:00 2023-05-06T16:12:07.728689+00:00 0:00:00.341766 374210 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T16:12:04.888095+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T15:00:00+00:00 EmrJobFlowSensor 2023-05-06T16:01:51.793775+00:00 2023-05-06T16:11:53.907482+00:00 0:10:02.113707 374204 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T16:01:49.345577+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T16:01:29.507153+00:00 2023-05-06T16:01:30.428562+00:00 0:00:00.921409 374201 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T16:01:27.305517+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T15:00:00+00:00 PythonOperator 2023-05-06T16:01:09.616387+00:00 2023-05-06T16:01:10.677368+00:00 0:00:01.060981 374200 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T16:01:07.287787+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T14:00:00+00:00 TriggerDagRunOperator 2023-05-06T15:12:26.571079+00:00 2023-05-06T15:12:27.030775+00:00 0:00:00.459696 374189 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T15:12:23.890093+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T14:00:00+00:00 TriggerDagRunOperator 2023-05-06T15:12:26.512678+00:00 2023-05-06T15:12:27.061747+00:00 0:00:00.549069 374188 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T15:12:23.890133+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T14:00:00+00:00 EmrJobFlowSensor 2023-05-06T15:02:00.254246+00:00 2023-05-06T15:12:02.208951+00:00 0:10:01.954705 374181 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T15:01:57.892789+00:00 2 default_pool