Task Instances

  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-history-job_v002 check_cluster_status 2021-04-28T19:00:00+00:00 EmrJobFlowSensor 2021-04-28T20:11:19.720037+00:00 2021-04-28T20:20:22.301117+00:00 0:09:02.581080 22315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T20:11:17.276182+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T19:00:00+00:00 EmrJobFlowSensor 2021-04-28T20:11:11.799975+00:00 2021-04-28T20:23:14.941037+00:00 0:12:03.141062 22314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T20:11:09.270133+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T20:10:59.460008+00:00 2021-04-28T20:11:01.227788+00:00 0:00:01.767780 22313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T20:10:57.195248+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T20:10:51.365645+00:00 2021-04-28T20:10:53.084133+00:00 0:00:01.718488 22312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T20:10:49.184778+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T19:00:00+00:00 PythonOperator 2021-04-28T20:10:37.918027+00:00 2021-04-28T20:10:40.890259+00:00 0:00:02.972232 22311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T20:10:35.176341+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T19:00:00+00:00 PythonOperator 2021-04-28T20:10:29.770425+00:00 2021-04-28T20:10:33.106960+00:00 0:00:03.336535 22310 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T20:10:27.181609+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T19:00:00+00:00 TriggerDagRunOperator 2021-04-28T20:10:13.852493+00:00 2021-04-28T20:10:14.388051+00:00 0:00:00.535558 22309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T20:10:11.145131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T19:00:00+00:00 TriggerDagRunOperator 2021-04-28T20:10:13.734966+00:00 2021-04-28T20:10:14.359505+00:00 0:00:00.624539 22308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T20:10:11.145080+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T19:05:00+00:00 EmrJobFlowSensor 2021-04-28T20:05:52.889304+00:00 2021-04-28T20:14:55.483762+00:00 0:09:02.594458 22307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T20:05:50.396764+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T20:05:30.752703+00:00 2021-04-28T20:05:32.446996+00:00 0:00:01.694293 22306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T20:05:28.357115+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T19:05:00+00:00 PythonOperator 2021-04-28T20:05:10.356661+00:00 2021-04-28T20:05:13.308738+00:00 0:00:02.952077 22305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T20:05:08.189669+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T19:00:00+00:00 EmrJobFlowSensor 2021-04-28T20:01:03.719527+00:00 2021-04-28T20:10:06.434763+00:00 0:09:02.715236 22304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T20:01:01.555298+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T20:00:39.845480+00:00 2021-04-28T20:00:41.534400+00:00 0:00:01.688920 22303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T20:00:37.525527+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T19:00:00+00:00 PythonOperator 2021-04-28T20:00:20.086647+00:00 2021-04-28T20:00:23.068762+00:00 0:00:02.982115 22302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T20:00:17.520421+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T18:00:00+00:00 EmrJobFlowSensor 2021-04-28T19:11:19.308298+00:00 2021-04-28T19:20:21.931501+00:00 0:09:02.623203 22300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T19:11:16.969513+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T18:00:00+00:00 EmrJobFlowSensor 2021-04-28T19:11:09.147806+00:00 2021-04-28T19:21:11.992305+00:00 0:10:02.844499 22299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T19:11:06.890126+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T19:10:59.137037+00:00 2021-04-28T19:11:00.808636+00:00 0:00:01.671599 22298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T19:10:56.829943+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T19:10:46.998465+00:00 2021-04-28T19:10:48.904389+00:00 0:00:01.905924 22297 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T19:10:44.799350+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T18:00:00+00:00 PythonOperator 2021-04-28T19:10:37.239911+00:00 2021-04-28T19:10:40.271673+00:00 0:00:03.031762 22296 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T19:10:34.854045+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T18:00:00+00:00 PythonOperator 2021-04-28T19:10:25.210634+00:00 2021-04-28T19:10:28.538743+00:00 0:00:03.328109 22295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T19:10:22.762569+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T18:00:00+00:00 TriggerDagRunOperator 2021-04-28T19:10:12.953254+00:00 2021-04-28T19:10:13.427025+00:00 0:00:00.473771 22294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T19:10:10.629004+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T18:00:00+00:00 TriggerDagRunOperator 2021-04-28T19:10:12.933339+00:00 2021-04-28T19:10:13.512111+00:00 0:00:00.578772 22293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T19:10:10.629055+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T18:05:00+00:00 EmrJobFlowSensor 2021-04-28T19:05:56.375509+00:00 2021-04-28T19:14:58.985875+00:00 0:09:02.610366 22292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T19:05:54.071206+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T19:05:34.144624+00:00 2021-04-28T19:05:35.822107+00:00 0:00:01.677483 22291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T19:05:31.911137+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T18:05:00+00:00 PythonOperator 2021-04-28T19:05:12.135976+00:00 2021-04-28T19:05:15.145707+00:00 0:00:03.009731 22290 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T19:05:09.851303+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T18:00:00+00:00 EmrJobFlowSensor 2021-04-28T19:00:55.912248+00:00 2021-04-28T19:09:58.624140+00:00 0:09:02.711892 22289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T19:00:53.365245+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T19:00:33.766759+00:00 2021-04-28T19:00:35.545807+00:00 0:00:01.779048 22288 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T19:00:31.252614+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T18:00:00+00:00 PythonOperator 2021-04-28T19:00:11.866412+00:00 2021-04-28T19:00:14.864450+00:00 0:00:02.998038 22287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T19:00:09.261219+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T17:00:00+00:00 EmrJobFlowSensor 2021-04-28T18:12:26.023652+00:00 2021-04-28T18:21:28.781892+00:00 0:09:02.758240 22285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T18:12:23.718418+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T17:00:00+00:00 EmrJobFlowSensor 2021-04-28T18:12:09.997374+00:00 2021-04-28T18:24:13.088212+00:00 0:12:03.090838 22284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T18:12:07.680237+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T18:12:05.894421+00:00 2021-04-28T18:12:07.742756+00:00 0:00:01.848335 22283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T18:12:03.678392+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T18:11:47.836764+00:00 2021-04-28T18:11:49.676521+00:00 0:00:01.839757 22282 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T18:11:45.592324+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T17:00:00+00:00 PythonOperator 2021-04-28T18:11:44.130455+00:00 2021-04-28T18:11:47.150468+00:00 0:00:03.020013 22281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T18:11:41.586120+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T17:00:00+00:00 PythonOperator 2021-04-28T18:11:26.103632+00:00 2021-04-28T18:11:29.311508+00:00 0:00:03.207876 22280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T18:11:23.561146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T17:00:00+00:00 TriggerDagRunOperator 2021-04-28T18:11:20.027510+00:00 2021-04-28T18:11:20.533483+00:00 0:00:00.505973 22279 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T18:11:17.561760+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T17:00:00+00:00 TriggerDagRunOperator 2021-04-28T18:11:19.910102+00:00 2021-04-28T18:11:20.311734+00:00 0:00:00.401632 22278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T18:11:17.561705+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T17:05:00+00:00 EmrJobFlowSensor 2021-04-28T18:05:52.815036+00:00 2021-04-28T18:13:55.335283+00:00 0:08:02.520247 22277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T18:05:50.440070+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T18:05:32.679878+00:00 2021-04-28T18:05:34.420944+00:00 0:00:01.741066 22276 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T18:05:30.450671+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T17:05:00+00:00 PythonOperator 2021-04-28T18:05:10.577739+00:00 2021-04-28T18:05:13.536789+00:00 0:00:02.959050 22275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T18:05:08.344362+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T17:00:00+00:00 EmrJobFlowSensor 2021-04-28T18:00:56.329989+00:00 2021-04-28T18:10:59.126912+00:00 0:10:02.796923 22274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T18:00:53.986235+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T18:00:34.325278+00:00 2021-04-28T18:00:36.033355+00:00 0:00:01.708077 22273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T18:00:31.848281+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T17:00:00+00:00 PythonOperator 2021-04-28T18:00:12.044438+00:00 2021-04-28T18:00:15.064833+00:00 0:00:03.020395 22272 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T18:00:09.726443+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T16:00:00+00:00 EmrJobFlowSensor 2021-04-28T17:11:11.914049+00:00 2021-04-28T17:20:14.584997+00:00 0:09:02.670948 22270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T17:11:09.518279+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T16:00:00+00:00 EmrJobFlowSensor 2021-04-28T17:11:05.715112+00:00 2021-04-28T17:21:08.419344+00:00 0:10:02.704232 22269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T17:11:03.509990+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T17:10:50.463956+00:00 2021-04-28T17:10:52.313450+00:00 0:00:01.849494 22268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T17:10:47.567069+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T17:10:41.811044+00:00 2021-04-28T17:10:43.608130+00:00 0:00:01.797086 22267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T17:10:39.491219+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T16:00:00+00:00 PythonOperator 2021-04-28T17:10:29.962534+00:00 2021-04-28T17:10:32.977019+00:00 0:00:03.014485 22266 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T17:10:27.550839+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T16:00:00+00:00 PythonOperator 2021-04-28T17:10:21.638854+00:00 2021-04-28T17:10:24.951296+00:00 0:00:03.312442 22265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T17:10:19.445623+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T16:00:00+00:00 TriggerDagRunOperator 2021-04-28T17:10:09.805698+00:00 2021-04-28T17:10:10.250353+00:00 0:00:00.444655 22264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T17:10:07.447274+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T16:00:00+00:00 TriggerDagRunOperator 2021-04-28T17:10:09.785589+00:00 2021-04-28T17:10:10.326989+00:00 0:00:00.541400 22263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T17:10:07.447233+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T16:05:00+00:00 EmrJobFlowSensor 2021-04-28T17:06:01.568040+00:00 2021-04-28T17:15:04.246843+00:00 0:09:02.678803 22262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T17:05:58.985796+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T17:05:39.252758+00:00 2021-04-28T17:05:41.012351+00:00 0:00:01.759593 22261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T17:05:36.909538+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T16:05:00+00:00 PythonOperator 2021-04-28T17:05:17.081788+00:00 2021-04-28T17:05:19.998639+00:00 0:00:02.916851 22260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T17:05:14.891551+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T16:00:00+00:00 EmrJobFlowSensor 2021-04-28T17:00:48.442168+00:00 2021-04-28T17:09:51.112939+00:00 0:09:02.670771 22259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T17:00:46.144949+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T17:00:26.584575+00:00 2021-04-28T17:00:28.449088+00:00 0:00:01.864513 22258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T17:00:24.156305+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T16:00:00+00:00 PythonOperator 2021-04-28T17:00:04.543429+00:00 2021-04-28T17:00:07.785099+00:00 0:00:03.241670 22257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T17:00:02.086101+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T15:00:00+00:00 EmrJobFlowSensor 2021-04-28T16:11:17.998201+00:00 2021-04-28T16:21:20.905626+00:00 0:10:02.907425 22255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T16:11:15.547421+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T15:00:00+00:00 EmrJobFlowSensor 2021-04-28T16:11:07.800045+00:00 2021-04-28T16:19:10.324151+00:00 0:08:02.524106 22254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T16:11:05.457792+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T16:10:55.669034+00:00 2021-04-28T16:10:57.471292+00:00 0:00:01.802258 22253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T16:10:53.330335+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T16:10:47.592152+00:00 2021-04-28T16:10:49.309227+00:00 0:00:01.717075 22252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T16:10:45.322130+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T15:00:00+00:00 PythonOperator 2021-04-28T16:10:34.027713+00:00 2021-04-28T16:10:37.238332+00:00 0:00:03.210619 22251 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T16:10:31.364727+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T15:00:00+00:00 PythonOperator 2021-04-28T16:10:26.173644+00:00 2021-04-28T16:10:29.396419+00:00 0:00:03.222775 22250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T16:10:23.369426+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T15:00:00+00:00 TriggerDagRunOperator 2021-04-28T16:10:21.533555+00:00 2021-04-28T16:10:22.162313+00:00 0:00:00.628758 22249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T16:10:19.300038+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T15:00:00+00:00 TriggerDagRunOperator 2021-04-28T16:10:21.465935+00:00 2021-04-28T16:10:21.886828+00:00 0:00:00.420893 22248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T16:10:19.300000+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T15:05:00+00:00 EmrJobFlowSensor 2021-04-28T16:06:05.034044+00:00 2021-04-28T16:14:07.585312+00:00 0:08:02.551268 22247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T16:06:02.671419+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T16:05:41.100900+00:00 2021-04-28T16:05:42.816445+00:00 0:00:01.715545 22246 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T16:05:38.681540+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T15:05:00+00:00 PythonOperator 2021-04-28T16:05:20.923621+00:00 2021-04-28T16:05:23.995075+00:00 0:00:03.071454 22245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T16:05:18.574443+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T15:00:00+00:00 EmrJobFlowSensor 2021-04-28T16:01:14.448596+00:00 2021-04-28T16:10:17.154815+00:00 0:09:02.706219 22244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T16:01:12.088098+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T16:00:54.364021+00:00 2021-04-28T16:00:56.181361+00:00 0:00:01.817340 22243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T16:00:52.038230+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T15:00:00+00:00 PythonOperator 2021-04-28T16:00:32.961140+00:00 2021-04-28T16:00:35.977326+00:00 0:00:03.016186 22242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T16:00:30.072541+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T14:00:00+00:00 EmrJobFlowSensor 2021-04-28T15:12:18.856658+00:00 2021-04-28T15:22:21.629634+00:00 0:10:02.772976 22240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T15:12:16.506095+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T14:00:00+00:00 EmrJobFlowSensor 2021-04-28T15:12:04.968780+00:00 2021-04-28T15:20:07.484694+00:00 0:08:02.515914 22239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T15:12:02.506128+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T15:11:55.032929+00:00 2021-04-28T15:11:56.849490+00:00 0:00:01.816561 22238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T15:11:52.490559+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T15:11:43.067271+00:00 2021-04-28T15:11:44.754291+00:00 0:00:01.687020 22237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T15:11:40.443424+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T14:00:00+00:00 PythonOperator 2021-04-28T15:11:34.839389+00:00 2021-04-28T15:11:38.222712+00:00 0:00:03.383323 22236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T15:11:32.447911+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T14:00:00+00:00 PythonOperator 2021-04-28T15:11:20.625198+00:00 2021-04-28T15:11:23.659780+00:00 0:00:03.034582 22235 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T15:11:18.432832+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T14:00:00+00:00 TriggerDagRunOperator 2021-04-28T15:11:09.302354+00:00 2021-04-28T15:11:09.809302+00:00 0:00:00.506948 22234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T15:11:06.421635+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T14:00:00+00:00 TriggerDagRunOperator 2021-04-28T15:11:09.011849+00:00 2021-04-28T15:11:09.417938+00:00 0:00:00.406089 22233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T15:11:06.421680+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T14:05:00+00:00 EmrJobFlowSensor 2021-04-28T15:06:00.086090+00:00 2021-04-28T15:16:02.902601+00:00 0:10:02.816511 22232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T15:05:57.762226+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T15:05:38.047503+00:00 2021-04-28T15:05:39.719198+00:00 0:00:01.671695 22231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T15:05:35.780844+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T14:05:00+00:00 PythonOperator 2021-04-28T15:05:17.950141+00:00 2021-04-28T15:05:20.894941+00:00 0:00:02.944800 22230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T15:05:15.670284+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T14:00:00+00:00 EmrJobFlowSensor 2021-04-28T15:00:47.508653+00:00 2021-04-28T15:10:50.420342+00:00 0:10:02.911689 22229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T15:00:45.102258+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T15:00:25.396313+00:00 2021-04-28T15:00:27.184762+00:00 0:00:01.788449 22228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T15:00:23.011084+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T14:00:00+00:00 PythonOperator 2021-04-28T15:00:05.655287+00:00 2021-04-28T15:00:08.717304+00:00 0:00:03.062017 22227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T15:00:03.051653+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T13:00:00+00:00 EmrJobFlowSensor 2021-04-28T14:17:05.600341+00:00 2021-04-28T14:28:08.604360+00:00 0:11:03.004019 22226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T14:17:03.162246+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T13:00:00+00:00 EmrJobFlowSensor 2021-04-28T14:16:59.316800+00:00 2021-04-28T14:26:02.150617+00:00 0:09:02.833817 22225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T14:16:57.116457+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T14:16:43.435275+00:00 2021-04-28T14:16:45.162564+00:00 0:00:01.727289 22224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T14:16:41.088356+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T14:16:37.386363+00:00 2021-04-28T14:16:39.076561+00:00 0:00:01.690198 22223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T14:16:35.063182+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T13:00:00+00:00 PythonOperator 2021-04-28T14:16:21.795785+00:00 2021-04-28T14:16:25.035268+00:00 0:00:03.239483 22222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T14:16:19.060279+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T13:00:00+00:00 PythonOperator 2021-04-28T14:16:13.446169+00:00 2021-04-28T14:16:16.447057+00:00 0:00:03.000888 22221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T14:16:10.999853+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T13:00:00+00:00 TriggerDagRunOperator 2021-04-28T14:16:05.853321+00:00 2021-04-28T14:16:06.393771+00:00 0:00:00.540450 22220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T14:16:02.983153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T13:00:00+00:00 TriggerDagRunOperator 2021-04-28T14:16:05.788627+00:00 2021-04-28T14:16:06.191868+00:00 0:00:00.403241 22219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T14:16:02.983182+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T13:05:00+00:00 EmrJobFlowSensor 2021-04-28T14:05:52.773644+00:00 2021-04-28T14:14:55.347705+00:00 0:09:02.574061 22217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T14:05:50.515318+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T14:05:31.019328+00:00 2021-04-28T14:05:32.713644+00:00 0:00:01.694316 22216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T14:05:28.666117+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T13:05:00+00:00 PythonOperator 2021-04-28T14:05:10.686512+00:00 2021-04-28T14:05:13.631486+00:00 0:00:02.944974 22215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T14:05:08.410207+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T13:00:00+00:00 EmrJobFlowSensor 2021-04-28T14:00:48.354176+00:00 2021-04-28T14:11:51.360066+00:00 0:11:03.005890 22214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T14:00:45.859933+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T14:00:28.250411+00:00 2021-04-28T14:00:30.145168+00:00 0:00:01.894757 22213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T14:00:25.768733+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T13:00:00+00:00 PythonOperator 2021-04-28T14:00:05.986651+00:00 2021-04-28T14:00:09.037897+00:00 0:00:03.051246 22212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T14:00:03.666892+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T12:00:00+00:00 EmrJobFlowSensor 2021-04-28T13:12:44.191106+00:00 2021-04-28T13:22:47.086103+00:00 0:10:02.894997 22211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T13:12:41.669654+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T12:00:00+00:00 EmrJobFlowSensor 2021-04-28T13:12:44.054944+00:00 2021-04-28T13:20:46.652475+00:00 0:08:02.597531 22210 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T13:12:41.669627+00:00 2 default_pool