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 booking-processing-job_v002 check_cluster_status 2021-05-13T12:00:00+00:00 EmrJobFlowSensor 2021-05-13T13:11:58.937128+00:00 2021-05-13T13:22:01.811656+00:00 0:10:02.874528 27650 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T13:11:56.381819+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-13T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T13:11:56.938387+00:00 2021-05-13T13:11:58.703235+00:00 0:00:01.764848 27649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T13:11:54.356741+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-13T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T13:11:36.866176+00:00 2021-05-13T13:11:38.678774+00:00 0:00:01.812598 27648 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T13:11:34.241139+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-13T12:00:00+00:00 PythonOperator 2021-05-13T13:11:36.763909+00:00 2021-05-13T13:11:39.871001+00:00 0:00:03.107092 27647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T13:11:34.241183+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-13T12:00:00+00:00 PythonOperator 2021-05-13T13:11:16.438386+00:00 2021-05-13T13:11:19.883123+00:00 0:00:03.444737 27646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T13:11:14.106559+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T12:00:00+00:00 TriggerDagRunOperator 2021-05-13T13:11:10.430960+00:00 2021-05-13T13:11:10.949021+00:00 0:00:00.518061 27645 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T13:11:08.095117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T12:00:00+00:00 TriggerDagRunOperator 2021-05-13T13:11:10.283902+00:00 2021-05-13T13:11:10.697169+00:00 0:00:00.413267 27644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T13:11:08.095070+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-13T12:05:00+00:00 EmrJobFlowSensor 2021-05-13T13:05:59.846512+00:00 2021-05-13T13:16:02.697591+00:00 0:10:02.851079 27643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T13:05:57.519984+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-13T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-13T13:05:39.620408+00:00 2021-05-13T13:05:41.272913+00:00 0:00:01.652505 27642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T13:05:37.472548+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-13T12:05:00+00:00 PythonOperator 2021-05-13T13:05:17.691799+00:00 2021-05-13T13:05:20.846506+00:00 0:00:03.154707 27641 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T13:05:15.442405+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T12:00:00+00:00 EmrJobFlowSensor 2021-05-13T13:00:46.837731+00:00 2021-05-13T13:10:49.629297+00:00 0:10:02.791566 27640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T13:00:44.693430+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T13:00:24.907562+00:00 2021-05-13T13:00:26.662054+00:00 0:00:01.754492 27639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T13:00:22.669372+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T12:00:00+00:00 PythonOperator 2021-05-13T13:00:04.999805+00:00 2021-05-13T13:00:08.164037+00:00 0:00:03.164232 27638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T13:00:02.535928+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-13T11:00:00+00:00 EmrJobFlowSensor 2021-05-13T12:32:25.712676+00:00 2021-05-13T12:42:28.607603+00:00 0:10:02.894927 27637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T12:32:23.410328+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-13T11:00:00+00:00 EmrJobFlowSensor 2021-05-13T12:32:09.882103+00:00 2021-05-13T12:43:12.886124+00:00 0:11:03.004021 27636 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T12:32:07.491850+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-13T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T12:32:03.699148+00:00 2021-05-13T12:32:05.383123+00:00 0:00:01.683975 27635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T12:32:01.378521+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-13T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T12:31:47.722658+00:00 2021-05-13T12:31:49.552446+00:00 0:00:01.829788 27634 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T12:31:45.362378+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-13T11:00:00+00:00 PythonOperator 2021-05-13T12:31:41.697344+00:00 2021-05-13T12:31:44.831512+00:00 0:00:03.134168 27633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T12:31:39.370293+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-13T11:00:00+00:00 PythonOperator 2021-05-13T12:31:27.981435+00:00 2021-05-13T12:31:31.356847+00:00 0:00:03.375412 27632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T12:31:25.288031+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T11:00:00+00:00 TriggerDagRunOperator 2021-05-13T12:31:20.013065+00:00 2021-05-13T12:31:20.526476+00:00 0:00:00.513411 27631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T12:31:17.265994+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T11:00:00+00:00 TriggerDagRunOperator 2021-05-13T12:31:19.653185+00:00 2021-05-13T12:31:20.092082+00:00 0:00:00.438897 27630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T12:31:17.265952+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-13T11:05:00+00:00 EmrJobFlowSensor 2021-05-13T12:05:55.938516+00:00 2021-05-13T12:13:58.548328+00:00 0:08:02.609812 27628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T12:05:53.568286+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-13T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-13T12:05:35.709233+00:00 2021-05-13T12:05:37.328361+00:00 0:00:01.619128 27627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T12:05:33.494901+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-13T11:05:00+00:00 PythonOperator 2021-05-13T12:05:13.645870+00:00 2021-05-13T12:05:16.700720+00:00 0:00:03.054850 27626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T12:05:11.409728+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T11:00:00+00:00 EmrJobFlowSensor 2021-05-13T12:00:58.925665+00:00 2021-05-13T12:31:04.867688+00:00 0:30:05.942023 27625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T12:00:56.591800+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T12:00:36.937267+00:00 2021-05-13T12:00:38.634951+00:00 0:00:01.697684 27624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T12:00:34.556279+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T11:00:00+00:00 PythonOperator 2021-05-13T12:00:16.475982+00:00 2021-05-13T12:00:19.717420+00:00 0:00:03.241438 27623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T12:00:14.384710+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-13T10:00:00+00:00 EmrJobFlowSensor 2021-05-13T11:11:30.401617+00:00 2021-05-13T11:21:33.127081+00:00 0:10:02.725464 27622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T11:11:27.950678+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-13T10:00:00+00:00 EmrJobFlowSensor 2021-05-13T11:11:22.101747+00:00 2021-05-13T11:21:24.914835+00:00 0:10:02.813088 27621 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T11:11:19.867940+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-13T10:05:00+00:00 EmrJobFlowSensor 2021-05-13T11:11:16.029767+00:00 2021-05-13T11:19:18.551096+00:00 0:08:02.521329 27620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T11:11:13.796033+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-13T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T11:11:10.366497+00:00 2021-05-13T11:11:12.057946+00:00 0:00:01.691449 27619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T11:11:07.863961+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-13T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T11:11:00.416742+00:00 2021-05-13T11:11:02.315619+00:00 0:00:01.898877 27618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T11:10:57.846024+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-13T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-13T11:10:53.800045+00:00 2021-05-13T11:10:55.497610+00:00 0:00:01.697565 27617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T11:10:51.695902+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-13T10:00:00+00:00 PythonOperator 2021-05-13T11:10:48.037338+00:00 2021-05-13T11:10:51.136130+00:00 0:00:03.098792 27616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T11:10:45.701730+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-13T10:00:00+00:00 PythonOperator 2021-05-13T11:10:40.570886+00:00 2021-05-13T11:10:43.923660+00:00 0:00:03.352774 27615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T11:10:37.756339+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-13T10:05:00+00:00 PythonOperator 2021-05-13T11:10:32.254460+00:00 2021-05-13T11:10:35.444492+00:00 0:00:03.190032 27614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T11:10:29.639107+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T10:00:00+00:00 TriggerDagRunOperator 2021-05-13T11:10:24.411295+00:00 2021-05-13T11:10:24.931468+00:00 0:00:00.520173 27613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T11:10:21.643759+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T10:00:00+00:00 TriggerDagRunOperator 2021-05-13T11:10:24.110917+00:00 2021-05-13T11:10:24.522754+00:00 0:00:00.411837 27612 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T11:10:21.643788+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T10:00:00+00:00 EmrJobFlowSensor 2021-05-13T11:00:55.689146+00:00 2021-05-13T11:09:58.504220+00:00 0:09:02.815074 27610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T11:00:53.488383+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T11:00:33.909924+00:00 2021-05-13T11:00:35.774452+00:00 0:00:01.864528 27609 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T11:00:31.456979+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T10:00:00+00:00 PythonOperator 2021-05-13T11:00:11.623688+00:00 2021-05-13T11:00:14.745020+00:00 0:00:03.121332 27608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T11:00:09.390989+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-13T09:00:00+00:00 EmrJobFlowSensor 2021-05-13T10:11:36.996484+00:00 2021-05-13T10:23:40.133220+00:00 0:12:03.136736 27607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T10:11:34.813511+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-13T09:00:00+00:00 EmrJobFlowSensor 2021-05-13T10:11:31.121617+00:00 2021-05-13T10:20:33.773746+00:00 0:09:02.652129 27606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T10:11:28.816588+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-13T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T10:11:13.026420+00:00 2021-05-13T10:11:14.710028+00:00 0:00:01.683608 27605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T10:11:10.743990+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-13T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T10:11:09.169119+00:00 2021-05-13T10:11:10.901248+00:00 0:00:01.732129 27604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T10:11:06.745787+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-13T09:00:00+00:00 PythonOperator 2021-05-13T10:10:51.273204+00:00 2021-05-13T10:10:55.064960+00:00 0:00:03.791756 27603 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T10:10:48.628328+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-13T09:00:00+00:00 PythonOperator 2021-05-13T10:10:46.965576+00:00 2021-05-13T10:10:50.701187+00:00 0:00:03.735611 27602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T10:10:44.661311+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T09:00:00+00:00 TriggerDagRunOperator 2021-05-13T10:10:27.127193+00:00 2021-05-13T10:10:27.657267+00:00 0:00:00.530074 27601 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T10:10:24.671621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T09:00:00+00:00 TriggerDagRunOperator 2021-05-13T10:10:27.028249+00:00 2021-05-13T10:10:27.434561+00:00 0:00:00.406312 27600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T10:10:24.671590+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-13T09:05:00+00:00 EmrJobFlowSensor 2021-05-13T10:06:04.498692+00:00 2021-05-13T10:15:07.267183+00:00 0:09:02.768491 27599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T10:06:02.152631+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-13T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-13T10:05:44.295037+00:00 2021-05-13T10:05:45.919406+00:00 0:00:01.624369 27598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T10:05:42.022935+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-13T09:05:00+00:00 PythonOperator 2021-05-13T10:05:22.683142+00:00 2021-05-13T10:05:25.744155+00:00 0:00:03.061013 27597 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T10:05:20.000245+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T09:00:00+00:00 EmrJobFlowSensor 2021-05-13T10:01:00.787272+00:00 2021-05-13T10:10:03.491498+00:00 0:09:02.704226 27595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T10:00:58.368269+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T10:00:38.394201+00:00 2021-05-13T10:00:40.115101+00:00 0:00:01.720900 27594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T10:00:36.181505+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T09:00:00+00:00 PythonOperator 2021-05-13T10:00:18.270521+00:00 2021-05-13T10:00:21.445821+00:00 0:00:03.175300 27593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T10:00:16.142883+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-13T08:00:00+00:00 EmrJobFlowSensor 2021-05-13T09:13:10.574309+00:00 2021-05-13T09:23:13.434959+00:00 0:10:02.860650 27592 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T09:13:08.262328+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-13T08:00:00+00:00 EmrJobFlowSensor 2021-05-13T09:12:58.650943+00:00 2021-05-13T09:25:01.795184+00:00 0:12:03.144241 27591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T09:12:56.278402+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-13T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T09:12:48.929983+00:00 2021-05-13T09:12:50.704198+00:00 0:00:01.774215 27590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T09:12:46.356602+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-13T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T09:12:36.768216+00:00 2021-05-13T09:12:38.436786+00:00 0:00:01.668570 27589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T09:12:34.226815+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-13T08:00:00+00:00 PythonOperator 2021-05-13T09:12:28.445833+00:00 2021-05-13T09:12:31.596538+00:00 0:00:03.150705 27588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T09:12:26.211730+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-13T08:00:00+00:00 PythonOperator 2021-05-13T09:12:16.392729+00:00 2021-05-13T09:12:19.730135+00:00 0:00:03.337406 27587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T09:12:14.203392+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T08:00:00+00:00 TriggerDagRunOperator 2021-05-13T09:12:06.556352+00:00 2021-05-13T09:12:07.077687+00:00 0:00:00.521335 27586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T09:12:04.204775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T08:00:00+00:00 TriggerDagRunOperator 2021-05-13T09:12:06.413176+00:00 2021-05-13T09:12:06.818405+00:00 0:00:00.405229 27585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T09:12:04.204728+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-13T08:05:00+00:00 EmrJobFlowSensor 2021-05-13T09:05:47.539638+00:00 2021-05-13T09:13:50.107019+00:00 0:08:02.567381 27584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T09:05:45.244457+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-13T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-13T09:05:27.334440+00:00 2021-05-13T09:05:29.101926+00:00 0:00:01.767486 27583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T09:05:25.083239+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-13T08:05:00+00:00 PythonOperator 2021-05-13T09:05:05.261836+00:00 2021-05-13T09:05:08.366167+00:00 0:00:03.104331 27582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T09:05:03.063361+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T08:00:00+00:00 EmrJobFlowSensor 2021-05-13T09:02:44.933298+00:00 2021-05-13T09:11:47.762984+00:00 0:09:02.829686 27581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T09:02:42.532741+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T09:02:22.711359+00:00 2021-05-13T09:02:24.417328+00:00 0:00:01.705969 27580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T09:02:20.502869+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T08:00:00+00:00 PythonOperator 2021-05-13T09:02:02.874171+00:00 2021-05-13T09:02:05.964496+00:00 0:00:03.090325 27579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T09:02:00.470189+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-13T07:00:00+00:00 EmrJobFlowSensor 2021-05-13T08:11:12.973638+00:00 2021-05-13T08:21:15.931601+00:00 0:10:02.957963 27577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T08:11:10.738130+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-13T07:00:00+00:00 EmrJobFlowSensor 2021-05-13T08:10:59.129744+00:00 2021-05-13T08:21:01.920760+00:00 0:10:02.791016 27576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T08:10:56.786395+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-13T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T08:10:52.932238+00:00 2021-05-13T08:10:54.606619+00:00 0:00:01.674381 27575 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T08:10:50.719906+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-13T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T08:10:36.929513+00:00 2021-05-13T08:10:38.733453+00:00 0:00:01.803940 27574 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T08:10:34.706426+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-13T07:00:00+00:00 PythonOperator 2021-05-13T08:10:30.976630+00:00 2021-05-13T08:10:34.113954+00:00 0:00:03.137324 27573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T08:10:28.757280+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-13T07:00:00+00:00 PythonOperator 2021-05-13T08:10:15.726354+00:00 2021-05-13T08:10:19.116261+00:00 0:00:03.389907 27572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T08:10:12.754808+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T07:00:00+00:00 TriggerDagRunOperator 2021-05-13T08:10:07.342160+00:00 2021-05-13T08:10:07.868666+00:00 0:00:00.526506 27571 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T08:10:04.655477+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T07:00:00+00:00 TriggerDagRunOperator 2021-05-13T08:10:06.773606+00:00 2021-05-13T08:10:07.170987+00:00 0:00:00.397381 27570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T08:10:04.655432+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-13T07:05:00+00:00 EmrJobFlowSensor 2021-05-13T08:06:06.578419+00:00 2021-05-13T08:17:09.562931+00:00 0:11:02.984512 27569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T08:06:04.266794+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-13T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-13T08:05:44.386629+00:00 2021-05-13T08:05:46.159573+00:00 0:00:01.772944 27568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T08:05:42.175759+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-13T07:05:00+00:00 PythonOperator 2021-05-13T08:05:22.447693+00:00 2021-05-13T08:05:25.532755+00:00 0:00:03.085062 27567 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T08:05:20.158287+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T07:00:00+00:00 EmrJobFlowSensor 2021-05-13T08:00:55.732582+00:00 2021-05-13T08:09:58.720821+00:00 0:09:02.988239 27566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T08:00:53.352104+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T08:00:33.530081+00:00 2021-05-13T08:00:35.258163+00:00 0:00:01.728082 27565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T08:00:31.297334+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T07:00:00+00:00 PythonOperator 2021-05-13T08:00:14.107977+00:00 2021-05-13T08:00:17.493375+00:00 0:00:03.385398 27564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T08:00:11.174833+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-13T06:00:00+00:00 EmrJobFlowSensor 2021-05-13T07:11:27.112656+00:00 2021-05-13T07:21:29.840590+00:00 0:10:02.727934 27562 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T07:11:24.849953+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-13T06:00:00+00:00 EmrJobFlowSensor 2021-05-13T07:11:13.505884+00:00 2021-05-13T07:19:15.998604+00:00 0:08:02.492720 27561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T07:11:10.812138+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-13T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T07:11:05.348545+00:00 2021-05-13T07:11:07.068585+00:00 0:00:01.720040 27560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T07:11:02.863837+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-13T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T07:10:50.929354+00:00 2021-05-13T07:10:52.598604+00:00 0:00:01.669250 27559 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T07:10:48.785445+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-13T06:00:00+00:00 PythonOperator 2021-05-13T07:10:43.187427+00:00 2021-05-13T07:10:46.496803+00:00 0:00:03.309376 27558 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T07:10:40.784978+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-13T06:00:00+00:00 PythonOperator 2021-05-13T07:10:30.991488+00:00 2021-05-13T07:10:34.203614+00:00 0:00:03.212126 27557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T07:10:28.778772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T06:00:00+00:00 TriggerDagRunOperator 2021-05-13T07:10:19.527204+00:00 2021-05-13T07:10:20.015703+00:00 0:00:00.488499 27556 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T07:10:16.766616+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T06:00:00+00:00 TriggerDagRunOperator 2021-05-13T07:10:19.119311+00:00 2021-05-13T07:10:19.516477+00:00 0:00:00.397166 27555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T07:10:16.766566+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-13T06:05:00+00:00 EmrJobFlowSensor 2021-05-13T07:06:06.418904+00:00 2021-05-13T07:15:09.074332+00:00 0:09:02.655428 27554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T07:06:04.295643+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-13T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-13T07:05:46.471240+00:00 2021-05-13T07:05:48.225164+00:00 0:00:01.753924 27553 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T07:05:44.263540+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-13T06:05:00+00:00 PythonOperator 2021-05-13T07:05:24.596973+00:00 2021-05-13T07:05:27.626242+00:00 0:00:03.029269 27552 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T07:05:22.189893+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T06:00:00+00:00 EmrJobFlowSensor 2021-05-13T07:01:03.798443+00:00 2021-05-13T07:10:06.542230+00:00 0:09:02.743787 27551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T07:01:01.691349+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T07:00:41.711698+00:00 2021-05-13T07:00:43.518626+00:00 0:00:01.806928 27550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T07:00:39.540755+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T06:00:00+00:00 PythonOperator 2021-05-13T07:00:21.745561+00:00 2021-05-13T07:00:24.929044+00:00 0:00:03.183483 27549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T07:00:19.524650+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-13T05:00:00+00:00 EmrJobFlowSensor 2021-05-13T06:10:13.863585+00:00 2021-05-13T06:18:16.342698+00:00 0:08:02.479113 27547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T06:10:11.183667+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-13T05:00:00+00:00 EmrJobFlowSensor 2021-05-13T06:10:11.478074+00:00 2021-05-13T06:20:14.595598+00:00 0:10:03.117524 27546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T06:10:09.183680+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-13T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T06:09:51.655656+00:00 2021-05-13T06:09:53.436678+00:00 0:00:01.781022 27545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-13T06:09:49.075766+00:00 2 default_pool