Task Instances

Reset Filters
  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 create_cluster_and_add_emr_steps 2021-03-25T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T22:19:53.601657+00:00 2021-03-25T22:19:55.555291+00:00 0:00:01.953634 11697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T22:19:51.317596+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T21:00:00+00:00 PythonOperator 2021-03-25T22:19:33.611715+00:00 2021-03-25T22:19:36.533589+00:00 0:00:02.921874 11696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T22:19:31.302476+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T21:00:00+00:00 TriggerDagRunOperator 2021-03-25T22:19:09.796569+00:00 2021-03-25T22:19:10.265814+00:00 0:00:00.469245 11695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T22:19:07.244622+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T21:00:00+00:00 TriggerDagRunOperator 2021-03-25T22:19:09.783995+00:00 2021-03-25T22:19:10.343123+00:00 0:00:00.559128 11694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T22:19:07.244593+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T21:05:00+00:00 EmrJobFlowSensor 2021-03-25T22:05:53.774068+00:00 2021-03-25T22:14:56.357707+00:00 0:09:02.583639 11692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T22:05:51.458177+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T21:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T22:05:33.506726+00:00 2021-03-25T22:05:35.162528+00:00 0:00:01.655802 11691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T22:05:31.363029+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T21:05:00+00:00 PythonOperator 2021-03-25T22:05:11.385215+00:00 2021-03-25T22:05:14.080332+00:00 0:00:02.695117 11690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T22:05:09.240032+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T21:00:00+00:00 EmrJobFlowSensor 2021-03-25T22:00:49.119905+00:00 2021-03-25T22:18:53.033800+00:00 0:18:03.913895 11689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T22:00:46.900364+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T22:00:29.017348+00:00 2021-03-25T22:00:30.716783+00:00 0:00:01.699435 11688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T22:00:26.823724+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T21:00:00+00:00 PythonOperator 2021-03-25T22:00:07.545141+00:00 2021-03-25T22:00:10.401270+00:00 0:00:02.856129 11687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T22:00:04.805247+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T20:00:00+00:00 EmrJobFlowSensor 2021-03-25T21:10:12.803424+00:00 2021-03-25T21:19:15.391654+00:00 0:09:02.588230 11685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T21:10:10.593506+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T21:09:50.787749+00:00 2021-03-25T21:09:52.583815+00:00 0:00:01.796066 11684 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T21:09:48.563710+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T20:00:00+00:00 PythonOperator 2021-03-25T21:09:29.047142+00:00 2021-03-25T21:09:32.153873+00:00 0:00:03.106731 11683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T21:09:26.542600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T20:00:00+00:00 TriggerDagRunOperator 2021-03-25T21:09:23.000653+00:00 2021-03-25T21:09:23.400653+00:00 0:00:00.400000 11682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T21:09:20.543943+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T20:00:00+00:00 TriggerDagRunOperator 2021-03-25T21:09:22.893807+00:00 2021-03-25T21:09:23.422147+00:00 0:00:00.528340 11681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T21:09:20.543912+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T20:05:00+00:00 EmrJobFlowSensor 2021-03-25T21:05:48.516725+00:00 2021-03-25T21:14:51.197930+00:00 0:09:02.681205 11680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T21:05:46.281961+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T20:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T21:05:26.481072+00:00 2021-03-25T21:05:28.289362+00:00 0:00:01.808290 11679 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T21:05:24.230645+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T20:05:00+00:00 PythonOperator 2021-03-25T21:05:06.387274+00:00 2021-03-25T21:05:09.087536+00:00 0:00:02.700262 11678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T21:05:04.213704+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T20:00:00+00:00 EmrJobFlowSensor 2021-03-25T21:01:06.207454+00:00 2021-03-25T21:09:08.899768+00:00 0:08:02.692314 11677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T21:01:03.871482+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T21:00:46.106952+00:00 2021-03-25T21:00:47.769313+00:00 0:00:01.662361 11676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T21:00:43.853126+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T20:00:00+00:00 PythonOperator 2021-03-25T21:00:24.664132+00:00 2021-03-25T21:00:27.560047+00:00 0:00:02.895915 11675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T21:00:21.863892+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T19:00:00+00:00 EmrJobFlowSensor 2021-03-25T20:10:21.427875+00:00 2021-03-25T20:20:24.259233+00:00 0:10:02.831358 11673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T20:10:19.223099+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T20:09:59.536724+00:00 2021-03-25T20:10:01.229214+00:00 0:00:01.692490 11672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T20:09:57.207328+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T19:00:00+00:00 PythonOperator 2021-03-25T20:09:39.417037+00:00 2021-03-25T20:09:42.539708+00:00 0:00:03.122671 11671 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T20:09:37.185207+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T19:00:00+00:00 TriggerDagRunOperator 2021-03-25T20:09:25.464853+00:00 2021-03-25T20:09:25.885018+00:00 0:00:00.420165 11670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T20:09:23.156336+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T19:00:00+00:00 TriggerDagRunOperator 2021-03-25T20:09:25.380464+00:00 2021-03-25T20:09:25.939048+00:00 0:00:00.558584 11669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T20:09:23.156370+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T19:05:00+00:00 EmrJobFlowSensor 2021-03-25T20:06:13.050152+00:00 2021-03-25T20:15:15.667201+00:00 0:09:02.617049 11668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T20:06:10.791908+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T19:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T20:05:44.857258+00:00 2021-03-25T20:05:46.562838+00:00 0:00:01.705580 11667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T20:05:42.744608+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T19:05:00+00:00 PythonOperator 2021-03-25T20:05:22.987673+00:00 2021-03-25T20:05:25.754071+00:00 0:00:02.766398 11666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T20:05:20.727954+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T19:00:00+00:00 EmrJobFlowSensor 2021-03-25T20:00:58.721030+00:00 2021-03-25T20:09:01.368499+00:00 0:08:02.647469 11665 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T20:00:56.366355+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T20:00:36.804349+00:00 2021-03-25T20:00:38.591950+00:00 0:00:01.787601 11664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T20:00:34.359411+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T19:00:00+00:00 PythonOperator 2021-03-25T20:00:12.661190+00:00 2021-03-25T20:00:15.552390+00:00 0:00:02.891200 11663 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T20:00:10.243771+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T18:00:00+00:00 EmrJobFlowSensor 2021-03-25T19:10:12.657581+00:00 2021-03-25T19:20:15.525299+00:00 0:10:02.867718 11661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T19:10:10.402853+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T19:09:50.797963+00:00 2021-03-25T19:09:52.575686+00:00 0:00:01.777723 11660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T19:09:48.444102+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T18:00:00+00:00 PythonOperator 2021-03-25T19:09:31.127307+00:00 2021-03-25T19:09:34.033010+00:00 0:00:02.905703 11659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T19:09:28.357140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T18:00:00+00:00 TriggerDagRunOperator 2021-03-25T19:09:18.449915+00:00 2021-03-25T19:09:18.977263+00:00 0:00:00.527348 11658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T19:09:16.195283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T18:00:00+00:00 TriggerDagRunOperator 2021-03-25T19:09:18.412976+00:00 2021-03-25T19:09:18.888433+00:00 0:00:00.475457 11657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T19:09:16.195311+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T18:05:00+00:00 EmrJobFlowSensor 2021-03-25T19:06:04.046495+00:00 2021-03-25T19:15:06.687821+00:00 0:09:02.641326 11656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T19:06:01.769919+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T18:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T19:05:41.781290+00:00 2021-03-25T19:05:43.434898+00:00 0:00:01.653608 11655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T19:05:39.684900+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T18:05:00+00:00 PythonOperator 2021-03-25T19:05:19.855518+00:00 2021-03-25T19:05:22.649306+00:00 0:00:02.793788 11654 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T19:05:17.661154+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T18:00:00+00:00 EmrJobFlowSensor 2021-03-25T19:00:55.515475+00:00 2021-03-25T19:08:57.921628+00:00 0:08:02.406153 11653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T19:00:53.333643+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T19:00:33.885152+00:00 2021-03-25T19:00:35.654976+00:00 0:00:01.769824 11652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T19:00:31.375853+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T18:00:00+00:00 PythonOperator 2021-03-25T19:00:11.979176+00:00 2021-03-25T19:00:14.740453+00:00 0:00:02.761277 11651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T19:00:09.366675+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T17:00:00+00:00 EmrJobFlowSensor 2021-03-25T18:11:36.317743+00:00 2021-03-25T18:21:39.064901+00:00 0:10:02.747158 11649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T18:11:34.066056+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T18:11:16.248556+00:00 2021-03-25T18:11:18.056998+00:00 0:00:01.808442 11648 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T18:11:14.012374+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T17:00:00+00:00 PythonOperator 2021-03-25T18:10:54.497954+00:00 2021-03-25T18:10:57.528105+00:00 0:00:03.030151 11647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T18:10:51.993055+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T17:00:00+00:00 TriggerDagRunOperator 2021-03-25T18:10:32.401679+00:00 2021-03-25T18:10:32.916342+00:00 0:00:00.514663 11646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T18:10:30.041026+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T17:00:00+00:00 TriggerDagRunOperator 2021-03-25T18:10:32.334309+00:00 2021-03-25T18:10:32.813024+00:00 0:00:00.478715 11645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T18:10:30.041077+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T17:05:00+00:00 EmrJobFlowSensor 2021-03-25T18:05:47.835632+00:00 2021-03-25T18:14:50.415332+00:00 0:09:02.579700 11644 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T18:05:45.659409+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T17:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T18:05:25.850214+00:00 2021-03-25T18:05:27.586663+00:00 0:00:01.736449 11643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T18:05:23.638332+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T17:05:00+00:00 PythonOperator 2021-03-25T18:05:03.855025+00:00 2021-03-25T18:05:06.579467+00:00 0:00:02.724442 11642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T18:05:01.608507+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T17:00:00+00:00 EmrJobFlowSensor 2021-03-25T18:00:53.667795+00:00 2021-03-25T18:09:56.377907+00:00 0:09:02.710112 11641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T18:00:51.311837+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T18:00:31.461454+00:00 2021-03-25T18:00:33.191291+00:00 0:00:01.729837 11640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T18:00:29.291717+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T17:00:00+00:00 PythonOperator 2021-03-25T18:00:11.521223+00:00 2021-03-25T18:00:14.350348+00:00 0:00:02.829125 11639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T18:00:09.229702+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T16:00:00+00:00 EmrJobFlowSensor 2021-03-25T17:12:12.638419+00:00 2021-03-25T17:22:15.448299+00:00 0:10:02.809880 11637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T17:12:10.391905+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T17:11:50.757852+00:00 2021-03-25T17:11:52.524431+00:00 0:00:01.766579 11636 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T17:11:48.353797+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T16:00:00+00:00 PythonOperator 2021-03-25T17:11:28.499715+00:00 2021-03-25T17:11:31.455010+00:00 0:00:02.955295 11635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T17:11:26.326621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T16:00:00+00:00 TriggerDagRunOperator 2021-03-25T17:11:14.711556+00:00 2021-03-25T17:11:15.198945+00:00 0:00:00.487389 11634 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T17:11:12.302753+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T16:00:00+00:00 TriggerDagRunOperator 2021-03-25T17:11:14.521346+00:00 2021-03-25T17:11:14.898784+00:00 0:00:00.377438 11633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T17:11:12.302706+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T16:05:00+00:00 EmrJobFlowSensor 2021-03-25T17:06:06.047295+00:00 2021-03-25T17:15:08.594714+00:00 0:09:02.547419 11632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T17:06:03.927469+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T16:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T17:05:44.059997+00:00 2021-03-25T17:05:45.829943+00:00 0:00:01.769946 11631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T17:05:41.912785+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T16:05:00+00:00 PythonOperator 2021-03-25T17:05:21.966437+00:00 2021-03-25T17:05:24.633500+00:00 0:00:02.667063 11630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T17:05:19.887694+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T16:00:00+00:00 EmrJobFlowSensor 2021-03-25T17:01:08.002464+00:00 2021-03-25T17:11:11.032304+00:00 0:10:03.029840 11629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T17:01:05.560555+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T17:00:45.730175+00:00 2021-03-25T17:00:47.528042+00:00 0:00:01.797867 11628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T17:00:43.491836+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T16:00:00+00:00 PythonOperator 2021-03-25T17:00:23.831398+00:00 2021-03-25T17:00:26.745517+00:00 0:00:02.914119 11627 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T17:00:21.477753+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T15:00:00+00:00 EmrJobFlowSensor 2021-03-25T16:26:26.037921+00:00 2021-03-25T16:36:28.804661+00:00 0:10:02.766740 11626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T16:26:23.843246+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T16:26:06.095214+00:00 2021-03-25T16:26:07.776075+00:00 0:00:01.680861 11625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T16:26:03.825816+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T15:00:00+00:00 PythonOperator 2021-03-25T16:25:42.063170+00:00 2021-03-25T16:25:45.176445+00:00 0:00:03.113275 11624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T16:25:39.808448+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T15:00:00+00:00 TriggerDagRunOperator 2021-03-25T16:25:26.330551+00:00 2021-03-25T16:25:26.848788+00:00 0:00:00.518237 11623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T16:25:23.791438+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T15:00:00+00:00 TriggerDagRunOperator 2021-03-25T16:25:26.049227+00:00 2021-03-25T16:25:26.456673+00:00 0:00:00.407446 11622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T16:25:23.791409+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T15:00:00+00:00 EmrJobFlowSensor 2021-03-25T16:15:11.069385+00:00 2021-03-25T16:25:14.009858+00:00 0:10:02.940473 11621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T16:15:08.819988+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T15:05:00+00:00 EmrJobFlowSensor 2021-03-25T16:15:07.033448+00:00 2021-03-25T16:23:09.521275+00:00 0:08:02.487827 11620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T16:15:04.872189+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T16:14:50.987974+00:00 2021-03-25T16:14:52.778820+00:00 0:00:01.790846 11619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T16:14:48.805124+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T15:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T16:14:44.984193+00:00 2021-03-25T16:14:46.760060+00:00 0:00:01.775867 11618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T16:14:42.797288+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T15:00:00+00:00 PythonOperator 2021-03-25T16:14:29.122772+00:00 2021-03-25T16:14:31.850489+00:00 0:00:02.727717 11617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T16:14:26.782260+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T15:05:00+00:00 PythonOperator 2021-03-25T16:14:25.158018+00:00 2021-03-25T16:14:28.001777+00:00 0:00:02.843759 11616 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T16:14:22.778885+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T14:00:00+00:00 EmrJobFlowSensor 2021-03-25T15:11:19.635739+00:00 2021-03-25T15:20:22.336103+00:00 0:09:02.700364 11614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T15:11:17.189411+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T15:10:59.602870+00:00 2021-03-25T15:11:01.428826+00:00 0:00:01.825956 11613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T15:10:57.162567+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T14:00:00+00:00 PythonOperator 2021-03-25T15:10:37.313355+00:00 2021-03-25T15:10:40.214767+00:00 0:00:02.901412 11612 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T15:10:35.097880+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T14:00:00+00:00 TriggerDagRunOperator 2021-03-25T15:10:17.363600+00:00 2021-03-25T15:10:17.876406+00:00 0:00:00.512806 11611 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T15:10:15.056017+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T14:00:00+00:00 TriggerDagRunOperator 2021-03-25T15:10:17.314128+00:00 2021-03-25T15:10:17.721303+00:00 0:00:00.407175 11610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T15:10:15.056053+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T14:05:00+00:00 EmrJobFlowSensor 2021-03-25T15:05:46.902973+00:00 2021-03-25T15:16:49.887303+00:00 0:11:02.984330 11609 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T15:05:44.691689+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T14:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T15:05:26.783866+00:00 2021-03-25T15:05:28.420670+00:00 0:00:01.636804 11608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T15:05:24.644463+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T14:05:00+00:00 PythonOperator 2021-03-25T15:05:05.037545+00:00 2021-03-25T15:05:07.702282+00:00 0:00:02.664737 11607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T15:05:02.666449+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T14:00:00+00:00 EmrJobFlowSensor 2021-03-25T15:00:58.389045+00:00 2021-03-25T15:10:01.158658+00:00 0:09:02.769613 11606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T15:00:56.111002+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T15:00:36.222683+00:00 2021-03-25T15:00:37.906481+00:00 0:00:01.683798 11605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T15:00:34.087010+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T14:00:00+00:00 PythonOperator 2021-03-25T15:00:16.848702+00:00 2021-03-25T15:00:19.717445+00:00 0:00:02.868743 11604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T15:00:14.071030+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T13:00:00+00:00 EmrJobFlowSensor 2021-03-25T14:11:56.879449+00:00 2021-03-25T14:20:59.554540+00:00 0:09:02.675091 11602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T14:11:54.482408+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T14:11:36.727782+00:00 2021-03-25T14:11:38.536719+00:00 0:00:01.808937 11601 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T14:11:34.395653+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T13:00:00+00:00 PythonOperator 2021-03-25T14:11:14.738865+00:00 2021-03-25T14:11:17.725492+00:00 0:00:02.986627 11600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T14:11:12.357548+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T13:00:00+00:00 TriggerDagRunOperator 2021-03-25T14:11:06.664270+00:00 2021-03-25T14:11:07.172895+00:00 0:00:00.508625 11599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T14:11:04.350192+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T13:00:00+00:00 TriggerDagRunOperator 2021-03-25T14:11:06.586925+00:00 2021-03-25T14:11:06.995038+00:00 0:00:00.408113 11598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T14:11:04.350232+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T13:05:00+00:00 EmrJobFlowSensor 2021-03-25T14:06:00.592731+00:00 2021-03-25T14:15:03.340076+00:00 0:09:02.747345 11597 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T14:05:58.047311+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T13:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T14:05:40.162631+00:00 2021-03-25T14:05:41.779252+00:00 0:00:01.616621 11596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T14:05:37.871031+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T13:05:00+00:00 PythonOperator 2021-03-25T14:05:07.956028+00:00 2021-03-25T14:05:10.702343+00:00 0:00:02.746315 11595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T14:05:05.831514+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T13:00:00+00:00 EmrJobFlowSensor 2021-03-25T14:00:49.879203+00:00 2021-03-25T14:10:52.595566+00:00 0:10:02.716363 11594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T14:00:47.531106+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T14:00:28.033116+00:00 2021-03-25T14:00:29.723664+00:00 0:00:01.690548 11593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T14:00:25.565214+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T13:00:00+00:00 PythonOperator 2021-03-25T14:00:06.092244+00:00 2021-03-25T14:00:08.850990+00:00 0:00:02.758746 11592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T14:00:03.558396+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T12:00:00+00:00 EmrJobFlowSensor 2021-03-25T13:10:49.408847+00:00 2021-03-25T13:20:52.170798+00:00 0:10:02.761951 11590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T13:10:46.990067+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T13:10:29.157548+00:00 2021-03-25T13:10:30.882798+00:00 0:00:01.725250 11589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T13:10:26.908568+00:00 2 default_pool