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 trigger_dagrun_booking-processing-job_v002 2023-04-01T07:00:00+00:00 TriggerDagRunOperator 2023-04-01T08:28:49.149253+00:00 2023-04-01T08:28:49.609777+00:00 0:00:00.460524 362363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T08:28:46.677138+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T07:00:00+00:00 EmrJobFlowSensor 2023-04-01T08:18:33.908112+00:00 2023-04-01T08:28:36.096488+00:00 0:10:02.188376 362359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T08:18:30.716789+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T07:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T08:18:10.925282+00:00 2023-04-01T08:18:11.951429+00:00 0:00:01.026147 362355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T08:18:08.695644+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T07:00:00+00:00 PythonOperator 2023-04-01T08:17:51.473096+00:00 2023-04-01T08:17:57.575409+00:00 0:00:06.102313 362353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T08:17:48.681483+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T06:00:00+00:00 TriggerDagRunOperator 2023-04-01T07:11:08.533188+00:00 2023-04-01T07:11:09.023511+00:00 0:00:00.490323 362344 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T07:11:06.217424+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T06:00:00+00:00 TriggerDagRunOperator 2023-04-01T07:11:08.380086+00:00 2023-04-01T07:11:08.831603+00:00 0:00:00.451517 362343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T07:11:06.217456+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T06:00:00+00:00 EmrJobFlowSensor 2023-04-01T07:01:00.464736+00:00 2023-04-01T07:11:02.402750+00:00 0:10:01.938014 362337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T07:00:57.820936+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T06:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T07:00:38.026211+00:00 2023-04-01T07:00:38.898224+00:00 0:00:00.872013 362335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T07:00:35.734257+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T06:00:00+00:00 PythonOperator 2023-04-01T07:00:15.939079+00:00 2023-04-01T07:00:19.291768+00:00 0:00:03.352689 362333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T07:00:13.654318+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T05:00:00+00:00 TriggerDagRunOperator 2023-04-01T06:15:43.523644+00:00 2023-04-01T06:15:43.973823+00:00 0:00:00.450179 362327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T06:15:41.139964+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T05:00:00+00:00 TriggerDagRunOperator 2023-04-01T06:15:43.307513+00:00 2023-04-01T06:15:43.770531+00:00 0:00:00.463018 362326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T06:15:41.140002+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T05:00:00+00:00 EmrJobFlowSensor 2023-04-01T06:00:47.446743+00:00 2023-04-01T06:10:49.289885+00:00 0:10:01.843142 362319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T06:00:45.137384+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T05:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T06:00:28.285601+00:00 2023-04-01T06:00:29.280316+00:00 0:00:00.994715 362317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T06:00:25.105428+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T05:00:00+00:00 PythonOperator 2023-04-01T06:00:05.796663+00:00 2023-04-01T06:00:09.485122+00:00 0:00:03.688459 362315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T06:00:03.063997+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T04:00:00+00:00 TriggerDagRunOperator 2023-04-01T05:12:43.348998+00:00 2023-04-01T05:12:43.857873+00:00 0:00:00.508875 362307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T05:12:40.442245+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T04:00:00+00:00 TriggerDagRunOperator 2023-04-01T05:12:43.131961+00:00 2023-04-01T05:12:43.598480+00:00 0:00:00.466519 362306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T05:12:40.442207+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T04:00:00+00:00 EmrJobFlowSensor 2023-04-01T05:00:47.350106+00:00 2023-04-01T05:10:49.119677+00:00 0:10:01.769571 362298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T05:00:45.148540+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T04:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T05:00:25.350898+00:00 2023-04-01T05:00:26.450988+00:00 0:00:01.100090 362296 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T05:00:23.081325+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T04:00:00+00:00 PythonOperator 2023-04-01T05:00:05.532358+00:00 2023-04-01T05:00:09.759812+00:00 0:00:04.227454 362294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T05:00:03.067301+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T03:00:00+00:00 TriggerDagRunOperator 2023-04-01T04:13:21.963753+00:00 2023-04-01T04:13:22.439758+00:00 0:00:00.476005 362285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T04:13:19.286541+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T03:00:00+00:00 TriggerDagRunOperator 2023-04-01T04:13:21.812642+00:00 2023-04-01T04:13:22.273980+00:00 0:00:00.461338 362284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T04:13:19.286513+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T03:00:00+00:00 EmrJobFlowSensor 2023-04-01T04:02:47.635048+00:00 2023-04-01T04:12:49.396694+00:00 0:10:01.761646 362278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T04:02:45.378858+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T03:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T04:02:27.547829+00:00 2023-04-01T04:02:28.490121+00:00 0:00:00.942292 362276 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T04:02:25.363723+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T03:00:00+00:00 PythonOperator 2023-04-01T04:02:05.525884+00:00 2023-04-01T04:02:09.255686+00:00 0:00:03.729802 362274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T04:02:03.340791+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T02:00:00+00:00 TriggerDagRunOperator 2023-04-01T03:19:36.154890+00:00 2023-04-01T03:19:36.606466+00:00 0:00:00.451576 362264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T03:19:33.062825+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T02:00:00+00:00 TriggerDagRunOperator 2023-04-01T03:19:35.247734+00:00 2023-04-01T03:19:35.678892+00:00 0:00:00.431158 362263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T03:19:33.062858+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T02:00:00+00:00 EmrJobFlowSensor 2023-04-01T03:00:58.530509+00:00 2023-04-01T03:11:00.296827+00:00 0:10:01.766318 362258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T03:00:56.149502+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T02:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T03:00:36.322113+00:00 2023-04-01T03:00:37.120913+00:00 0:00:00.798800 362255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T03:00:34.119639+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T02:00:00+00:00 PythonOperator 2023-04-01T03:00:15.327790+00:00 2023-04-01T03:00:20.933149+00:00 0:00:05.605359 362253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T03:00:12.048972+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T01:00:00+00:00 TriggerDagRunOperator 2023-04-01T02:11:22.442909+00:00 2023-04-01T02:11:22.927447+00:00 0:00:00.484538 362245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T02:11:19.963558+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T01:00:00+00:00 TriggerDagRunOperator 2023-04-01T02:11:22.303227+00:00 2023-04-01T02:11:22.754309+00:00 0:00:00.451082 362244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T02:11:19.963529+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T01:00:00+00:00 EmrJobFlowSensor 2023-04-01T02:00:58.574769+00:00 2023-04-01T02:11:00.548791+00:00 0:10:01.974022 362238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T02:00:56.329578+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T01:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T02:00:38.492757+00:00 2023-04-01T02:00:39.361512+00:00 0:00:00.868755 362236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T02:00:36.265826+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T01:00:00+00:00 PythonOperator 2023-04-01T02:00:16.493614+00:00 2023-04-01T02:00:20.968372+00:00 0:00:04.474758 362234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T02:00:14.241880+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-01T00:00:00+00:00 TriggerDagRunOperator 2023-04-01T01:12:54.733591+00:00 2023-04-01T01:12:55.554645+00:00 0:00:00.821054 362218 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T01:12:51.839740+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-01T00:00:00+00:00 TriggerDagRunOperator 2023-04-01T01:12:54.416503+00:00 2023-04-01T01:12:54.858572+00:00 0:00:00.442069 362217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T01:12:51.839712+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-01T00:00:00+00:00 EmrJobFlowSensor 2023-04-01T01:00:48.952385+00:00 2023-04-01T01:10:50.729395+00:00 0:10:01.777010 362212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T01:00:46.727193+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-01T00:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T01:00:26.961456+00:00 2023-04-01T01:00:27.870185+00:00 0:00:00.908729 362210 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T01:00:24.676386+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-01T00:00:00+00:00 PythonOperator 2023-04-01T01:00:07.235059+00:00 2023-04-01T01:00:10.832735+00:00 0:00:03.597676 362208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T01:00:04.646583+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T23:00:00+00:00 TriggerDagRunOperator 2023-04-01T00:16:33.328915+00:00 2023-04-01T00:16:34.125086+00:00 0:00:00.796171 362196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T00:16:29.819850+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T23:00:00+00:00 TriggerDagRunOperator 2023-04-01T00:16:32.572271+00:00 2023-04-01T00:16:33.030133+00:00 0:00:00.457862 362195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-01T00:16:29.819877+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T23:00:00+00:00 EmrJobFlowSensor 2023-04-01T00:01:05.707902+00:00 2023-04-01T00:11:07.570852+00:00 0:10:01.862950 362192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-01T00:01:03.461745+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-01T00:00:45.863510+00:00 2023-04-01T00:00:46.800703+00:00 0:00:00.937193 362190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-01T00:00:43.447856+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T23:00:00+00:00 PythonOperator 2023-04-01T00:00:23.566269+00:00 2023-04-01T00:00:27.598233+00:00 0:00:04.031964 362188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-01T00:00:21.428329+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T22:00:00+00:00 TriggerDagRunOperator 2023-03-31T23:10:59.773960+00:00 2023-03-31T23:11:00.359820+00:00 0:00:00.585860 362177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T23:10:57.448415+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T22:00:00+00:00 TriggerDagRunOperator 2023-03-31T23:10:59.601991+00:00 2023-03-31T23:11:00.187359+00:00 0:00:00.585368 362176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T23:10:57.448446+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T22:00:00+00:00 EmrJobFlowSensor 2023-03-31T23:00:53.264633+00:00 2023-03-31T23:10:55.271865+00:00 0:10:02.007232 362169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T23:00:50.850084+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T23:00:33.222531+00:00 2023-03-31T23:00:34.126540+00:00 0:00:00.904009 362166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T23:00:30.833529+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T22:00:00+00:00 PythonOperator 2023-03-31T23:00:11.241302+00:00 2023-03-31T23:00:16.635343+00:00 0:00:05.394041 362163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T23:00:08.795139+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T21:00:00+00:00 TriggerDagRunOperator 2023-03-31T22:12:49.236797+00:00 2023-03-31T22:12:49.726287+00:00 0:00:00.489490 362153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T22:12:46.732782+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T21:00:00+00:00 TriggerDagRunOperator 2023-03-31T22:12:49.227023+00:00 2023-03-31T22:12:49.684617+00:00 0:00:00.457594 362152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T22:12:46.732837+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T21:00:00+00:00 EmrJobFlowSensor 2023-03-31T22:01:33.847257+00:00 2023-03-31T22:12:35.875291+00:00 0:11:02.028034 362145 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T22:01:31.133277+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T22:01:14.010120+00:00 2023-03-31T22:01:14.985673+00:00 0:00:00.975553 362143 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T22:01:11.123143+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T21:00:00+00:00 PythonOperator 2023-03-31T22:00:18.975581+00:00 2023-03-31T22:00:22.150211+00:00 0:00:03.174630 362140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T22:00:16.541008+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T20:00:00+00:00 TriggerDagRunOperator 2023-03-31T21:11:57.028090+00:00 2023-03-31T21:11:57.538252+00:00 0:00:00.510162 362130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T21:11:54.326191+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T20:00:00+00:00 TriggerDagRunOperator 2023-03-31T21:11:56.974154+00:00 2023-03-31T21:11:57.430086+00:00 0:00:00.455932 362129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T21:11:54.326221+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T20:00:00+00:00 EmrJobFlowSensor 2023-03-31T21:01:43.035565+00:00 2023-03-31T21:11:44.763664+00:00 0:10:01.728099 362123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T21:01:40.852329+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T21:01:21.529227+00:00 2023-03-31T21:01:22.378085+00:00 0:00:00.848858 362121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T21:01:18.867367+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T20:00:00+00:00 PythonOperator 2023-03-31T21:00:21.520148+00:00 2023-03-31T21:00:24.896845+00:00 0:00:03.376697 362118 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T21:00:19.191157+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T19:00:00+00:00 TriggerDagRunOperator 2023-03-31T20:11:18.995541+00:00 2023-03-31T20:11:19.485151+00:00 0:00:00.489610 362108 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T20:11:16.627801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T19:00:00+00:00 TriggerDagRunOperator 2023-03-31T20:11:18.811432+00:00 2023-03-31T20:11:19.307485+00:00 0:00:00.496053 362107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T20:11:16.627830+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T19:00:00+00:00 EmrJobFlowSensor 2023-03-31T20:01:05.248195+00:00 2023-03-31T20:11:07.208656+00:00 0:10:01.960461 362101 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T20:01:02.627080+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T20:00:45.032287+00:00 2023-03-31T20:00:45.972896+00:00 0:00:00.940609 362099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T20:00:42.602442+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T19:00:00+00:00 PythonOperator 2023-03-31T20:00:22.729110+00:00 2023-03-31T20:00:29.021205+00:00 0:00:06.292095 362097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T20:00:20.582707+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T18:00:00+00:00 TriggerDagRunOperator 2023-03-31T19:12:06.993104+00:00 2023-03-31T19:12:07.528424+00:00 0:00:00.535320 362087 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T19:12:04.111351+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T18:00:00+00:00 TriggerDagRunOperator 2023-03-31T19:12:06.763679+00:00 2023-03-31T19:12:07.215155+00:00 0:00:00.451476 362086 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T19:12:04.111324+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T18:00:00+00:00 EmrJobFlowSensor 2023-03-31T19:01:39.837220+00:00 2023-03-31T19:11:41.640253+00:00 0:10:01.803033 362080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T19:01:37.530730+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T19:01:17.636235+00:00 2023-03-31T19:01:18.491169+00:00 0:00:00.854934 362077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T19:01:15.468262+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T18:00:00+00:00 PythonOperator 2023-03-31T19:00:56.221453+00:00 2023-03-31T19:01:00.208308+00:00 0:00:03.986855 362075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T19:00:53.450843+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T17:00:00+00:00 TriggerDagRunOperator 2023-03-31T18:16:36.096271+00:00 2023-03-31T18:16:36.596591+00:00 0:00:00.500320 362064 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T18:16:33.009254+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T17:00:00+00:00 TriggerDagRunOperator 2023-03-31T18:16:35.737489+00:00 2023-03-31T18:16:36.277674+00:00 0:00:00.540185 362063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T18:16:33.009295+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T17:00:00+00:00 EmrJobFlowSensor 2023-03-31T18:00:50.160929+00:00 2023-03-31T18:10:51.881945+00:00 0:10:01.721016 362055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T18:00:47.967508+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T18:00:30.314029+00:00 2023-03-31T18:00:31.293058+00:00 0:00:00.979029 362053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T18:00:27.946440+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T17:00:00+00:00 PythonOperator 2023-03-31T18:00:08.226507+00:00 2023-03-31T18:00:12.377855+00:00 0:00:04.151348 362051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T18:00:05.933358+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T16:00:00+00:00 TriggerDagRunOperator 2023-03-31T17:10:55.258369+00:00 2023-03-31T17:10:56.045914+00:00 0:00:00.787545 362041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T17:10:52.106918+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T16:00:00+00:00 TriggerDagRunOperator 2023-03-31T17:10:54.675864+00:00 2023-03-31T17:10:55.532606+00:00 0:00:00.856742 362040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T17:10:52.106984+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T16:00:00+00:00 EmrJobFlowSensor 2023-03-31T17:00:48.005350+00:00 2023-03-31T17:10:49.880204+00:00 0:10:01.874854 362032 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T17:00:45.701513+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T17:00:27.947294+00:00 2023-03-31T17:00:28.876796+00:00 0:00:00.929502 362030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T17:00:25.695855+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T16:00:00+00:00 PythonOperator 2023-03-31T17:00:06.290581+00:00 2023-03-31T17:00:10.332346+00:00 0:00:04.041765 362028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T17:00:03.669165+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T15:00:00+00:00 TriggerDagRunOperator 2023-03-31T16:21:03.288153+00:00 2023-03-31T16:21:03.799500+00:00 0:00:00.511347 362019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T16:21:00.592674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T15:00:00+00:00 TriggerDagRunOperator 2023-03-31T16:21:03.221786+00:00 2023-03-31T16:21:03.697197+00:00 0:00:00.475411 362018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T16:21:00.592630+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T15:00:00+00:00 EmrJobFlowSensor 2023-03-31T16:10:47.968484+00:00 2023-03-31T16:20:49.738172+00:00 0:10:01.769688 362013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T16:10:45.734762+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T16:10:28.113252+00:00 2023-03-31T16:10:28.931658+00:00 0:00:00.818406 362010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T16:10:25.721409+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T15:00:00+00:00 PythonOperator 2023-03-31T16:10:06.566629+00:00 2023-03-31T16:10:10.386728+00:00 0:00:03.820099 362007 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T16:10:03.698883+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T14:00:00+00:00 TriggerDagRunOperator 2023-03-31T15:21:29.880102+00:00 2023-03-31T15:21:30.417004+00:00 0:00:00.536902 362001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T15:21:26.952638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T14:00:00+00:00 TriggerDagRunOperator 2023-03-31T15:21:29.705301+00:00 2023-03-31T15:21:30.253607+00:00 0:00:00.548306 362000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T15:21:26.952601+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T14:00:00+00:00 EmrJobFlowSensor 2023-03-31T15:09:45.539422+00:00 2023-03-31T15:19:47.303013+00:00 0:10:01.763591 361997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T15:09:43.252437+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T15:09:23.566304+00:00 2023-03-31T15:09:24.388316+00:00 0:00:00.822012 361994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T15:09:21.235580+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T14:00:00+00:00 PythonOperator 2023-03-31T15:09:01.482739+00:00 2023-03-31T15:09:05.523196+00:00 0:00:04.040457 361991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T15:08:59.180621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T13:00:00+00:00 TriggerDagRunOperator 2023-03-31T14:11:16.566689+00:00 2023-03-31T14:11:17.074267+00:00 0:00:00.507578 361981 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T14:11:14.088012+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T13:00:00+00:00 TriggerDagRunOperator 2023-03-31T14:11:16.414144+00:00 2023-03-31T14:11:16.874042+00:00 0:00:00.459898 361980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T14:11:14.087954+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T13:00:00+00:00 EmrJobFlowSensor 2023-03-31T14:00:57.738958+00:00 2023-03-31T14:10:59.556427+00:00 0:10:01.817469 361974 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T14:00:54.716994+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T14:00:37.296140+00:00 2023-03-31T14:00:38.463249+00:00 0:00:01.167109 361972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T14:00:32.692683+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T13:00:00+00:00 PythonOperator 2023-03-31T14:00:12.919621+00:00 2023-03-31T14:00:16.271118+00:00 0:00:03.351497 361970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T14:00:10.582994+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T12:00:00+00:00 TriggerDagRunOperator 2023-03-31T13:31:38.207348+00:00 2023-03-31T13:31:38.739240+00:00 0:00:00.531892 361964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T13:31:35.755861+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T12:00:00+00:00 TriggerDagRunOperator 2023-03-31T13:31:38.214357+00:00 2023-03-31T13:31:38.669987+00:00 0:00:00.455630 361963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T13:31:35.755833+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T12:00:00+00:00 EmrJobFlowSensor 2023-03-31T13:21:16.160490+00:00 2023-03-31T13:31:18.048691+00:00 0:10:01.888201 361960 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T13:21:13.846691+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T13:20:56.209534+00:00 2023-03-31T13:20:57.031363+00:00 0:00:00.821829 361957 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T13:20:53.836339+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T12:00:00+00:00 PythonOperator 2023-03-31T13:20:33.923324+00:00 2023-03-31T13:20:38.022464+00:00 0:00:04.099140 361953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T13:20:31.748793+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T11:00:00+00:00 TriggerDagRunOperator 2023-03-31T12:19:29.235184+00:00 2023-03-31T12:19:29.762137+00:00 0:00:00.526953 361944 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T12:19:26.806500+00:00 2 default_pool