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-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T23:00:26.287739+00:00 2021-04-28T23:00:27.996923+00:00 0:00:01.709184 22349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T23:00:24.103725+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-04-27T23:00:00+00:00 PythonOperator 2021-04-28T23:00:16.394811+00:00 2021-04-28T23:00:19.425611+00:00 0:00:03.030800 22348 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T23:00:14.111766+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T22:00:00+00:00 PythonOperator 2021-04-28T23:00:04.892905+00:00 2021-04-28T23:00:08.040029+00:00 0:00:03.147124 22347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T23:00:02.098555+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T21:00:00+00:00 EmrJobFlowSensor 2021-04-28T22:10:25.500318+00:00 2021-04-28T22:19:28.149276+00:00 0:09:02.648958 22345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T22:10:23.078213+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T21:00:00+00:00 EmrJobFlowSensor 2021-04-28T22:10:21.242681+00:00 2021-04-28T22:20:24.248406+00:00 0:10:03.005725 22344 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T22:10:19.075830+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T22:10:05.334525+00:00 2021-04-28T22:10:07.077058+00:00 0:00:01.742533 22343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T22:10:03.060629+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T22:10:01.289095+00:00 2021-04-28T22:10:03.117541+00:00 0:00:01.828446 22342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T22:09:59.081776+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T21:00:00+00:00 PythonOperator 2021-04-28T22:09:41.408225+00:00 2021-04-28T22:09:44.426480+00:00 0:00:03.018255 22341 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T22:09:39.053191+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T21:00:00+00:00 PythonOperator 2021-04-28T22:09:39.284429+00:00 2021-04-28T22:09:42.592423+00:00 0:00:03.307994 22340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T22:09:37.053031+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T21:00:00+00:00 TriggerDagRunOperator 2021-04-28T22:09:29.385294+00:00 2021-04-28T22:09:29.917702+00:00 0:00:00.532408 22339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T22:09:26.934028+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T21:00:00+00:00 TriggerDagRunOperator 2021-04-28T22:09:29.243868+00:00 2021-04-28T22:09:29.662989+00:00 0:00:00.419121 22338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T22:09:26.934060+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T21:05:00+00:00 EmrJobFlowSensor 2021-04-28T22:06:06.880965+00:00 2021-04-28T22:15:09.668994+00:00 0:09:02.788029 22337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T22:06:04.712756+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T22:05:42.808335+00:00 2021-04-28T22:05:44.443006+00:00 0:00:01.634671 22336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T22:05:40.540760+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T21:05:00+00:00 PythonOperator 2021-04-28T22:05:12.764134+00:00 2021-04-28T22:05:15.724390+00:00 0:00:02.960256 22335 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T22:05:10.516992+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T21:00:00+00:00 EmrJobFlowSensor 2021-04-28T22:01:00.501954+00:00 2021-04-28T22:09:03.077504+00:00 0:08:02.575550 22334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T22:00:58.247197+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T22:00:38.601141+00:00 2021-04-28T22:00:40.304258+00:00 0:00:01.703117 22333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T22:00:36.179481+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T21:00:00+00:00 PythonOperator 2021-04-28T22:00:16.552982+00:00 2021-04-28T22:00:19.583488+00:00 0:00:03.030506 22332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T22:00:14.094156+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T20:00:00+00:00 EmrJobFlowSensor 2021-04-28T21:11:20.219130+00:00 2021-04-28T21:20:22.708397+00:00 0:09:02.489267 22330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T21:11:17.651204+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T20:00:00+00:00 EmrJobFlowSensor 2021-04-28T21:11:18.025384+00:00 2021-04-28T21:21:21.021035+00:00 0:10:02.995651 22329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T21:11:15.665726+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T21:10:57.836124+00:00 2021-04-28T21:10:59.584803+00:00 0:00:01.748679 22328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T21:10:55.547579+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T21:10:57.850856+00:00 2021-04-28T21:10:59.750863+00:00 0:00:01.900007 22327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T21:10:55.547614+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T20:00:00+00:00 PythonOperator 2021-04-28T21:10:36.227412+00:00 2021-04-28T21:10:39.460841+00:00 0:00:03.233429 22326 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T21:10:33.552306+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T20:00:00+00:00 PythonOperator 2021-04-28T21:10:35.956873+00:00 2021-04-28T21:10:39.038915+00:00 0:00:03.082042 22325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T21:10:33.552274+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T20:00:00+00:00 TriggerDagRunOperator 2021-04-28T21:10:12.141862+00:00 2021-04-28T21:10:12.670736+00:00 0:00:00.528874 22324 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T21:10:09.560526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T20:00:00+00:00 TriggerDagRunOperator 2021-04-28T21:10:11.977595+00:00 2021-04-28T21:10:12.397134+00:00 0:00:00.419539 22323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T21:10:09.560490+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T20:05:00+00:00 EmrJobFlowSensor 2021-04-28T21:05:47.091525+00:00 2021-04-28T21:14:49.751211+00:00 0:09:02.659686 22322 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T21:05:44.901527+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T21:05:24.965277+00:00 2021-04-28T21:05:26.643269+00:00 0:00:01.677992 22321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T21:05:22.821088+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T20:05:00+00:00 PythonOperator 2021-04-28T21:05:03.464367+00:00 2021-04-28T21:05:06.529968+00:00 0:00:03.065601 22320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T21:05:00.867194+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T20:00:00+00:00 EmrJobFlowSensor 2021-04-28T21:00:56.212396+00:00 2021-04-28T21:09:59.033853+00:00 0:09:02.821457 22319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T21:00:54.002257+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T21:00:34.563808+00:00 2021-04-28T21:00:36.443930+00:00 0:00:01.880122 22318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T21:00:32.059335+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T20:00:00+00:00 PythonOperator 2021-04-28T21:00:12.425322+00:00 2021-04-28T21:00:15.407155+00:00 0:00:02.981833 22317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T21:00:10.046361+00:00 2 default_pool
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