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-02T07:05:00+00:00 EmrJobFlowSensor 2021-04-02T08:05:47.577850+00:00 2021-04-02T08:13:50.039542+00:00 0:08:02.461692 12694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T08:05:45.395951+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T08:05:27.494716+00:00 2021-04-02T08:05:29.142763+00:00 0:00:01.648047 12693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T08:05:25.356821+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T07:05:00+00:00 PythonOperator 2021-04-02T08:05:03.525377+00:00 2021-04-02T08:05:06.206606+00:00 0:00:02.681229 12692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T08:05:01.334790+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T07:00:00+00:00 EmrJobFlowSensor 2021-04-02T08:00:55.023635+00:00 2021-04-02T08:09:57.742465+00:00 0:09:02.718830 12691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T08:00:52.657401+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T08:00:32.845899+00:00 2021-04-02T08:00:34.641999+00:00 0:00:01.796100 12690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T08:00:30.580484+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T07:00:00+00:00 PythonOperator 2021-04-02T08:00:12.970410+00:00 2021-04-02T08:00:15.795428+00:00 0:00:02.825018 12689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T08:00:10.563007+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T06:00:00+00:00 EmrJobFlowSensor 2021-04-02T07:12:47.322501+00:00 2021-04-02T07:21:49.943002+00:00 0:09:02.620501 12687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T07:12:45.099374+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T06:00:00+00:00 EmrJobFlowSensor 2021-04-02T07:12:35.837491+00:00 2021-04-02T07:21:38.689420+00:00 0:09:02.851929 12686 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T07:12:33.090074+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T07:12:25.512046+00:00 2021-04-02T07:12:27.287188+00:00 0:00:01.775142 12685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T07:12:23.028461+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T07:12:13.519293+00:00 2021-04-02T07:12:15.227181+00:00 0:00:01.707888 12684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T07:12:11.062235+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T06:00:00+00:00 PythonOperator 2021-04-02T07:12:05.615256+00:00 2021-04-02T07:12:08.525407+00:00 0:00:02.910151 12683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T07:12:02.965729+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T06:00:00+00:00 PythonOperator 2021-04-02T07:11:53.214066+00:00 2021-04-02T07:11:55.998921+00:00 0:00:02.784855 12682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T07:11:50.955652+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T06:00:00+00:00 TriggerDagRunOperator 2021-04-02T07:11:35.389598+00:00 2021-04-02T07:11:35.953481+00:00 0:00:00.563883 12681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T07:11:32.948162+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T06:00:00+00:00 TriggerDagRunOperator 2021-04-02T07:11:35.201457+00:00 2021-04-02T07:11:35.663377+00:00 0:00:00.461920 12680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T07:11:32.948196+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T06:05:00+00:00 EmrJobFlowSensor 2021-04-02T07:05:52.584005+00:00 2021-04-02T07:14:55.245427+00:00 0:09:02.661422 12679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T07:05:50.431279+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T07:05:28.669421+00:00 2021-04-02T07:05:30.299668+00:00 0:00:01.630247 12678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T07:05:26.404267+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T06:05:00+00:00 PythonOperator 2021-04-02T07:05:06.605219+00:00 2021-04-02T07:05:09.376243+00:00 0:00:02.771024 12677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T07:05:04.389053+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T06:00:00+00:00 EmrJobFlowSensor 2021-04-02T07:01:12.400048+00:00 2021-04-02T07:11:15.248339+00:00 0:10:02.848291 12676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T07:01:10.046970+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T07:00:50.233517+00:00 2021-04-02T07:00:52.014626+00:00 0:00:01.781109 12675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T07:00:47.948158+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T06:00:00+00:00 PythonOperator 2021-04-02T07:00:24.607429+00:00 2021-04-02T07:00:27.347663+00:00 0:00:02.740234 12674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T07:00:21.925973+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T05:00:00+00:00 EmrJobFlowSensor 2021-04-02T06:12:39.433633+00:00 2021-04-02T06:22:42.157487+00:00 0:10:02.723854 12672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T06:12:37.059069+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T05:00:00+00:00 EmrJobFlowSensor 2021-04-02T06:12:25.317288+00:00 2021-04-02T06:24:28.512736+00:00 0:12:03.195448 12671 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T06:12:22.951210+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T06:12:17.099463+00:00 2021-04-02T06:12:18.778442+00:00 0:00:01.678979 12670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T06:12:14.945799+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T06:12:03.342534+00:00 2021-04-02T06:12:05.225661+00:00 0:00:01.883127 12669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T06:12:00.934024+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T05:00:00+00:00 PythonOperator 2021-04-02T06:11:43.237154+00:00 2021-04-02T06:11:45.957533+00:00 0:00:02.720379 12668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T06:11:40.911466+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T05:00:00+00:00 PythonOperator 2021-04-02T06:11:37.384825+00:00 2021-04-02T06:11:40.492419+00:00 0:00:03.107594 12667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T06:11:34.965283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T05:00:00+00:00 TriggerDagRunOperator 2021-04-02T06:11:27.674338+00:00 2021-04-02T06:11:28.202674+00:00 0:00:00.528336 12666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T06:11:24.967265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T05:00:00+00:00 TriggerDagRunOperator 2021-04-02T06:11:27.575904+00:00 2021-04-02T06:11:28.029259+00:00 0:00:00.453355 12665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T06:11:24.967230+00:00 2 default_pool
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