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 check_cluster_status 2023-02-17T05:00:00+00:00 EmrJobFlowSensor 2023-02-17T06:00:51.606632+00:00 2023-02-17T06:11:53.418978+00:00 0:11:01.812346 341266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T06:00:49.368922+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T05:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T06:00:31.966541+00:00 2023-02-17T06:00:32.882887+00:00 0:00:00.916346 341264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T06:00:29.354318+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T05:00:00+00:00 PythonOperator 2023-02-17T06:00:09.794775+00:00 2023-02-17T06:00:16.854614+00:00 0:00:07.059839 341262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T06:00:07.330456+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T04:00:00+00:00 TriggerDagRunOperator 2023-02-17T05:11:13.403429+00:00 2023-02-17T05:11:13.892978+00:00 0:00:00.489549 341249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T05:11:10.596612+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T04:00:00+00:00 TriggerDagRunOperator 2023-02-17T05:11:13.122612+00:00 2023-02-17T05:11:13.575594+00:00 0:00:00.452982 341248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T05:11:10.596642+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T04:00:00+00:00 EmrJobFlowSensor 2023-02-17T05:00:53.223392+00:00 2023-02-17T05:10:55.026041+00:00 0:10:01.802649 341240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T05:00:51.014519+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T04:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T05:00:33.527121+00:00 2023-02-17T05:00:34.349912+00:00 0:00:00.822791 341238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T05:00:31.002140+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T04:00:00+00:00 PythonOperator 2023-02-17T05:00:11.429240+00:00 2023-02-17T05:00:15.755511+00:00 0:00:04.326271 341236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T05:00:08.975892+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T03:00:00+00:00 TriggerDagRunOperator 2023-02-17T04:11:10.384758+00:00 2023-02-17T04:11:10.884570+00:00 0:00:00.499812 341223 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T04:11:07.722599+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T03:00:00+00:00 TriggerDagRunOperator 2023-02-17T04:11:10.133356+00:00 2023-02-17T04:11:10.693152+00:00 0:00:00.559796 341222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T04:11:07.722630+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T03:00:00+00:00 EmrJobFlowSensor 2023-02-17T04:00:54.282747+00:00 2023-02-17T04:10:56.153202+00:00 0:10:01.870455 341214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T04:00:51.973627+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T04:00:32.148783+00:00 2023-02-17T04:00:32.995452+00:00 0:00:00.846669 341212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T04:00:29.954429+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T03:00:00+00:00 PythonOperator 2023-02-17T04:00:12.425716+00:00 2023-02-17T04:00:15.598530+00:00 0:00:03.172814 341210 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T04:00:09.934925+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T02:00:00+00:00 TriggerDagRunOperator 2023-02-17T03:11:24.149644+00:00 2023-02-17T03:11:24.613862+00:00 0:00:00.464218 341197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T03:11:21.211743+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T02:00:00+00:00 TriggerDagRunOperator 2023-02-17T03:11:23.864575+00:00 2023-02-17T03:11:24.357889+00:00 0:00:00.493314 341196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T03:11:21.211789+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T02:00:00+00:00 EmrJobFlowSensor 2023-02-17T03:01:05.851237+00:00 2023-02-17T03:11:07.709118+00:00 0:10:01.857881 341189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T03:01:03.115123+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T02:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T03:00:43.323419+00:00 2023-02-17T03:00:44.480544+00:00 0:00:01.157125 341187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T03:00:41.017261+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T02:00:00+00:00 PythonOperator 2023-02-17T03:00:23.219503+00:00 2023-02-17T03:00:27.113235+00:00 0:00:03.893732 341185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T03:00:20.994650+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T01:00:00+00:00 TriggerDagRunOperator 2023-02-17T02:12:18.432718+00:00 2023-02-17T02:12:18.898337+00:00 0:00:00.465619 341172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T02:12:15.596638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T01:00:00+00:00 TriggerDagRunOperator 2023-02-17T02:12:18.169233+00:00 2023-02-17T02:12:18.619969+00:00 0:00:00.450736 341171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T02:12:15.596668+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T01:00:00+00:00 EmrJobFlowSensor 2023-02-17T02:01:05.827916+00:00 2023-02-17T02:11:07.771742+00:00 0:10:01.943826 341164 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T02:01:03.571511+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T02:00:45.854450+00:00 2023-02-17T02:00:46.730987+00:00 0:00:00.876537 341162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T02:00:43.556839+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T01:00:00+00:00 PythonOperator 2023-02-17T02:00:23.667488+00:00 2023-02-17T02:00:27.530030+00:00 0:00:03.862542 341160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T02:00:21.536265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-17T00:00:00+00:00 TriggerDagRunOperator 2023-02-17T01:11:58.173898+00:00 2023-02-17T01:11:58.652673+00:00 0:00:00.478775 341140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T01:11:55.798720+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-17T00:00:00+00:00 TriggerDagRunOperator 2023-02-17T01:11:58.186020+00:00 2023-02-17T01:11:58.719951+00:00 0:00:00.533931 341139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T01:11:55.798750+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-17T00:00:00+00:00 EmrJobFlowSensor 2023-02-17T01:01:07.260503+00:00 2023-02-17T01:11:09.048103+00:00 0:10:01.787600 341132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T01:01:04.821802+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-17T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T01:00:45.280904+00:00 2023-02-17T01:00:46.164544+00:00 0:00:00.883640 341130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T01:00:42.804822+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-17T00:00:00+00:00 PythonOperator 2023-02-17T01:00:25.090011+00:00 2023-02-17T01:00:31.489805+00:00 0:00:06.399794 341128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T01:00:22.704422+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T23:00:00+00:00 TriggerDagRunOperator 2023-02-17T00:14:06.833962+00:00 2023-02-17T00:14:07.422332+00:00 0:00:00.588370 341115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T00:14:03.787209+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T23:00:00+00:00 TriggerDagRunOperator 2023-02-17T00:14:06.763314+00:00 2023-02-17T00:14:07.319350+00:00 0:00:00.556036 341114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-17T00:14:03.787172+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T23:00:00+00:00 EmrJobFlowSensor 2023-02-17T00:01:29.838574+00:00 2023-02-17T00:11:31.616245+00:00 0:10:01.777671 341108 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-17T00:01:27.707908+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-17T00:01:09.916765+00:00 2023-02-17T00:01:10.867973+00:00 0:00:00.951208 341106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-17T00:01:07.686064+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T23:00:00+00:00 PythonOperator 2023-02-17T00:00:47.833793+00:00 2023-02-17T00:00:50.616449+00:00 0:00:02.782656 341104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-17T00:00:45.667984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T22:00:00+00:00 TriggerDagRunOperator 2023-02-16T23:11:02.593270+00:00 2023-02-16T23:11:03.155574+00:00 0:00:00.562304 341088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T23:10:59.939954+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T22:00:00+00:00 TriggerDagRunOperator 2023-02-16T23:11:02.320424+00:00 2023-02-16T23:11:02.803844+00:00 0:00:00.483420 341087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T23:10:59.939984+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T22:00:00+00:00 EmrJobFlowSensor 2023-02-16T23:00:51.585359+00:00 2023-02-16T23:10:53.476555+00:00 0:10:01.891196 341079 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T23:00:49.282306+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T23:00:29.432404+00:00 2023-02-16T23:00:30.349483+00:00 0:00:00.917079 341076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T23:00:27.267241+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T22:00:00+00:00 PythonOperator 2023-02-16T23:00:10.836387+00:00 2023-02-16T23:00:16.114498+00:00 0:00:05.278111 341073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T23:00:07.296981+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T21:00:00+00:00 TriggerDagRunOperator 2023-02-16T22:11:11.868058+00:00 2023-02-16T22:11:12.442411+00:00 0:00:00.574353 341058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T22:11:09.327248+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T21:00:00+00:00 TriggerDagRunOperator 2023-02-16T22:11:11.821318+00:00 2023-02-16T22:11:12.310358+00:00 0:00:00.489040 341057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T22:11:09.327276+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T21:00:00+00:00 EmrJobFlowSensor 2023-02-16T22:00:53.659496+00:00 2023-02-16T22:10:55.478154+00:00 0:10:01.818658 341050 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T22:00:51.250775+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T22:00:33.387045+00:00 2023-02-16T22:00:34.210862+00:00 0:00:00.823817 341048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T22:00:31.217458+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T21:00:00+00:00 PythonOperator 2023-02-16T22:00:12.080192+00:00 2023-02-16T22:00:18.501328+00:00 0:00:06.421136 341046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T22:00:09.248193+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T20:00:00+00:00 TriggerDagRunOperator 2023-02-16T21:10:58.685093+00:00 2023-02-16T21:10:59.225890+00:00 0:00:00.540797 341032 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T21:10:56.107118+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T20:00:00+00:00 TriggerDagRunOperator 2023-02-16T21:10:58.578179+00:00 2023-02-16T21:10:59.087532+00:00 0:00:00.509353 341031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T21:10:56.107090+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T20:00:00+00:00 EmrJobFlowSensor 2023-02-16T21:00:50.914336+00:00 2023-02-16T21:10:53.404028+00:00 0:10:02.489692 341024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T21:00:46.659189+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T21:00:26.861404+00:00 2023-02-16T21:00:27.758555+00:00 0:00:00.897151 341022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T21:00:24.637206+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T20:00:00+00:00 PythonOperator 2023-02-16T21:00:07.194311+00:00 2023-02-16T21:00:10.069070+00:00 0:00:02.874759 341020 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T21:00:04.616422+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T19:00:00+00:00 TriggerDagRunOperator 2023-02-16T20:11:24.582665+00:00 2023-02-16T20:11:25.146206+00:00 0:00:00.563541 341006 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T20:11:21.911392+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T19:00:00+00:00 TriggerDagRunOperator 2023-02-16T20:11:24.415352+00:00 2023-02-16T20:11:24.865771+00:00 0:00:00.450419 341005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T20:11:21.911364+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T19:00:00+00:00 EmrJobFlowSensor 2023-02-16T20:01:00.460278+00:00 2023-02-16T20:11:02.355570+00:00 0:10:01.895292 340999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T20:00:57.600598+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T20:00:39.845286+00:00 2023-02-16T20:00:40.750760+00:00 0:00:00.905474 340997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T20:00:37.507414+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T19:00:00+00:00 PythonOperator 2023-02-16T20:00:17.639612+00:00 2023-02-16T20:00:21.518522+00:00 0:00:03.878910 340995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T20:00:15.487661+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T18:00:00+00:00 TriggerDagRunOperator 2023-02-16T19:11:06.834067+00:00 2023-02-16T19:11:07.305633+00:00 0:00:00.471566 340979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T19:11:04.326619+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T18:00:00+00:00 TriggerDagRunOperator 2023-02-16T19:11:06.706548+00:00 2023-02-16T19:11:07.192803+00:00 0:00:00.486255 340978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T19:11:04.326592+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T18:00:00+00:00 EmrJobFlowSensor 2023-02-16T19:00:54.729232+00:00 2023-02-16T19:10:56.647163+00:00 0:10:01.917931 340972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T19:00:51.964996+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T19:00:32.301082+00:00 2023-02-16T19:00:33.213368+00:00 0:00:00.912286 340970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T19:00:29.941947+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T18:00:00+00:00 PythonOperator 2023-02-16T19:00:12.457317+00:00 2023-02-16T19:00:16.506795+00:00 0:00:04.049478 340968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T19:00:09.919654+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T17:00:00+00:00 TriggerDagRunOperator 2023-02-16T18:11:31.698082+00:00 2023-02-16T18:11:32.235112+00:00 0:00:00.537030 340953 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T18:11:29.136741+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T17:00:00+00:00 TriggerDagRunOperator 2023-02-16T18:11:31.640985+00:00 2023-02-16T18:11:32.125449+00:00 0:00:00.484464 340952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T18:11:29.136701+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T17:00:00+00:00 EmrJobFlowSensor 2023-02-16T18:01:12.999511+00:00 2023-02-16T18:11:14.740538+00:00 0:10:01.741027 340945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T18:01:10.635289+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T18:00:52.835364+00:00 2023-02-16T18:00:53.776524+00:00 0:00:00.941160 340943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T18:00:50.565954+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T17:00:00+00:00 PythonOperator 2023-02-16T18:00:31.192662+00:00 2023-02-16T18:00:34.083577+00:00 0:00:02.890915 340942 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T18:00:28.545496+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T16:00:00+00:00 TriggerDagRunOperator 2023-02-16T17:11:27.718585+00:00 2023-02-16T17:11:28.221707+00:00 0:00:00.503122 340927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T17:11:25.251787+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T16:00:00+00:00 TriggerDagRunOperator 2023-02-16T17:11:27.712542+00:00 2023-02-16T17:11:28.230237+00:00 0:00:00.517695 340926 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T17:11:25.251758+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T16:00:00+00:00 EmrJobFlowSensor 2023-02-16T17:01:22.043886+00:00 2023-02-16T17:11:23.840505+00:00 0:10:01.796619 340919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T17:01:19.752662+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T17:00:59.875724+00:00 2023-02-16T17:01:00.969729+00:00 0:00:01.094005 340917 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T17:00:57.731118+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T16:00:00+00:00 PythonOperator 2023-02-16T17:00:40.714580+00:00 2023-02-16T17:00:47.437351+00:00 0:00:06.722771 340915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T17:00:37.715128+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T15:00:00+00:00 TriggerDagRunOperator 2023-02-16T16:11:32.754602+00:00 2023-02-16T16:11:33.354625+00:00 0:00:00.600023 340901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T16:11:30.257770+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T15:00:00+00:00 TriggerDagRunOperator 2023-02-16T16:11:32.555705+00:00 2023-02-16T16:11:33.064720+00:00 0:00:00.509015 340900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T16:11:30.257804+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T15:00:00+00:00 EmrJobFlowSensor 2023-02-16T16:01:08.659596+00:00 2023-02-16T16:11:10.534267+00:00 0:10:01.874671 340894 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T16:01:06.310925+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T16:00:47.282175+00:00 2023-02-16T16:00:48.140598+00:00 0:00:00.858423 340892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T16:00:44.314995+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T15:00:00+00:00 PythonOperator 2023-02-16T16:00:24.503216+00:00 2023-02-16T16:00:28.769131+00:00 0:00:04.265915 340890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T16:00:22.272342+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T14:00:00+00:00 TriggerDagRunOperator 2023-02-16T15:20:00.854121+00:00 2023-02-16T15:20:01.391722+00:00 0:00:00.537601 340878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T15:19:57.713339+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T14:00:00+00:00 TriggerDagRunOperator 2023-02-16T15:20:00.752261+00:00 2023-02-16T15:20:01.235419+00:00 0:00:00.483158 340877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T15:19:57.713379+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T14:00:00+00:00 EmrJobFlowSensor 2023-02-16T15:01:05.241375+00:00 2023-02-16T15:11:07.011398+00:00 0:10:01.770023 340870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T15:01:03.038055+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T15:00:43.411128+00:00 2023-02-16T15:00:44.478390+00:00 0:00:01.067262 340868 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T15:00:40.998010+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T14:00:00+00:00 PythonOperator 2023-02-16T15:00:23.530341+00:00 2023-02-16T15:00:27.392088+00:00 0:00:03.861747 340866 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T15:00:20.981330+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T13:00:00+00:00 TriggerDagRunOperator 2023-02-16T14:20:04.609221+00:00 2023-02-16T14:20:05.174563+00:00 0:00:00.565342 340856 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T14:20:02.030825+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T13:00:00+00:00 TriggerDagRunOperator 2023-02-16T14:20:04.574824+00:00 2023-02-16T14:20:05.090998+00:00 0:00:00.516174 340855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T14:20:02.030854+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T13:00:00+00:00 EmrJobFlowSensor 2023-02-16T14:08:10.302335+00:00 2023-02-16T14:18:12.150153+00:00 0:10:01.847818 340850 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T14:08:07.979686+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T13:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T14:07:48.226894+00:00 2023-02-16T14:07:49.111076+00:00 0:00:00.884182 340847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T14:07:45.958676+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T13:00:00+00:00 PythonOperator 2023-02-16T14:07:28.736319+00:00 2023-02-16T14:07:35.158781+00:00 0:00:06.422462 340844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T14:07:25.989620+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T12:00:00+00:00 TriggerDagRunOperator 2023-02-16T13:12:10.706030+00:00 2023-02-16T13:12:11.343284+00:00 0:00:00.637254 340831 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T13:12:07.950218+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T12:00:00+00:00 TriggerDagRunOperator 2023-02-16T13:12:10.522013+00:00 2023-02-16T13:12:11.004452+00:00 0:00:00.482439 340830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T13:12:07.950246+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T12:00:00+00:00 EmrJobFlowSensor 2023-02-16T13:00:58.928180+00:00 2023-02-16T13:11:00.940794+00:00 0:10:02.012614 340823 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T13:00:56.398705+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T13:00:36.613340+00:00 2023-02-16T13:00:37.448578+00:00 0:00:00.835238 340821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T13:00:34.299848+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T12:00:00+00:00 PythonOperator 2023-02-16T13:00:14.636070+00:00 2023-02-16T13:00:17.651757+00:00 0:00:03.015687 340819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T13:00:12.231252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T11:00:00+00:00 TriggerDagRunOperator 2023-02-16T12:14:25.746739+00:00 2023-02-16T12:14:26.236388+00:00 0:00:00.489649 340807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T12:14:22.838389+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T11:00:00+00:00 TriggerDagRunOperator 2023-02-16T12:14:25.561226+00:00 2023-02-16T12:14:26.038043+00:00 0:00:00.476817 340806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T12:14:22.838352+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T11:00:00+00:00 EmrJobFlowSensor 2023-02-16T12:01:57.204809+00:00 2023-02-16T12:11:59.072730+00:00 0:10:01.867921 340797 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T12:01:54.879399+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T12:01:35.533432+00:00 2023-02-16T12:01:36.375526+00:00 0:00:00.842094 340796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T12:01:32.861947+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T11:00:00+00:00 PythonOperator 2023-02-16T12:00:23.545510+00:00 2023-02-16T12:00:27.610576+00:00 0:00:04.065066 340794 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T12:00:21.347943+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T10:00:00+00:00 TriggerDagRunOperator 2023-02-16T11:11:20.963050+00:00 2023-02-16T11:11:21.451959+00:00 0:00:00.488909 340781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T11:11:18.589270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T10:00:00+00:00 TriggerDagRunOperator 2023-02-16T11:11:20.845389+00:00 2023-02-16T11:11:21.325097+00:00 0:00:00.479708 340780 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T11:11:18.589301+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T10:00:00+00:00 EmrJobFlowSensor 2023-02-16T11:00:58.748354+00:00 2023-02-16T11:11:00.678150+00:00 0:10:01.929796 340774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T11:00:56.490312+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T11:00:36.789367+00:00 2023-02-16T11:00:37.628974+00:00 0:00:00.839607 340772 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T11:00:34.490332+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T10:00:00+00:00 PythonOperator 2023-02-16T11:00:16.771262+00:00 2023-02-16T11:00:19.821679+00:00 0:00:03.050417 340770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T11:00:14.453208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T09:00:00+00:00 TriggerDagRunOperator 2023-02-16T10:13:27.883311+00:00 2023-02-16T10:13:28.510006+00:00 0:00:00.626695 340757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T10:13:25.037102+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T09:00:00+00:00 TriggerDagRunOperator 2023-02-16T10:13:27.632049+00:00 2023-02-16T10:13:28.345230+00:00 0:00:00.713181 340756 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T10:13:25.037129+00:00 2 default_pool