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 vc-asset-import_v002 check_cluster_status 2021-04-02T05:05:00+00:00 EmrJobFlowSensor 2021-04-02T06:05:54.604710+00:00 2021-04-02T06:14:57.046015+00:00 0:09:02.441305 12664 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T06:05:52.423011+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T06:05:32.733348+00:00 2021-04-02T06:05:34.413225+00:00 0:00:01.679877 12663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T06:05:30.476149+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T05:05:00+00:00 PythonOperator 2021-04-02T06:05:10.687358+00:00 2021-04-02T06:05:13.365559+00:00 0:00:02.678201 12662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T06:05:08.465264+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T05:00:00+00:00 EmrJobFlowSensor 2021-04-02T06:01:16.545925+00:00 2021-04-02T06:11:19.521918+00:00 0:10:02.975993 12661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T06:01:14.144125+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T06:00:56.461459+00:00 2021-04-02T06:00:58.209375+00:00 0:00:01.747916 12660 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T06:00:54.161486+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T05:00:00+00:00 PythonOperator 2021-04-02T06:00:34.687680+00:00 2021-04-02T06:00:37.541496+00:00 0:00:02.853816 12659 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T06:00:32.038430+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T04:00:00+00:00 EmrJobFlowSensor 2021-04-02T05:23:25.205653+00:00 2021-04-02T05:23:26.691770+00:00 0:00:01.486117 12657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T05:23:23.053296+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T04:00:00+00:00 EmrJobFlowSensor 2021-04-02T05:11:20.638962+00:00 2021-04-02T05:21:23.360142+00:00 0:10:02.721180 12655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T05:11:18.157377+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T05:11:04.380379+00:00 2021-04-02T05:11:06.085496+00:00 0:00:01.705117 12654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T05:11:02.073479+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T05:11:00.731116+00:00 2021-04-02T05:11:02.607526+00:00 0:00:01.876410 12653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T05:10:58.156899+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T04:00:00+00:00 PythonOperator 2021-04-02T05:10:42.817360+00:00 2021-04-02T05:10:45.619945+00:00 0:00:02.802585 12652 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T05:10:39.912157+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T04:00:00+00:00 PythonOperator 2021-04-02T05:10:38.393719+00:00 2021-04-02T05:10:42.144456+00:00 0:00:03.750737 12651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T05:10:35.906747+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T04:00:00+00:00 TriggerDagRunOperator 2021-04-02T05:10:30.359196+00:00 2021-04-02T05:10:30.941490+00:00 0:00:00.582294 12650 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T05:10:27.902710+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T04:00:00+00:00 TriggerDagRunOperator 2021-04-02T05:10:30.313626+00:00 2021-04-02T05:10:30.811057+00:00 0:00:00.497431 12649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T05:10:27.902664+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T04:05:00+00:00 EmrJobFlowSensor 2021-04-02T05:06:09.761681+00:00 2021-04-02T05:14:12.358286+00:00 0:08:02.596605 12648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T05:06:07.529822+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T05:05:41.878423+00:00 2021-04-02T05:05:43.625784+00:00 0:00:01.747361 12647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T05:05:39.576881+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T04:05:00+00:00 PythonOperator 2021-04-02T05:05:19.870951+00:00 2021-04-02T05:05:22.556730+00:00 0:00:02.685779 12646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T05:05:17.568862+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T04:00:00+00:00 EmrJobFlowSensor 2021-04-02T05:01:09.366093+00:00 2021-04-02T05:10:12.130354+00:00 0:09:02.764261 12645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T05:01:07.014658+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T05:00:47.299588+00:00 2021-04-02T05:00:49.118529+00:00 0:00:01.818941 12644 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T05:00:44.993955+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T04:00:00+00:00 PythonOperator 2021-04-02T05:00:25.461807+00:00 2021-04-02T05:00:28.311940+00:00 0:00:02.850133 12643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T05:00:22.965443+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T03:00:00+00:00 EmrJobFlowSensor 2021-04-02T04:10:33.582878+00:00 2021-04-02T04:19:36.164053+00:00 0:09:02.581175 12641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T04:10:31.337666+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T03:00:00+00:00 EmrJobFlowSensor 2021-04-02T04:10:29.532331+00:00 2021-04-02T04:19:32.247007+00:00 0:09:02.714676 12640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T04:10:27.329717+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T04:10:09.677159+00:00 2021-04-02T04:10:11.498978+00:00 0:00:01.821819 12639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T04:10:07.312222+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T04:10:03.550343+00:00 2021-04-02T04:10:05.304483+00:00 0:00:01.754140 12638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T04:10:01.306366+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T03:00:00+00:00 PythonOperator 2021-04-02T04:09:37.617458+00:00 2021-04-02T04:09:40.527694+00:00 0:00:02.910236 12637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T04:09:35.285889+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T03:00:00+00:00 PythonOperator 2021-04-02T04:09:33.824930+00:00 2021-04-02T04:09:36.678127+00:00 0:00:02.853197 12636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T04:09:31.355038+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T03:00:00+00:00 TriggerDagRunOperator 2021-04-02T04:09:19.634662+00:00 2021-04-02T04:09:20.148137+00:00 0:00:00.513475 12635 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T04:09:17.210271+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T03:00:00+00:00 TriggerDagRunOperator 2021-04-02T04:09:19.497511+00:00 2021-04-02T04:09:19.915399+00:00 0:00:00.417888 12634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T04:09:17.210241+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T03:05:00+00:00 EmrJobFlowSensor 2021-04-02T04:05:46.971112+00:00 2021-04-02T04:14:49.560837+00:00 0:09:02.589725 12633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T04:05:44.829406+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T04:05:25.178590+00:00 2021-04-02T04:05:26.944937+00:00 0:00:01.766347 12632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T04:05:22.808237+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T03:05:00+00:00 PythonOperator 2021-04-02T04:05:03.012852+00:00 2021-04-02T04:05:05.690613+00:00 0:00:02.677761 12631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T04:05:00.790911+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T03:00:00+00:00 EmrJobFlowSensor 2021-04-02T04:00:58.744833+00:00 2021-04-02T04:09:01.442813+00:00 0:08:02.697980 12630 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T04:00:56.301082+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T04:00:36.645631+00:00 2021-04-02T04:00:38.393665+00:00 0:00:01.748034 12629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T04:00:34.286469+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T03:00:00+00:00 PythonOperator 2021-04-02T04:00:16.751777+00:00 2021-04-02T04:00:19.511629+00:00 0:00:02.759852 12628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T04:00:14.266881+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T02:00:00+00:00 EmrJobFlowSensor 2021-04-02T03:11:21.241415+00:00 2021-04-02T03:32:25.473126+00:00 0:21:04.231711 12626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T03:11:18.995511+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T02:00:00+00:00 EmrJobFlowSensor 2021-04-02T03:11:21.272480+00:00 2021-04-02T03:21:24.263300+00:00 0:10:02.990820 12625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T03:11:18.995558+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T03:11:01.688537+00:00 2021-04-02T03:11:03.426626+00:00 0:00:01.738089 12624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T03:10:58.971869+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T03:10:59.390522+00:00 2021-04-02T03:11:01.384952+00:00 0:00:01.994430 12623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T03:10:56.976163+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T02:00:00+00:00 PythonOperator 2021-04-02T03:10:39.337781+00:00 2021-04-02T03:10:42.186378+00:00 0:00:02.848597 12622 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T03:10:36.911047+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T02:00:00+00:00 PythonOperator 2021-04-02T03:10:39.225387+00:00 2021-04-02T03:10:42.171755+00:00 0:00:02.946368 12621 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T03:10:36.911081+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T02:00:00+00:00 TriggerDagRunOperator 2021-04-02T03:10:19.314084+00:00 2021-04-02T03:10:19.867365+00:00 0:00:00.553281 12620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T03:10:16.893629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T02:00:00+00:00 TriggerDagRunOperator 2021-04-02T03:10:19.250443+00:00 2021-04-02T03:10:19.674288+00:00 0:00:00.423845 12619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T03:10:16.893594+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T02:05:00+00:00 EmrJobFlowSensor 2021-04-02T03:05:56.570792+00:00 2021-04-02T03:13:58.983059+00:00 0:08:02.412267 12618 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T03:05:54.463559+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T03:05:36.602472+00:00 2021-04-02T03:05:38.223911+00:00 0:00:01.621439 12617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T03:05:34.445542+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T02:05:00+00:00 PythonOperator 2021-04-02T03:05:06.637059+00:00 2021-04-02T03:05:09.452491+00:00 0:00:02.815432 12616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T03:05:04.416420+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T02:00:00+00:00 EmrJobFlowSensor 2021-04-02T03:01:08.370112+00:00 2021-04-02T03:10:11.031588+00:00 0:09:02.661476 12615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T03:01:06.114631+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T03:00:46.429717+00:00 2021-04-02T03:00:48.302669+00:00 0:00:01.872952 12614 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T03:00:44.094599+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T02:00:00+00:00 PythonOperator 2021-04-02T03:00:24.564246+00:00 2021-04-02T03:00:27.257786+00:00 0:00:02.693540 12613 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T03:00:22.063916+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T01:00:00+00:00 EmrJobFlowSensor 2021-04-02T02:12:08.838143+00:00 2021-04-02T02:21:11.537275+00:00 0:09:02.699132 12611 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T02:12:06.510490+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T01:00:00+00:00 EmrJobFlowSensor 2021-04-02T02:12:06.705440+00:00 2021-04-02T02:21:09.391155+00:00 0:09:02.685715 12610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T02:12:04.501816+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T02:11:46.952666+00:00 2021-04-02T02:11:48.800467+00:00 0:00:01.847801 12609 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T02:11:44.556585+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T02:11:45.155725+00:00 2021-04-02T02:11:46.886551+00:00 0:00:01.730826 12608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T02:11:42.580873+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T01:00:00+00:00 PythonOperator 2021-04-02T02:11:25.076914+00:00 2021-04-02T02:11:27.915659+00:00 0:00:02.838745 12607 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T02:11:22.469028+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T01:00:00+00:00 PythonOperator 2021-04-02T02:11:24.954593+00:00 2021-04-02T02:11:27.900699+00:00 0:00:02.946106 12606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T02:11:22.468985+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T01:00:00+00:00 TriggerDagRunOperator 2021-04-02T02:11:06.990550+00:00 2021-04-02T02:11:07.536930+00:00 0:00:00.546380 12605 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T02:11:04.404660+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T01:00:00+00:00 TriggerDagRunOperator 2021-04-02T02:11:06.610651+00:00 2021-04-02T02:11:07.040549+00:00 0:00:00.429898 12604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T02:11:04.404689+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T01:05:00+00:00 EmrJobFlowSensor 2021-04-02T02:06:00.626812+00:00 2021-04-02T02:15:03.381911+00:00 0:09:02.755099 12603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T02:05:58.064837+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T02:05:40.079376+00:00 2021-04-02T02:05:41.742826+00:00 0:00:01.663450 12602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T02:05:37.900206+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T01:05:00+00:00 PythonOperator 2021-04-02T02:05:16.069943+00:00 2021-04-02T02:05:18.797505+00:00 0:00:02.727562 12601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T02:05:13.886427+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T01:00:00+00:00 EmrJobFlowSensor 2021-04-02T02:00:51.757779+00:00 2021-04-02T02:10:54.677653+00:00 0:10:02.919874 12600 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T02:00:49.503651+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T02:00:30.041545+00:00 2021-04-02T02:00:31.725404+00:00 0:00:01.683859 12599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T02:00:27.540830+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T01:00:00+00:00 PythonOperator 2021-04-02T02:00:10.137752+00:00 2021-04-02T02:00:13.031121+00:00 0:00:02.893369 12598 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T02:00:07.417775+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T00:00:00+00:00 EmrJobFlowSensor 2021-04-02T01:11:07.865971+00:00 2021-04-02T01:20:10.450988+00:00 0:09:02.585017 12596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T01:11:05.646430+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T00:00:00+00:00 EmrJobFlowSensor 2021-04-02T01:10:59.994453+00:00 2021-04-02T01:21:02.947470+00:00 0:10:02.953017 12595 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T01:10:57.646808+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T01:10:48.259614+00:00 2021-04-02T01:10:49.971161+00:00 0:00:01.711547 12594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T01:10:45.616906+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T01:10:38.372164+00:00 2021-04-02T01:10:40.047207+00:00 0:00:01.675043 12593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T01:10:35.606102+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T00:00:00+00:00 PythonOperator 2021-04-02T01:10:25.917899+00:00 2021-04-02T01:10:28.993197+00:00 0:00:03.075298 12592 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T01:10:23.616624+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T00:00:00+00:00 PythonOperator 2021-04-02T01:10:16.175018+00:00 2021-04-02T01:10:18.917455+00:00 0:00:02.742437 12591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T01:10:13.589224+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T00:00:00+00:00 TriggerDagRunOperator 2021-04-02T01:10:08.083768+00:00 2021-04-02T01:10:08.508176+00:00 0:00:00.424408 12590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T01:10:05.525327+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T00:00:00+00:00 TriggerDagRunOperator 2021-04-02T01:10:08.085985+00:00 2021-04-02T01:10:08.701554+00:00 0:00:00.615569 12589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T01:10:05.525359+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T00:05:00+00:00 EmrJobFlowSensor 2021-04-02T01:05:55.623786+00:00 2021-04-02T01:14:58.381495+00:00 0:09:02.757709 12588 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T01:05:53.149483+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T01:05:33.380944+00:00 2021-04-02T01:05:35.091053+00:00 0:00:01.710109 12587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T01:05:31.155700+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T00:05:00+00:00 PythonOperator 2021-04-02T01:05:11.155588+00:00 2021-04-02T01:05:13.852411+00:00 0:00:02.696823 12586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T01:05:08.982645+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T00:00:00+00:00 EmrJobFlowSensor 2021-04-02T01:00:52.746840+00:00 2021-04-02T01:09:55.332775+00:00 0:09:02.585935 12585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T01:00:50.570730+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T01:00:31.139286+00:00 2021-04-02T01:00:32.948713+00:00 0:00:01.809427 12584 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T01:00:28.672616+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T00:00:00+00:00 PythonOperator 2021-04-02T01:00:09.342706+00:00 2021-04-02T01:00:12.193352+00:00 0:00:02.850646 12583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T01:00:06.564940+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T23:00:00+00:00 EmrJobFlowSensor 2021-04-02T00:12:23.184879+00:00 2021-04-02T00:20:25.891838+00:00 0:08:02.706959 12581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T00:12:20.932167+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T23:00:00+00:00 EmrJobFlowSensor 2021-04-02T00:12:13.239511+00:00 2021-04-02T00:22:16.178973+00:00 0:10:02.939462 12580 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T00:12:10.922028+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T00:12:01.357834+00:00 2021-04-02T00:12:03.244784+00:00 0:00:01.886950 12579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T00:11:58.960337+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T00:11:51.305836+00:00 2021-04-02T00:11:53.029146+00:00 0:00:01.723310 12578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T00:11:48.901679+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T23:00:00+00:00 PythonOperator 2021-04-02T00:11:39.190909+00:00 2021-04-02T00:11:41.916264+00:00 0:00:02.725355 12577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T00:11:36.900876+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T23:00:00+00:00 PythonOperator 2021-04-02T00:11:17.061567+00:00 2021-04-02T00:11:20.073255+00:00 0:00:03.011688 12576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T00:11:14.804175+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T23:00:00+00:00 TriggerDagRunOperator 2021-04-02T00:11:09.535667+00:00 2021-04-02T00:11:10.193411+00:00 0:00:00.657744 12575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T00:11:06.796048+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T23:00:00+00:00 TriggerDagRunOperator 2021-04-02T00:11:09.360993+00:00 2021-04-02T00:11:09.769387+00:00 0:00:00.408394 12574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T00:11:06.796016+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T23:05:00+00:00 EmrJobFlowSensor 2021-04-02T00:06:00.886360+00:00 2021-04-02T00:15:03.410912+00:00 0:09:02.524552 12573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T00:05:58.463856+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T00:05:38.461004+00:00 2021-04-02T00:05:40.164201+00:00 0:00:01.703197 12572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T00:05:36.223344+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T23:05:00+00:00 PythonOperator 2021-04-02T00:05:16.563410+00:00 2021-04-02T00:05:19.248613+00:00 0:00:02.685203 12571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T00:05:14.266849+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T23:00:00+00:00 EmrJobFlowSensor 2021-04-02T00:00:56.095907+00:00 2021-04-02T00:10:59.095372+00:00 0:10:02.999465 12570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T00:00:53.804387+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T00:00:34.367907+00:00 2021-04-02T00:00:36.181938+00:00 0:00:01.814031 12569 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T00:00:31.851216+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T23:00:00+00:00 PythonOperator 2021-04-02T00:00:12.395948+00:00 2021-04-02T00:00:15.112676+00:00 0:00:02.716728 12568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T00:00:09.766765+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T22:00:00+00:00 EmrJobFlowSensor 2021-04-01T23:12:09.401943+00:00 2021-04-01T23:21:12.046646+00:00 0:09:02.644703 12566 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T23:12:07.254924+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T22:00:00+00:00 EmrJobFlowSensor 2021-04-01T23:12:01.535566+00:00 2021-04-01T23:22:04.326308+00:00 0:10:02.790742 12565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T23:11:59.260583+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T23:11:47.332363+00:00 2021-04-01T23:11:49.026426+00:00 0:00:01.694063 12564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T23:11:45.187238+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T23:11:39.483630+00:00 2021-04-01T23:11:41.289630+00:00 0:00:01.806000 12563 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T23:11:37.154766+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T22:00:00+00:00 PythonOperator 2021-04-01T23:11:27.320058+00:00 2021-04-01T23:11:30.093955+00:00 0:00:02.773897 12562 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T23:11:25.139578+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T22:00:00+00:00 PythonOperator 2021-04-01T23:11:17.657806+00:00 2021-04-01T23:11:20.830873+00:00 0:00:03.173067 12561 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T23:11:15.166633+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T22:00:00+00:00 TriggerDagRunOperator 2021-04-01T23:11:09.745192+00:00 2021-04-01T23:11:10.168810+00:00 0:00:00.423618 12560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T23:11:07.124408+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T22:00:00+00:00 TriggerDagRunOperator 2021-04-01T23:11:09.597860+00:00 2021-04-01T23:11:10.150757+00:00 0:00:00.552897 12559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T23:11:07.124380+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T22:05:00+00:00 EmrJobFlowSensor 2021-04-01T23:06:01.197971+00:00 2021-04-01T23:14:03.702838+00:00 0:08:02.504867 12558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T23:05:58.766294+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T23:05:38.889129+00:00 2021-04-01T23:05:40.622907+00:00 0:00:01.733778 12557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T23:05:36.595628+00:00 2 default_pool