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-03-18T03:00:00+00:00 EmrJobFlowSensor 2023-03-18T04:01:02.574820+00:00 2023-03-18T04:11:04.399001+00:00 0:10:01.824181 355384 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T04:01:00.374190+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T04:00:42.684836+00:00 2023-03-18T04:00:43.672825+00:00 0:00:00.987989 355382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T04:00:40.355823+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T03:00:00+00:00 PythonOperator 2023-03-18T04:00:20.661209+00:00 2023-03-18T04:00:24.151423+00:00 0:00:03.490214 355380 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T04:00:18.334262+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T02:00:00+00:00 TriggerDagRunOperator 2023-03-18T03:20:34.867841+00:00 2023-03-18T03:20:35.350838+00:00 0:00:00.482997 355371 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T03:20:32.342813+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T02:00:00+00:00 TriggerDagRunOperator 2023-03-18T03:20:34.721538+00:00 2023-03-18T03:20:35.169512+00:00 0:00:00.447974 355370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T03:20:32.342780+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T02:00:00+00:00 EmrJobFlowSensor 2023-03-18T03:10:13.535616+00:00 2023-03-18T03:20:15.420523+00:00 0:10:01.884907 355367 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T03:10:11.056896+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T03:09:55.831071+00:00 2023-03-18T03:09:56.885724+00:00 0:00:01.054653 355364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T03:09:50.998008+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T02:00:00+00:00 PythonOperator 2023-03-18T03:09:34.132574+00:00 2023-03-18T03:09:37.170688+00:00 0:00:03.038114 355361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T03:09:28.974580+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T01:00:00+00:00 TriggerDagRunOperator 2023-03-18T02:12:10.884563+00:00 2023-03-18T02:12:11.438096+00:00 0:00:00.553533 355351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T02:12:08.297762+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T01:00:00+00:00 TriggerDagRunOperator 2023-03-18T02:12:10.846420+00:00 2023-03-18T02:12:11.432666+00:00 0:00:00.586246 355350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T02:12:08.297805+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T01:00:00+00:00 EmrJobFlowSensor 2023-03-18T02:01:56.058005+00:00 2023-03-18T02:11:57.935518+00:00 0:10:01.877513 355343 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T02:01:53.591203+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T02:01:33.985603+00:00 2023-03-18T02:01:34.876404+00:00 0:00:00.890801 355341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T02:01:31.571759+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T01:00:00+00:00 PythonOperator 2023-03-18T02:01:14.215631+00:00 2023-03-18T02:01:18.146562+00:00 0:00:03.930931 355339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T02:01:11.555995+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-18T00:00:00+00:00 TriggerDagRunOperator 2023-03-18T01:11:15.288022+00:00 2023-03-18T01:11:15.794341+00:00 0:00:00.506319 355324 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T01:11:12.764327+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-18T00:00:00+00:00 TriggerDagRunOperator 2023-03-18T01:11:15.268374+00:00 2023-03-18T01:11:15.744734+00:00 0:00:00.476360 355323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T01:11:12.764295+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-18T00:00:00+00:00 EmrJobFlowSensor 2023-03-18T01:00:48.410796+00:00 2023-03-18T01:10:50.394265+00:00 0:10:01.983469 355316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T01:00:46.222692+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-18T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T01:00:28.556216+00:00 2023-03-18T01:00:29.463351+00:00 0:00:00.907135 355314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T01:00:26.204103+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-18T00:00:00+00:00 PythonOperator 2023-03-18T01:00:08.088493+00:00 2023-03-18T01:00:11.764532+00:00 0:00:03.676039 355312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T01:00:04.182244+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T23:00:00+00:00 TriggerDagRunOperator 2023-03-18T00:11:05.026062+00:00 2023-03-18T00:11:05.631608+00:00 0:00:00.605546 355300 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T00:11:02.442761+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T23:00:00+00:00 TriggerDagRunOperator 2023-03-18T00:11:04.764662+00:00 2023-03-18T00:11:05.400673+00:00 0:00:00.636011 355299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-18T00:11:02.442732+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T23:00:00+00:00 EmrJobFlowSensor 2023-03-18T00:00:54.645044+00:00 2023-03-18T00:10:56.692467+00:00 0:10:02.047423 355291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-18T00:00:52.510420+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-18T00:00:34.644908+00:00 2023-03-18T00:00:35.430836+00:00 0:00:00.785928 355289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-18T00:00:32.490683+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T23:00:00+00:00 PythonOperator 2023-03-18T00:00:13.725941+00:00 2023-03-18T00:00:19.292115+00:00 0:00:05.566174 355287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-18T00:00:10.416865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T22:00:00+00:00 TriggerDagRunOperator 2023-03-17T23:11:16.105769+00:00 2023-03-17T23:11:16.570923+00:00 0:00:00.465154 355275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T23:11:13.527589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T22:00:00+00:00 TriggerDagRunOperator 2023-03-17T23:11:16.094573+00:00 2023-03-17T23:11:16.560584+00:00 0:00:00.466011 355274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T23:11:13.527619+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T22:00:00+00:00 EmrJobFlowSensor 2023-03-17T23:00:49.800700+00:00 2023-03-17T23:10:51.633114+00:00 0:10:01.832414 355265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T23:00:46.908811+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T23:00:29.291570+00:00 2023-03-17T23:00:30.619991+00:00 0:00:01.328421 355262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T23:00:24.825786+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T22:00:00+00:00 PythonOperator 2023-03-17T23:00:05.379386+00:00 2023-03-17T23:00:08.465655+00:00 0:00:03.086269 355259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T23:00:02.826063+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T21:00:00+00:00 TriggerDagRunOperator 2023-03-17T22:11:20.464384+00:00 2023-03-17T22:11:21.082631+00:00 0:00:00.618247 355248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T22:11:17.493775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T21:00:00+00:00 TriggerDagRunOperator 2023-03-17T22:11:20.452919+00:00 2023-03-17T22:11:21.009414+00:00 0:00:00.556495 355247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T22:11:17.493729+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T21:00:00+00:00 EmrJobFlowSensor 2023-03-17T22:00:53.964862+00:00 2023-03-17T22:10:55.874716+00:00 0:10:01.909854 355239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T22:00:51.529215+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T22:00:31.775190+00:00 2023-03-17T22:00:32.718328+00:00 0:00:00.943138 355237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T22:00:29.499793+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T21:00:00+00:00 PythonOperator 2023-03-17T22:00:09.865291+00:00 2023-03-17T22:00:13.079514+00:00 0:00:03.214223 355235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T22:00:07.480702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T20:00:00+00:00 TriggerDagRunOperator 2023-03-17T21:11:11.480969+00:00 2023-03-17T21:11:11.956183+00:00 0:00:00.475214 355225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T21:11:08.692966+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T20:00:00+00:00 TriggerDagRunOperator 2023-03-17T21:11:11.475221+00:00 2023-03-17T21:11:12.004467+00:00 0:00:00.529246 355224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T21:11:08.692996+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T20:00:00+00:00 EmrJobFlowSensor 2023-03-17T21:00:49.744970+00:00 2023-03-17T21:10:51.594326+00:00 0:10:01.849356 355217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T21:00:47.344490+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T21:00:27.655014+00:00 2023-03-17T21:00:28.467581+00:00 0:00:00.812567 355214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T21:00:25.306802+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T20:00:00+00:00 PythonOperator 2023-03-17T21:00:07.873268+00:00 2023-03-17T21:00:11.834390+00:00 0:00:03.961122 355213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T21:00:05.287020+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T19:00:00+00:00 TriggerDagRunOperator 2023-03-17T20:11:04.063412+00:00 2023-03-17T20:11:04.551244+00:00 0:00:00.487832 355202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T20:11:01.199655+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T19:00:00+00:00 TriggerDagRunOperator 2023-03-17T20:11:04.030863+00:00 2023-03-17T20:11:04.485181+00:00 0:00:00.454318 355201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T20:11:01.199612+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T19:00:00+00:00 EmrJobFlowSensor 2023-03-17T20:00:49.096470+00:00 2023-03-17T20:10:50.824339+00:00 0:10:01.727869 355193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T20:00:46.934558+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T20:00:29.192214+00:00 2023-03-17T20:00:30.099005+00:00 0:00:00.906791 355191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T20:00:26.777069+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T19:00:00+00:00 PythonOperator 2023-03-17T20:00:07.074464+00:00 2023-03-17T20:00:10.271551+00:00 0:00:03.197087 355189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T20:00:04.755456+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T18:00:00+00:00 TriggerDagRunOperator 2023-03-17T19:11:07.342986+00:00 2023-03-17T19:11:07.829838+00:00 0:00:00.486852 355179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T19:11:04.391181+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T18:00:00+00:00 TriggerDagRunOperator 2023-03-17T19:11:07.336078+00:00 2023-03-17T19:11:07.838011+00:00 0:00:00.501933 355178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T19:11:04.391225+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T18:00:00+00:00 EmrJobFlowSensor 2023-03-17T19:00:52.762649+00:00 2023-03-17T19:10:54.593846+00:00 0:10:01.831197 355168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T19:00:50.524300+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T19:00:32.861106+00:00 2023-03-17T19:00:33.735926+00:00 0:00:00.874820 355167 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T19:00:30.493105+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T18:00:00+00:00 PythonOperator 2023-03-17T19:00:10.769693+00:00 2023-03-17T19:00:14.753352+00:00 0:00:03.983659 355165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T19:00:08.459207+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T17:00:00+00:00 TriggerDagRunOperator 2023-03-17T18:11:18.647878+00:00 2023-03-17T18:11:19.131011+00:00 0:00:00.483133 355155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T18:11:15.906299+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T17:00:00+00:00 TriggerDagRunOperator 2023-03-17T18:11:18.579491+00:00 2023-03-17T18:11:19.061541+00:00 0:00:00.482050 355154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T18:11:15.906342+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T17:00:00+00:00 EmrJobFlowSensor 2023-03-17T18:00:59.104245+00:00 2023-03-17T18:11:00.920870+00:00 0:10:01.816625 355144 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T18:00:56.843674+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T18:00:37.092255+00:00 2023-03-17T18:00:37.977226+00:00 0:00:00.884971 355143 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T18:00:34.825974+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T17:00:00+00:00 PythonOperator 2023-03-17T18:00:17.635109+00:00 2023-03-17T18:00:20.741876+00:00 0:00:03.106767 355142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T18:00:14.743440+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T16:00:00+00:00 TriggerDagRunOperator 2023-03-17T17:11:15.454430+00:00 2023-03-17T17:11:16.001823+00:00 0:00:00.547393 355131 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T17:11:12.787711+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T16:00:00+00:00 TriggerDagRunOperator 2023-03-17T17:11:15.303482+00:00 2023-03-17T17:11:15.802438+00:00 0:00:00.498956 355130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T17:11:12.787764+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T16:00:00+00:00 EmrJobFlowSensor 2023-03-17T17:01:06.636892+00:00 2023-03-17T17:11:08.614212+00:00 0:10:01.977320 355124 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T17:01:04.404078+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T17:00:44.630921+00:00 2023-03-17T17:00:45.725717+00:00 0:00:01.094796 355122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T17:00:42.330742+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T16:00:00+00:00 PythonOperator 2023-03-17T17:00:24.438378+00:00 2023-03-17T17:00:27.600200+00:00 0:00:03.161822 355120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T17:00:22.262702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T15:00:00+00:00 TriggerDagRunOperator 2023-03-17T16:12:15.589570+00:00 2023-03-17T16:12:16.096263+00:00 0:00:00.506693 355110 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T16:12:13.138025+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T15:00:00+00:00 TriggerDagRunOperator 2023-03-17T16:12:15.321991+00:00 2023-03-17T16:12:15.783242+00:00 0:00:00.461251 355109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T16:12:13.137994+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T15:00:00+00:00 EmrJobFlowSensor 2023-03-17T16:01:07.643817+00:00 2023-03-17T16:12:09.519877+00:00 0:11:01.876060 355103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T16:01:05.375999+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T16:00:45.675649+00:00 2023-03-17T16:00:46.518699+00:00 0:00:00.843050 355101 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T16:00:43.352998+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T15:00:00+00:00 PythonOperator 2023-03-17T16:00:24.017035+00:00 2023-03-17T16:00:27.043626+00:00 0:00:03.026591 355099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T16:00:21.401528+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T14:00:00+00:00 TriggerDagRunOperator 2023-03-17T15:11:30.828715+00:00 2023-03-17T15:11:31.382033+00:00 0:00:00.553318 355090 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T15:11:28.299940+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T14:00:00+00:00 TriggerDagRunOperator 2023-03-17T15:11:30.768544+00:00 2023-03-17T15:11:31.315343+00:00 0:00:00.546799 355089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T15:11:28.299979+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T14:00:00+00:00 EmrJobFlowSensor 2023-03-17T15:01:07.902111+00:00 2023-03-17T15:11:09.771460+00:00 0:10:01.869349 355083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T15:01:05.362346+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T15:00:48.273358+00:00 2023-03-17T15:00:49.091729+00:00 0:00:00.818371 355081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T15:00:43.335479+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T14:00:00+00:00 PythonOperator 2023-03-17T15:00:23.842268+00:00 2023-03-17T15:00:28.334420+00:00 0:00:04.492152 355079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T15:00:21.263105+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T13:00:00+00:00 TriggerDagRunOperator 2023-03-17T14:13:52.717299+00:00 2023-03-17T14:13:53.176551+00:00 0:00:00.459252 355070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T14:13:49.933478+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T13:00:00+00:00 TriggerDagRunOperator 2023-03-17T14:13:52.620288+00:00 2023-03-17T14:13:53.119680+00:00 0:00:00.499392 355069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T14:13:49.933435+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T13:00:00+00:00 EmrJobFlowSensor 2023-03-17T14:01:19.955074+00:00 2023-03-17T14:11:21.725800+00:00 0:10:01.770726 355062 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T14:01:17.543863+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T14:00:57.910310+00:00 2023-03-17T14:00:58.932537+00:00 0:00:01.022227 355060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T14:00:55.515261+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T13:00:00+00:00 PythonOperator 2023-03-17T14:00:35.828891+00:00 2023-03-17T14:00:42.812319+00:00 0:00:06.983428 355058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T14:00:33.472797+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T12:00:00+00:00 TriggerDagRunOperator 2023-03-17T13:26:09.635508+00:00 2023-03-17T13:26:10.160840+00:00 0:00:00.525332 355051 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T13:26:06.166829+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T12:00:00+00:00 TriggerDagRunOperator 2023-03-17T13:26:09.202701+00:00 2023-03-17T13:26:09.824167+00:00 0:00:00.621466 355050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T13:26:06.166795+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T12:00:00+00:00 EmrJobFlowSensor 2023-03-17T13:13:27.884452+00:00 2023-03-17T13:23:29.793018+00:00 0:10:01.908566 355046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T13:13:24.924604+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T13:13:07.228858+00:00 2023-03-17T13:13:08.177961+00:00 0:00:00.949103 355043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T13:13:04.842064+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T12:00:00+00:00 PythonOperator 2023-03-17T13:12:47.654476+00:00 2023-03-17T13:12:56.752279+00:00 0:00:09.097803 355040 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T13:12:42.833856+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T11:00:00+00:00 TriggerDagRunOperator 2023-03-17T12:11:56.545206+00:00 2023-03-17T12:11:57.133071+00:00 0:00:00.587865 355030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T12:11:54.112561+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T11:00:00+00:00 TriggerDagRunOperator 2023-03-17T12:11:56.478562+00:00 2023-03-17T12:11:56.950668+00:00 0:00:00.472106 355029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T12:11:54.112590+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T11:00:00+00:00 EmrJobFlowSensor 2023-03-17T12:01:01.147921+00:00 2023-03-17T12:11:03.235910+00:00 0:10:02.087989 355021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T12:00:58.690086+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T12:00:38.879753+00:00 2023-03-17T12:00:39.792634+00:00 0:00:00.912881 355019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T12:00:36.650835+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T11:00:00+00:00 PythonOperator 2023-03-17T12:00:19.027545+00:00 2023-03-17T12:00:22.516973+00:00 0:00:03.489428 355017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T12:00:16.631772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T10:00:00+00:00 TriggerDagRunOperator 2023-03-17T11:11:59.880920+00:00 2023-03-17T11:12:00.411392+00:00 0:00:00.530472 355005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T11:11:57.391416+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T10:00:00+00:00 TriggerDagRunOperator 2023-03-17T11:11:59.696452+00:00 2023-03-17T11:12:00.387920+00:00 0:00:00.691468 355004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T11:11:57.391381+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T10:00:00+00:00 EmrJobFlowSensor 2023-03-17T11:00:55.314743+00:00 2023-03-17T11:10:57.321884+00:00 0:10:02.007141 355000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T11:00:52.317681+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T11:00:32.870389+00:00 2023-03-17T11:00:33.874312+00:00 0:00:01.003923 354998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T11:00:30.306694+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T10:00:00+00:00 PythonOperator 2023-03-17T11:00:12.728395+00:00 2023-03-17T11:00:17.450618+00:00 0:00:04.722223 354996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T11:00:10.303650+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T09:00:00+00:00 TriggerDagRunOperator 2023-03-17T10:11:30.828455+00:00 2023-03-17T10:11:31.418584+00:00 0:00:00.590129 354987 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T10:11:28.162311+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T09:00:00+00:00 TriggerDagRunOperator 2023-03-17T10:11:30.748374+00:00 2023-03-17T10:11:31.408860+00:00 0:00:00.660486 354986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T10:11:28.162282+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T09:00:00+00:00 EmrJobFlowSensor 2023-03-17T10:01:08.664759+00:00 2023-03-17T10:11:10.598209+00:00 0:10:01.933450 354980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T10:01:06.114681+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T10:00:48.546530+00:00 2023-03-17T10:00:49.903194+00:00 0:00:01.356664 354978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T10:00:44.029987+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T09:00:00+00:00 PythonOperator 2023-03-17T10:00:24.237660+00:00 2023-03-17T10:00:28.381388+00:00 0:00:04.143728 354976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T10:00:21.992914+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T08:00:00+00:00 TriggerDagRunOperator 2023-03-17T09:11:16.518255+00:00 2023-03-17T09:11:16.998374+00:00 0:00:00.480119 354966 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T09:11:13.999313+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T08:00:00+00:00 TriggerDagRunOperator 2023-03-17T09:11:16.379122+00:00 2023-03-17T09:11:16.998172+00:00 0:00:00.619050 354965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T09:11:13.999349+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-17T08:00:00+00:00 EmrJobFlowSensor 2023-03-17T09:00:57.497943+00:00 2023-03-17T09:10:59.453643+00:00 0:10:01.955700 354959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-17T09:00:54.852651+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-17T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-17T09:00:35.353497+00:00 2023-03-17T09:00:36.230850+00:00 0:00:00.877353 354957 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-17T09:00:32.906916+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-17T08:00:00+00:00 PythonOperator 2023-03-17T09:00:13.135916+00:00 2023-03-17T09:00:17.174328+00:00 0:00:04.038412 354955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-17T09:00:10.811667+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-17T07:00:00+00:00 TriggerDagRunOperator 2023-03-17T08:25:13.316945+00:00 2023-03-17T08:25:13.810228+00:00 0:00:00.493283 354947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T08:25:10.585914+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-17T07:00:00+00:00 TriggerDagRunOperator 2023-03-17T08:25:13.286850+00:00 2023-03-17T08:25:13.879760+00:00 0:00:00.592910 354946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-17T08:25:10.585942+00:00 2 default_pool