Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-history-job_v002 check_cluster_status 2021-05-09T10:00:00+00:00 EmrJobFlowSensor 2021-05-09T11:10:21.885923+00:00 2021-05-09T11:19:24.492309+00:00 0:09:02.606386 26170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T11:10:19.818210+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T11:10:04.371010+00:00 2021-05-09T11:10:06.200496+00:00 0:00:01.829486 26169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T11:10:01.861243+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T11:10:00.386909+00:00 2021-05-09T11:10:02.157996+00:00 0:00:01.771087 26168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T11:09:57.865507+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T10:00:00+00:00 PythonOperator 2021-05-09T11:09:42.551525+00:00 2021-05-09T11:09:46.070061+00:00 0:00:03.518536 26167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T11:09:39.764574+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T10:00:00+00:00 PythonOperator 2021-05-09T11:09:38.305054+00:00 2021-05-09T11:09:42.058489+00:00 0:00:03.753435 26166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T11:09:35.762391+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T10:00:00+00:00 TriggerDagRunOperator 2021-05-09T11:09:18.333899+00:00 2021-05-09T11:09:18.840532+00:00 0:00:00.506633 26165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T11:09:15.749271+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T10:00:00+00:00 TriggerDagRunOperator 2021-05-09T11:09:18.104109+00:00 2021-05-09T11:09:18.515278+00:00 0:00:00.411169 26164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T11:09:15.749328+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T10:05:00+00:00 EmrJobFlowSensor 2021-05-09T11:05:59.794211+00:00 2021-05-09T11:15:02.760017+00:00 0:09:02.965806 26163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T11:05:57.417472+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T11:05:37.455761+00:00 2021-05-09T11:05:39.112972+00:00 0:00:01.657211 26162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T11:05:35.389444+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T10:05:00+00:00 PythonOperator 2021-05-09T11:05:17.551382+00:00 2021-05-09T11:05:20.598843+00:00 0:00:03.047461 26161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T11:05:15.324524+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T10:00:00+00:00 EmrJobFlowSensor 2021-05-09T11:00:55.081251+00:00 2021-05-09T11:08:57.711607+00:00 0:08:02.630356 26160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T11:00:52.801176+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T11:00:33.320923+00:00 2021-05-09T11:00:35.151808+00:00 0:00:01.830885 26159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T11:00:30.851450+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T10:00:00+00:00 PythonOperator 2021-05-09T11:00:12.823660+00:00 2021-05-09T11:00:15.884933+00:00 0:00:03.061273 26158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T11:00:10.584905+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T09:00:00+00:00 EmrJobFlowSensor 2021-05-09T10:11:23.199101+00:00 2021-05-09T10:21:25.958068+00:00 0:10:02.758967 26156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T10:11:20.867027+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T09:00:00+00:00 EmrJobFlowSensor 2021-05-09T10:11:04.999047+00:00 2021-05-09T10:20:07.738731+00:00 0:09:02.739684 26155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T10:11:02.791738+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T10:11:01.295742+00:00 2021-05-09T10:11:03.012184+00:00 0:00:01.716442 26154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T10:10:58.863024+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T10:10:45.071793+00:00 2021-05-09T10:10:46.926244+00:00 0:00:01.854451 26153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T10:10:42.711889+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T09:00:00+00:00 PythonOperator 2021-05-09T10:10:40.814112+00:00 2021-05-09T10:10:43.861106+00:00 0:00:03.046994 26152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T10:10:38.705638+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T09:00:00+00:00 PythonOperator 2021-05-09T10:10:22.987678+00:00 2021-05-09T10:10:26.335138+00:00 0:00:03.347460 26151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T10:10:20.692448+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T09:00:00+00:00 TriggerDagRunOperator 2021-05-09T10:10:17.037027+00:00 2021-05-09T10:10:17.600441+00:00 0:00:00.563414 26150 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T10:10:14.690065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T09:00:00+00:00 TriggerDagRunOperator 2021-05-09T10:10:16.874836+00:00 2021-05-09T10:10:17.291533+00:00 0:00:00.416697 26149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T10:10:14.690097+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T09:05:00+00:00 EmrJobFlowSensor 2021-05-09T10:06:06.350866+00:00 2021-05-09T10:15:08.990905+00:00 0:09:02.640039 26148 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T10:06:04.289415+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T10:05:36.487819+00:00 2021-05-09T10:05:38.236364+00:00 0:00:01.748545 26147 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T10:05:34.233820+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T09:05:00+00:00 PythonOperator 2021-05-09T10:05:06.447884+00:00 2021-05-09T10:05:09.488492+00:00 0:00:03.040608 26146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T10:05:04.270807+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T09:00:00+00:00 EmrJobFlowSensor 2021-05-09T10:00:54.062801+00:00 2021-05-09T10:09:56.908691+00:00 0:09:02.845890 26145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T10:00:51.814151+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T10:00:31.967138+00:00 2021-05-09T10:00:33.680852+00:00 0:00:01.713714 26144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T10:00:29.793955+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T09:00:00+00:00 PythonOperator 2021-05-09T10:00:10.144396+00:00 2021-05-09T10:00:13.319368+00:00 0:00:03.174972 26143 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T10:00:07.756875+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T08:00:00+00:00 EmrJobFlowSensor 2021-05-09T09:11:27.489139+00:00 2021-05-09T09:19:30.053051+00:00 0:08:02.563912 26141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T09:11:25.272184+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T08:00:00+00:00 EmrJobFlowSensor 2021-05-09T09:11:09.996468+00:00 2021-05-09T09:20:12.579433+00:00 0:09:02.582965 26140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T09:11:07.264912+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T09:11:07.519699+00:00 2021-05-09T09:11:09.329442+00:00 0:00:01.809743 26139 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T09:11:05.243905+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T09:10:49.904115+00:00 2021-05-09T09:10:51.726496+00:00 0:00:01.822381 26138 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T09:10:47.142092+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T08:00:00+00:00 PythonOperator 2021-05-09T09:10:45.390412+00:00 2021-05-09T09:10:48.855339+00:00 0:00:03.464927 26137 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T09:10:43.134134+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T08:00:00+00:00 PythonOperator 2021-05-09T09:10:27.200378+00:00 2021-05-09T09:10:30.461290+00:00 0:00:03.260912 26136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T09:10:25.119801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T08:00:00+00:00 TriggerDagRunOperator 2021-05-09T09:10:23.449290+00:00 2021-05-09T09:10:23.977531+00:00 0:00:00.528241 26135 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T09:10:21.116775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T08:00:00+00:00 TriggerDagRunOperator 2021-05-09T09:10:23.313181+00:00 2021-05-09T09:10:23.715137+00:00 0:00:00.401956 26134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T09:10:21.116806+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T08:05:00+00:00 EmrJobFlowSensor 2021-05-09T09:06:06.706752+00:00 2021-05-09T09:14:09.381203+00:00 0:08:02.674451 26133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T09:06:04.602084+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T09:05:44.988637+00:00 2021-05-09T09:05:46.772540+00:00 0:00:01.783903 26132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T09:05:42.592115+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T08:05:00+00:00 PythonOperator 2021-05-09T09:05:24.798575+00:00 2021-05-09T09:05:27.880085+00:00 0:00:03.081510 26131 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T09:05:22.459600+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T08:00:00+00:00 EmrJobFlowSensor 2021-05-09T09:00:56.392259+00:00 2021-05-09T09:09:59.294094+00:00 0:09:02.901835 26130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T09:00:54.151316+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T09:00:34.196862+00:00 2021-05-09T09:00:35.936645+00:00 0:00:01.739783 26129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T09:00:32.042497+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T08:00:00+00:00 PythonOperator 2021-05-09T09:00:12.787072+00:00 2021-05-09T09:00:15.839224+00:00 0:00:03.052152 26128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T09:00:10.052327+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T07:00:00+00:00 EmrJobFlowSensor 2021-05-09T08:11:47.343650+00:00 2021-05-09T08:20:49.965395+00:00 0:09:02.621745 26126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T08:11:45.104269+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T07:00:00+00:00 EmrJobFlowSensor 2021-05-09T08:11:33.633183+00:00 2021-05-09T08:21:36.557727+00:00 0:10:02.924544 26125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T08:11:31.160524+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T08:11:25.509586+00:00 2021-05-09T08:11:27.271349+00:00 0:00:01.761763 26124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T08:11:23.143394+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T08:11:09.774725+00:00 2021-05-09T08:11:11.614701+00:00 0:00:01.839976 26123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T08:11:06.989833+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T07:00:00+00:00 PythonOperator 2021-05-09T08:11:01.409544+00:00 2021-05-09T08:11:04.598601+00:00 0:00:03.189057 26122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T08:10:59.052694+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T07:00:00+00:00 PythonOperator 2021-05-09T08:10:43.190767+00:00 2021-05-09T08:10:46.452346+00:00 0:00:03.261579 26121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T08:10:40.919023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T07:00:00+00:00 TriggerDagRunOperator 2021-05-09T08:10:33.533639+00:00 2021-05-09T08:10:34.065300+00:00 0:00:00.531661 26120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T08:10:30.910465+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T07:00:00+00:00 TriggerDagRunOperator 2021-05-09T08:10:33.264706+00:00 2021-05-09T08:10:33.683621+00:00 0:00:00.418915 26119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T08:10:30.910428+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T07:05:00+00:00 EmrJobFlowSensor 2021-05-09T08:05:46.443112+00:00 2021-05-09T08:14:48.946105+00:00 0:09:02.502993 26118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T08:05:44.406441+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T08:05:24.657539+00:00 2021-05-09T08:05:26.355876+00:00 0:00:01.698337 26117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T08:05:22.449685+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T07:05:00+00:00 PythonOperator 2021-05-09T08:05:04.733289+00:00 2021-05-09T08:05:07.772647+00:00 0:00:03.039358 26116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T08:05:02.352248+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T07:00:00+00:00 EmrJobFlowSensor 2021-05-09T08:01:06.305022+00:00 2021-05-09T08:10:09.258914+00:00 0:09:02.953892 26115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T08:01:03.866211+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T08:00:46.091937+00:00 2021-05-09T08:00:47.788594+00:00 0:00:01.696657 26114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T08:00:43.805661+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T07:00:00+00:00 PythonOperator 2021-05-09T08:00:24.099260+00:00 2021-05-09T08:00:27.170871+00:00 0:00:03.071611 26113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T08:00:21.789521+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T06:00:00+00:00 EmrJobFlowSensor 2021-05-09T07:11:28.620923+00:00 2021-05-09T07:19:31.111175+00:00 0:08:02.490252 26111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T07:11:26.323143+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T06:00:00+00:00 EmrJobFlowSensor 2021-05-09T07:11:18.596694+00:00 2021-05-09T07:20:21.266556+00:00 0:09:02.669862 26110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T07:11:16.376043+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T07:11:06.450926+00:00 2021-05-09T07:11:08.250272+00:00 0:00:01.799346 26109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T07:11:04.288098+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T07:10:56.523329+00:00 2021-05-09T07:10:58.282778+00:00 0:00:01.759449 26108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T07:10:54.244579+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T06:00:00+00:00 PythonOperator 2021-05-09T07:10:44.728309+00:00 2021-05-09T07:10:47.943154+00:00 0:00:03.214845 26107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T07:10:42.230168+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T06:00:00+00:00 PythonOperator 2021-05-09T07:10:34.441664+00:00 2021-05-09T07:10:37.816307+00:00 0:00:03.374643 26106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T07:10:32.248497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T06:00:00+00:00 TriggerDagRunOperator 2021-05-09T07:10:24.920489+00:00 2021-05-09T07:10:25.441324+00:00 0:00:00.520835 26105 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T07:10:22.283047+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T06:00:00+00:00 TriggerDagRunOperator 2021-05-09T07:10:24.660357+00:00 2021-05-09T07:10:25.096084+00:00 0:00:00.435727 26104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T07:10:22.283011+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T06:05:00+00:00 EmrJobFlowSensor 2021-05-09T07:06:00.521961+00:00 2021-05-09T07:15:03.171020+00:00 0:09:02.649059 26103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T07:05:58.050002+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T07:05:40.296566+00:00 2021-05-09T07:05:42.010007+00:00 0:00:01.713441 26102 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T07:05:37.881792+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T06:05:00+00:00 PythonOperator 2021-05-09T07:05:17.911660+00:00 2021-05-09T07:05:20.933115+00:00 0:00:03.021455 26101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T07:05:15.827642+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T06:00:00+00:00 EmrJobFlowSensor 2021-05-09T07:00:57.743369+00:00 2021-05-09T07:10:00.517716+00:00 0:09:02.774347 26100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T07:00:55.454666+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T07:00:35.855755+00:00 2021-05-09T07:00:37.735721+00:00 0:00:01.879966 26099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T07:00:33.455929+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T06:00:00+00:00 PythonOperator 2021-05-09T07:00:13.837588+00:00 2021-05-09T07:00:17.014482+00:00 0:00:03.176894 26098 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T07:00:11.379998+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T05:00:00+00:00 EmrJobFlowSensor 2021-05-09T06:23:28.809951+00:00 2021-05-09T06:33:31.707796+00:00 0:10:02.897845 26096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T06:23:26.236686+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T05:00:00+00:00 EmrJobFlowSensor 2021-05-09T06:23:10.635185+00:00 2021-05-09T06:31:13.209751+00:00 0:08:02.574566 26095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T06:23:08.263676+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T06:23:06.468091+00:00 2021-05-09T06:23:08.156869+00:00 0:00:01.688778 26094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T06:23:04.273833+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T06:22:48.480295+00:00 2021-05-09T06:22:50.275655+00:00 0:00:01.795360 26093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T06:22:46.153678+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T05:00:00+00:00 PythonOperator 2021-05-09T06:22:46.383981+00:00 2021-05-09T06:22:49.651356+00:00 0:00:03.267375 26092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T06:22:44.186773+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T05:00:00+00:00 PythonOperator 2021-05-09T06:22:28.340627+00:00 2021-05-09T06:22:31.478732+00:00 0:00:03.138105 26091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T06:22:26.132466+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T05:00:00+00:00 TriggerDagRunOperator 2021-05-09T06:22:22.465000+00:00 2021-05-09T06:22:22.985810+00:00 0:00:00.520810 26090 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T06:22:20.127610+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T05:00:00+00:00 TriggerDagRunOperator 2021-05-09T06:22:22.305466+00:00 2021-05-09T06:22:22.741228+00:00 0:00:00.435762 26089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T06:22:20.127580+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T05:05:00+00:00 EmrJobFlowSensor 2021-05-09T06:05:56.965469+00:00 2021-05-09T06:13:59.458919+00:00 0:08:02.493450 26088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T06:05:54.762974+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T06:05:34.979837+00:00 2021-05-09T06:05:36.750608+00:00 0:00:01.770771 26087 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T06:05:32.682060+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T05:05:00+00:00 PythonOperator 2021-05-09T06:05:15.104055+00:00 2021-05-09T06:05:18.226958+00:00 0:00:03.122903 26086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T06:05:12.657480+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T05:00:00+00:00 EmrJobFlowSensor 2021-05-09T06:01:04.159477+00:00 2021-05-09T06:22:08.549001+00:00 0:21:04.389524 26085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T06:01:02.019378+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T06:00:40.479704+00:00 2021-05-09T06:00:42.325569+00:00 0:00:01.845865 26084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T06:00:38.060324+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T05:00:00+00:00 PythonOperator 2021-05-09T06:00:18.316188+00:00 2021-05-09T06:00:21.483668+00:00 0:00:03.167480 26083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T06:00:15.957360+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T04:00:00+00:00 EmrJobFlowSensor 2021-05-09T05:11:37.518254+00:00 2021-05-09T05:19:40.061019+00:00 0:08:02.542765 26081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T05:11:35.206295+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T04:00:00+00:00 EmrJobFlowSensor 2021-05-09T05:11:27.549566+00:00 2021-05-09T05:20:30.192934+00:00 0:09:02.643368 26080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T05:11:25.263684+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-09T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T05:11:15.479440+00:00 2021-05-09T05:11:17.164829+00:00 0:00:01.685389 26079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T05:11:13.251786+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T05:11:05.475410+00:00 2021-05-09T05:11:07.281186+00:00 0:00:01.805776 26078 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T05:11:03.170910+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-09T04:00:00+00:00 PythonOperator 2021-05-09T05:10:55.259995+00:00 2021-05-09T05:10:58.425438+00:00 0:00:03.165443 26077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T05:10:53.126407+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-09T04:00:00+00:00 PythonOperator 2021-05-09T05:10:45.334809+00:00 2021-05-09T05:10:48.710491+00:00 0:00:03.375682 26076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T05:10:43.153623+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-09T04:00:00+00:00 TriggerDagRunOperator 2021-05-09T05:10:31.622761+00:00 2021-05-09T05:10:32.120939+00:00 0:00:00.498178 26075 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T05:10:29.174175+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-09T04:00:00+00:00 TriggerDagRunOperator 2021-05-09T05:10:31.463821+00:00 2021-05-09T05:10:31.886335+00:00 0:00:00.422514 26074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T05:10:29.174120+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-09T04:05:00+00:00 EmrJobFlowSensor 2021-05-09T05:06:02.910092+00:00 2021-05-09T05:15:05.591521+00:00 0:09:02.681429 26073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T05:06:00.682972+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-09T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-09T05:05:40.891647+00:00 2021-05-09T05:05:42.637062+00:00 0:00:01.745415 26072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T05:05:38.616369+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-09T04:05:00+00:00 PythonOperator 2021-05-09T05:05:18.888943+00:00 2021-05-09T05:05:21.932421+00:00 0:00:03.043478 26071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T05:05:16.662340+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-09T04:00:00+00:00 EmrJobFlowSensor 2021-05-09T05:01:04.469828+00:00 2021-05-09T05:10:07.310834+00:00 0:09:02.841006 26070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-09T05:01:02.109283+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-09T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T05:00:42.299591+00:00 2021-05-09T05:00:44.061059+00:00 0:00:01.761468 26069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-09T05:00:40.090276+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-09T04:00:00+00:00 PythonOperator 2021-05-09T05:00:18.586203+00:00 2021-05-09T05:00:21.677507+00:00 0:00:03.091304 26068 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-09T05:00:16.017522+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-09T03:00:00+00:00 EmrJobFlowSensor 2021-05-09T04:10:59.157399+00:00 2021-05-09T04:21:01.912936+00:00 0:10:02.755537 26066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T04:10:56.941180+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-09T03:00:00+00:00 EmrJobFlowSensor 2021-05-09T04:10:47.100130+00:00 2021-05-09T04:20:49.822472+00:00 0:10:02.722342 26065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-09T04:10:44.958099+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-09T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-09T04:10:39.503881+00:00 2021-05-09T04:10:41.320684+00:00 0:00:01.816803 26064 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-09T04:10:36.941333+00:00 2 default_pool