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 create_cluster_and_add_emr_steps 2021-04-28T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T12:12:00.820534+00:00 2021-04-28T12:12:02.549036+00:00 0:00:01.728502 22194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T12:11:58.176558+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T12:11:54.216292+00:00 2021-04-28T12:11:55.945920+00:00 0:00:01.729628 22193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T12:11:52.041244+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T11:00:00+00:00 PythonOperator 2021-04-28T12:11:38.181201+00:00 2021-04-28T12:11:41.146343+00:00 0:00:02.965142 22192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T12:11:35.992102+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T11:00:00+00:00 PythonOperator 2021-04-28T12:11:32.571936+00:00 2021-04-28T12:11:35.794596+00:00 0:00:03.222660 22191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T12:11:30.066834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T11:00:00+00:00 TriggerDagRunOperator 2021-04-28T12:11:18.683498+00:00 2021-04-28T12:11:19.190407+00:00 0:00:00.506909 22190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T12:11:15.964626+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T11:00:00+00:00 TriggerDagRunOperator 2021-04-28T12:11:18.366581+00:00 2021-04-28T12:11:18.828975+00:00 0:00:00.462394 22189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T12:11:15.964583+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T11:05:00+00:00 EmrJobFlowSensor 2021-04-28T12:10:54.399985+00:00 2021-04-28T12:19:57.016459+00:00 0:09:02.616474 22188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T12:10:51.973186+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T12:10:32.623839+00:00 2021-04-28T12:10:34.359130+00:00 0:00:01.735291 22187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T12:10:29.966715+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T11:05:00+00:00 PythonOperator 2021-04-28T12:10:10.359385+00:00 2021-04-28T12:10:13.324989+00:00 0:00:02.965604 22186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T12:10:07.825044+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T11:00:00+00:00 EmrJobFlowSensor 2021-04-28T12:00:59.809148+00:00 2021-04-28T12:11:02.766506+00:00 0:10:02.957358 22184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T12:00:57.409091+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T12:00:37.687798+00:00 2021-04-28T12:00:39.501295+00:00 0:00:01.813497 22183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T12:00:35.392307+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T11:00:00+00:00 PythonOperator 2021-04-28T12:00:15.622933+00:00 2021-04-28T12:00:18.653348+00:00 0:00:03.030415 22182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T12:00:13.287867+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T10:00:00+00:00 EmrJobFlowSensor 2021-04-28T11:11:35.351025+00:00 2021-04-28T11:23:38.299642+00:00 0:12:02.948617 22181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T11:11:32.881566+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T10:00:00+00:00 EmrJobFlowSensor 2021-04-28T11:11:19.085570+00:00 2021-04-28T11:20:21.787093+00:00 0:09:02.701523 22180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T11:11:16.709514+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T11:11:13.124692+00:00 2021-04-28T11:11:14.829599+00:00 0:00:01.704907 22179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T11:11:10.717251+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T11:10:57.223750+00:00 2021-04-28T11:10:58.996804+00:00 0:00:01.773054 22178 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T11:10:54.764826+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T10:00:00+00:00 PythonOperator 2021-04-28T11:10:51.141800+00:00 2021-04-28T11:10:54.405067+00:00 0:00:03.263267 22177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T11:10:48.753956+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T10:00:00+00:00 PythonOperator 2021-04-28T11:10:35.191615+00:00 2021-04-28T11:10:38.229680+00:00 0:00:03.038065 22176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T11:10:32.695781+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T10:00:00+00:00 TriggerDagRunOperator 2021-04-28T11:10:24.985565+00:00 2021-04-28T11:10:25.433492+00:00 0:00:00.447927 22175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T11:10:22.557464+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T10:00:00+00:00 TriggerDagRunOperator 2021-04-28T11:10:24.919777+00:00 2021-04-28T11:10:25.516247+00:00 0:00:00.596470 22174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T11:10:22.557505+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T10:05:00+00:00 EmrJobFlowSensor 2021-04-28T11:06:06.345858+00:00 2021-04-28T11:15:08.958272+00:00 0:09:02.612414 22173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T11:06:04.107561+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T11:05:42.718334+00:00 2021-04-28T11:05:44.498692+00:00 0:00:01.780358 22172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T11:05:40.158284+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T10:05:00+00:00 PythonOperator 2021-04-28T11:05:22.546616+00:00 2021-04-28T11:05:25.484165+00:00 0:00:02.937549 22171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T11:05:20.056357+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T10:00:00+00:00 EmrJobFlowSensor 2021-04-28T11:00:58.909148+00:00 2021-04-28T11:10:01.753993+00:00 0:09:02.844845 22169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T11:00:56.400151+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T11:00:38.838981+00:00 2021-04-28T11:00:40.651879+00:00 0:00:01.812898 22168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T11:00:36.353055+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T10:00:00+00:00 PythonOperator 2021-04-28T11:00:16.492175+00:00 2021-04-28T11:00:19.512344+00:00 0:00:03.020169 22167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T11:00:14.243452+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T09:00:00+00:00 EmrJobFlowSensor 2021-04-28T10:13:21.019827+00:00 2021-04-28T10:26:24.329178+00:00 0:13:03.309351 22166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T10:13:18.801582+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T09:00:00+00:00 EmrJobFlowSensor 2021-04-28T10:13:15.025845+00:00 2021-04-28T10:23:17.797024+00:00 0:10:02.771179 22165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T10:13:12.798191+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T10:12:59.123313+00:00 2021-04-28T10:13:00.891350+00:00 0:00:01.768037 22164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T10:12:56.737662+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T10:12:53.150421+00:00 2021-04-28T10:12:54.816436+00:00 0:00:01.666015 22163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T10:12:50.728016+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T09:00:00+00:00 PythonOperator 2021-04-28T10:12:37.166152+00:00 2021-04-28T10:12:40.352411+00:00 0:00:03.186259 22162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T10:12:34.767710+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T09:00:00+00:00 PythonOperator 2021-04-28T10:12:31.533230+00:00 2021-04-28T10:12:34.593946+00:00 0:00:03.060716 22161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T10:12:28.866285+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T09:00:00+00:00 TriggerDagRunOperator 2021-04-28T10:12:25.080866+00:00 2021-04-28T10:12:25.482760+00:00 0:00:00.401894 22160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T10:12:22.711190+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T09:00:00+00:00 TriggerDagRunOperator 2021-04-28T10:12:25.099740+00:00 2021-04-28T10:12:25.647378+00:00 0:00:00.547638 22159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T10:12:22.711161+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T09:05:00+00:00 EmrJobFlowSensor 2021-04-28T10:06:08.197217+00:00 2021-04-28T10:15:10.777546+00:00 0:09:02.580329 22158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T10:06:06.082134+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T10:05:48.404090+00:00 2021-04-28T10:05:50.136921+00:00 0:00:01.732831 22157 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T10:05:46.061728+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T09:05:00+00:00 PythonOperator 2021-04-28T10:05:18.345412+00:00 2021-04-28T10:05:21.310357+00:00 0:00:02.964945 22156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T10:05:16.036074+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T09:00:00+00:00 EmrJobFlowSensor 2021-04-28T10:02:12.093000+00:00 2021-04-28T10:12:14.894473+00:00 0:10:02.801473 22155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T10:02:09.793184+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T10:01:50.044680+00:00 2021-04-28T10:01:51.730037+00:00 0:00:01.685357 22154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T10:01:47.693834+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T09:00:00+00:00 PythonOperator 2021-04-28T10:01:29.946838+00:00 2021-04-28T10:01:32.966914+00:00 0:00:03.020076 22153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T10:01:27.670488+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T08:00:00+00:00 EmrJobFlowSensor 2021-04-28T09:11:06.721970+00:00 2021-04-28T09:20:09.342681+00:00 0:09:02.620711 22151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T09:11:04.512373+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T08:00:00+00:00 EmrJobFlowSensor 2021-04-28T09:10:56.921892+00:00 2021-04-28T09:19:59.485055+00:00 0:09:02.563163 22150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T09:10:54.573184+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T09:10:44.868878+00:00 2021-04-28T09:10:46.716059+00:00 0:00:01.847181 22149 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T09:10:42.494122+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T09:10:34.846099+00:00 2021-04-28T09:10:36.678139+00:00 0:00:01.832040 22148 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T09:10:32.488873+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T08:00:00+00:00 PythonOperator 2021-04-28T09:10:24.628094+00:00 2021-04-28T09:10:27.588756+00:00 0:00:02.960662 22147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T09:10:22.432027+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T08:00:00+00:00 PythonOperator 2021-04-28T09:10:12.852732+00:00 2021-04-28T09:10:16.118524+00:00 0:00:03.265792 22146 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T09:10:10.409018+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T08:00:00+00:00 TriggerDagRunOperator 2021-04-28T09:10:06.657674+00:00 2021-04-28T09:10:07.195174+00:00 0:00:00.537500 22145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T09:10:04.406206+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T08:00:00+00:00 TriggerDagRunOperator 2021-04-28T09:10:06.589843+00:00 2021-04-28T09:10:07.043971+00:00 0:00:00.454128 22144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T09:10:04.406240+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T08:05:00+00:00 EmrJobFlowSensor 2021-04-28T09:05:54.266723+00:00 2021-04-28T09:13:56.712922+00:00 0:08:02.446199 22143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T09:05:51.956007+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T09:05:34.208243+00:00 2021-04-28T09:05:35.870437+00:00 0:00:01.662194 22142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T09:05:31.938403+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T08:05:00+00:00 PythonOperator 2021-04-28T09:05:10.343238+00:00 2021-04-28T09:05:13.308675+00:00 0:00:02.965437 22141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T09:05:07.981472+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T08:00:00+00:00 EmrJobFlowSensor 2021-04-28T09:01:00.220467+00:00 2021-04-28T09:10:03.183532+00:00 0:09:02.963065 22140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T09:00:57.670237+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T09:00:38.107909+00:00 2021-04-28T09:00:39.991643+00:00 0:00:01.883734 22139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T09:00:35.661230+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T08:00:00+00:00 PythonOperator 2021-04-28T09:00:17.813441+00:00 2021-04-28T09:00:20.798743+00:00 0:00:02.985302 22138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T09:00:15.559436+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T07:00:00+00:00 EmrJobFlowSensor 2021-04-28T08:11:33.954950+00:00 2021-04-28T08:22:36.934014+00:00 0:11:02.979064 22136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T08:11:31.658167+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T07:00:00+00:00 EmrJobFlowSensor 2021-04-28T08:11:21.821195+00:00 2021-04-28T08:21:24.603280+00:00 0:10:02.782085 22135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T08:11:19.599191+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T08:11:11.889849+00:00 2021-04-28T08:11:13.660385+00:00 0:00:01.770536 22134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T08:11:09.591129+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T08:11:00.108026+00:00 2021-04-28T08:11:01.794049+00:00 0:00:01.686023 22133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T08:10:57.561069+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T07:00:00+00:00 PythonOperator 2021-04-28T08:10:49.801567+00:00 2021-04-28T08:10:53.086889+00:00 0:00:03.285322 22132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T08:10:47.443138+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T07:00:00+00:00 PythonOperator 2021-04-28T08:10:40.085211+00:00 2021-04-28T08:10:43.113893+00:00 0:00:03.028682 22131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T08:10:37.546479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T07:00:00+00:00 TriggerDagRunOperator 2021-04-28T08:10:33.949428+00:00 2021-04-28T08:10:34.506853+00:00 0:00:00.557425 22130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T08:10:31.481141+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T07:00:00+00:00 TriggerDagRunOperator 2021-04-28T08:10:33.928335+00:00 2021-04-28T08:10:34.404895+00:00 0:00:00.476560 22129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T08:10:31.481107+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T07:05:00+00:00 EmrJobFlowSensor 2021-04-28T08:05:56.952213+00:00 2021-04-28T08:14:59.597642+00:00 0:09:02.645429 22128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T08:05:54.809478+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T08:05:35.207784+00:00 2021-04-28T08:05:36.984895+00:00 0:00:01.777111 22127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T08:05:32.786607+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T07:05:00+00:00 PythonOperator 2021-04-28T08:05:10.880976+00:00 2021-04-28T08:05:13.856895+00:00 0:00:02.975919 22126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T08:05:08.726465+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T07:00:00+00:00 EmrJobFlowSensor 2021-04-28T08:01:06.593184+00:00 2021-04-28T08:10:09.423368+00:00 0:09:02.830184 22125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T08:01:04.246528+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T08:00:44.620082+00:00 2021-04-28T08:00:46.346131+00:00 0:00:01.726049 22124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T08:00:42.280573+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T07:00:00+00:00 PythonOperator 2021-04-28T08:00:25.208881+00:00 2021-04-28T08:00:28.176293+00:00 0:00:02.967412 22123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T08:00:22.263727+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T06:00:00+00:00 EmrJobFlowSensor 2021-04-28T07:12:39.735751+00:00 2021-04-28T07:22:42.405957+00:00 0:10:02.670206 22121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T07:12:37.562484+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T06:00:00+00:00 EmrJobFlowSensor 2021-04-28T07:12:37.857824+00:00 2021-04-28T07:22:40.733205+00:00 0:10:02.875381 22120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T07:12:35.563485+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T07:12:18.346144+00:00 2021-04-28T07:12:20.155167+00:00 0:00:01.809023 22119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T07:12:15.574320+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T07:12:16.117641+00:00 2021-04-28T07:12:18.118423+00:00 0:00:02.000782 22118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T07:12:13.567594+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T06:00:00+00:00 PythonOperator 2021-04-28T07:11:55.879906+00:00 2021-04-28T07:11:59.111960+00:00 0:00:03.232054 22117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T07:11:53.555704+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T06:00:00+00:00 PythonOperator 2021-04-28T07:11:54.126029+00:00 2021-04-28T07:11:57.125305+00:00 0:00:02.999276 22116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T07:11:51.543786+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T06:00:00+00:00 TriggerDagRunOperator 2021-04-28T07:11:33.794375+00:00 2021-04-28T07:11:34.331457+00:00 0:00:00.537082 22115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T07:11:31.471436+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T06:00:00+00:00 TriggerDagRunOperator 2021-04-28T07:11:33.736169+00:00 2021-04-28T07:11:34.230664+00:00 0:00:00.494495 22114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T07:11:31.471406+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T06:05:00+00:00 EmrJobFlowSensor 2021-04-28T07:05:49.401353+00:00 2021-04-28T07:14:52.000101+00:00 0:09:02.598748 22113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T07:05:46.984554+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T07:05:26.910696+00:00 2021-04-28T07:05:28.512845+00:00 0:00:01.602149 22112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T07:05:24.803258+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T06:05:00+00:00 PythonOperator 2021-04-28T07:05:06.986107+00:00 2021-04-28T07:05:10.018893+00:00 0:00:03.032786 22111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T07:05:04.791107+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T06:00:00+00:00 EmrJobFlowSensor 2021-04-28T07:01:08.755812+00:00 2021-04-28T07:11:11.554386+00:00 0:10:02.798574 22110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T07:01:06.261422+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T07:00:44.855186+00:00 2021-04-28T07:00:46.688950+00:00 0:00:01.833764 22109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T07:00:42.244726+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T06:00:00+00:00 PythonOperator 2021-04-28T07:00:23.107873+00:00 2021-04-28T07:00:26.219222+00:00 0:00:03.111349 22108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T07:00:20.276379+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T05:00:00+00:00 EmrJobFlowSensor 2021-04-28T06:12:10.634222+00:00 2021-04-28T06:22:13.475993+00:00 0:10:02.841771 22106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T06:12:08.214262+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T05:00:00+00:00 EmrJobFlowSensor 2021-04-28T06:11:58.597190+00:00 2021-04-28T06:21:01.169463+00:00 0:09:02.572273 22105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T06:11:56.207883+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T06:11:48.725510+00:00 2021-04-28T06:11:50.512489+00:00 0:00:01.786979 22104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T06:11:46.201743+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T06:11:38.379246+00:00 2021-04-28T06:11:40.066772+00:00 0:00:01.687526 22103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T06:11:36.189068+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T05:00:00+00:00 PythonOperator 2021-04-28T06:11:28.331000+00:00 2021-04-28T06:11:31.640933+00:00 0:00:03.309933 22102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T06:11:26.114752+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T05:00:00+00:00 PythonOperator 2021-04-28T06:11:16.273273+00:00 2021-04-28T06:11:19.275917+00:00 0:00:03.002644 22101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T06:11:14.104295+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T05:00:00+00:00 TriggerDagRunOperator 2021-04-28T06:11:12.437918+00:00 2021-04-28T06:11:12.865886+00:00 0:00:00.427968 22100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T06:11:10.104589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T05:00:00+00:00 TriggerDagRunOperator 2021-04-28T06:11:12.413879+00:00 2021-04-28T06:11:12.999395+00:00 0:00:00.585516 22099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T06:11:10.104557+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T05:05:00+00:00 EmrJobFlowSensor 2021-04-28T06:05:49.751239+00:00 2021-04-28T06:14:52.321387+00:00 0:09:02.570148 22098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T06:05:47.503171+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T06:05:29.766015+00:00 2021-04-28T06:05:31.438307+00:00 0:00:01.672292 22097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T06:05:27.484469+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T05:05:00+00:00 PythonOperator 2021-04-28T06:05:08.091424+00:00 2021-04-28T06:05:11.093534+00:00 0:00:03.002110 22096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T06:05:05.470584+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T05:00:00+00:00 EmrJobFlowSensor 2021-04-28T06:00:51.073389+00:00 2021-04-28T06:10:53.798664+00:00 0:10:02.725275 22095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T06:00:48.903255+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T06:00:31.141104+00:00 2021-04-28T06:00:32.921866+00:00 0:00:01.780762 22094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T06:00:28.885473+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T05:00:00+00:00 PythonOperator 2021-04-28T06:00:09.191033+00:00 2021-04-28T06:00:12.230419+00:00 0:00:03.039386 22093 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T06:00:06.827796+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T04:00:00+00:00 EmrJobFlowSensor 2021-04-28T05:13:24.981079+00:00 2021-04-28T05:22:27.502880+00:00 0:09:02.521801 22091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T05:13:22.745945+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T04:00:00+00:00 EmrJobFlowSensor 2021-04-28T05:12:22.981893+00:00 2021-04-28T05:21:25.737651+00:00 0:09:02.755758 22090 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T05:12:20.692246+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T05:12:06.961728+00:00 2021-04-28T05:12:08.719134+00:00 0:00:01.757406 22089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T05:12:04.742481+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T05:12:02.941993+00:00 2021-04-28T05:12:04.761500+00:00 0:00:01.819507 22088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T05:12:00.672848+00:00 2 default_pool