Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 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
success booking-processing-job_v002 create_emr_steps 2021-03-25T12:00:00+00:00 PythonOperator 2021-03-25T13:10:07.120662+00:00 2021-03-25T13:10:10.204114+00:00 0:00:03.083452 11588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T13:10:04.887058+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T12:00:00+00:00 TriggerDagRunOperator 2021-03-25T13:09:59.280814+00:00 2021-03-25T13:09:59.761641+00:00 0:00:00.480827 11587 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T13:09:56.834747+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T12:00:00+00:00 TriggerDagRunOperator 2021-03-25T13:09:59.014946+00:00 2021-03-25T13:09:59.409575+00:00 0:00:00.394629 11586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T13:09:56.834712+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T12:05:00+00:00 EmrJobFlowSensor 2021-03-25T13:06:12.771326+00:00 2021-03-25T13:15:15.352545+00:00 0:09:02.581219 11585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T13:06:10.558813+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T12:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T13:05:50.648983+00:00 2021-03-25T13:05:52.326921+00:00 0:00:01.677938 11584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T13:05:48.487806+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T12:05:00+00:00 PythonOperator 2021-03-25T13:05:22.609095+00:00 2021-03-25T13:05:25.383073+00:00 0:00:02.773978 11583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T13:05:20.399786+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T12:00:00+00:00 EmrJobFlowSensor 2021-03-25T13:00:48.150688+00:00 2021-03-25T13:09:50.616439+00:00 0:09:02.465751 11582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T13:00:45.915974+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T13:00:26.093977+00:00 2021-03-25T13:00:27.772358+00:00 0:00:01.678381 11581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T13:00:23.910778+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T12:00:00+00:00 PythonOperator 2021-03-25T13:00:04.173339+00:00 2021-03-25T13:00:07.011119+00:00 0:00:02.837780 11580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T13:00:01.853649+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T11:00:00+00:00 EmrJobFlowSensor 2021-03-25T12:10:59.529259+00:00 2021-03-25T12:21:02.389943+00:00 0:10:02.860684 11578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T12:10:57.322572+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T12:10:39.684144+00:00 2021-03-25T12:10:41.497592+00:00 0:00:01.813448 11577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T12:10:37.303264+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T11:00:00+00:00 PythonOperator 2021-03-25T12:10:17.426373+00:00 2021-03-25T12:10:20.379799+00:00 0:00:02.953426 11576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T12:10:15.267065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T11:00:00+00:00 TriggerDagRunOperator 2021-03-25T12:10:07.618661+00:00 2021-03-25T12:10:08.112012+00:00 0:00:00.493351 11575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T12:10:05.271365+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T11:00:00+00:00 TriggerDagRunOperator 2021-03-25T12:10:07.447815+00:00 2021-03-25T12:10:07.862438+00:00 0:00:00.414623 11574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T12:10:05.271336+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T11:05:00+00:00 EmrJobFlowSensor 2021-03-25T12:05:59.490668+00:00 2021-03-25T12:15:02.185559+00:00 0:09:02.694891 11573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T12:05:57.057027+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T11:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T12:05:39.270973+00:00 2021-03-25T12:05:40.978771+00:00 0:00:01.707798 11572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T12:05:37.059884+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T11:05:00+00:00 PythonOperator 2021-03-25T12:05:17.168089+00:00 2021-03-25T12:05:19.905965+00:00 0:00:02.737876 11571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T12:05:14.949284+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T11:00:00+00:00 EmrJobFlowSensor 2021-03-25T12:00:48.756839+00:00 2021-03-25T12:09:51.534244+00:00 0:09:02.777405 11570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T12:00:46.489889+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T12:00:28.708215+00:00 2021-03-25T12:00:30.386645+00:00 0:00:01.678430 11569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T12:00:26.476695+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T11:00:00+00:00 PythonOperator 2021-03-25T12:00:06.968765+00:00 2021-03-25T12:00:09.803555+00:00 0:00:02.834790 11568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T12:00:04.456599+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T10:00:00+00:00 EmrJobFlowSensor 2021-03-25T11:11:22.140035+00:00 2021-03-25T11:23:25.467449+00:00 0:12:03.327414 11566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T11:11:19.825863+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T11:10:57.927980+00:00 2021-03-25T11:10:59.652264+00:00 0:00:01.724284 11565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T11:10:55.807055+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T10:00:00+00:00 PythonOperator 2021-03-25T11:10:33.989354+00:00 2021-03-25T11:10:37.005037+00:00 0:00:03.015683 11564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T11:10:31.784390+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T10:00:00+00:00 TriggerDagRunOperator 2021-03-25T11:10:16.287265+00:00 2021-03-25T11:10:16.682551+00:00 0:00:00.395286 11563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T11:10:13.755599+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T10:00:00+00:00 TriggerDagRunOperator 2021-03-25T11:10:16.106581+00:00 2021-03-25T11:10:16.645382+00:00 0:00:00.538801 11562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T11:10:13.755563+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T10:05:00+00:00 EmrJobFlowSensor 2021-03-25T11:06:11.492642+00:00 2021-03-25T11:15:14.042566+00:00 0:09:02.549924 11561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T11:06:09.322730+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T10:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T11:05:51.401517+00:00 2021-03-25T11:05:53.038665+00:00 0:00:01.637148 11560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T11:05:49.302708+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T10:05:00+00:00 PythonOperator 2021-03-25T11:05:29.763091+00:00 2021-03-25T11:05:32.540523+00:00 0:00:02.777432 11559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T11:05:27.363098+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T10:00:00+00:00 EmrJobFlowSensor 2021-03-25T11:01:06.911797+00:00 2021-03-25T11:10:09.630949+00:00 0:09:02.719152 11558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T11:01:04.787406+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T11:00:45.084282+00:00 2021-03-25T11:00:46.958361+00:00 0:00:01.874079 11557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T11:00:42.759571+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T10:00:00+00:00 PythonOperator 2021-03-25T11:00:23.381369+00:00 2021-03-25T11:00:26.507716+00:00 0:00:03.126347 11556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T11:00:20.766644+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T09:00:00+00:00 EmrJobFlowSensor 2021-03-25T10:12:16.331679+00:00 2021-03-25T10:22:19.208439+00:00 0:10:02.876760 11554 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T10:12:14.040541+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T10:11:56.411907+00:00 2021-03-25T10:11:58.228203+00:00 0:00:01.816296 11553 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T10:11:54.016300+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T09:00:00+00:00 PythonOperator 2021-03-25T10:11:34.208313+00:00 2021-03-25T10:11:37.189018+00:00 0:00:02.980705 11552 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T10:11:31.993894+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T09:00:00+00:00 TriggerDagRunOperator 2021-03-25T10:11:16.247751+00:00 2021-03-25T10:11:16.667547+00:00 0:00:00.419796 11551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T10:11:13.945140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T09:00:00+00:00 TriggerDagRunOperator 2021-03-25T10:11:16.210494+00:00 2021-03-25T10:11:16.740736+00:00 0:00:00.530242 11550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T10:11:13.945105+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T09:05:00+00:00 EmrJobFlowSensor 2021-03-25T10:05:57.695956+00:00 2021-03-25T10:15:00.290047+00:00 0:09:02.594091 11549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T10:05:55.503806+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T09:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T10:05:37.645200+00:00 2021-03-25T10:05:39.235434+00:00 0:00:01.590234 11548 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T10:05:35.435810+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T09:05:00+00:00 PythonOperator 2021-03-25T10:05:15.628017+00:00 2021-03-25T10:05:18.402718+00:00 0:00:02.774701 11547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T10:05:13.381891+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T09:00:00+00:00 EmrJobFlowSensor 2021-03-25T10:01:05.072783+00:00 2021-03-25T10:11:07.937862+00:00 0:10:02.865079 11546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T10:01:02.912807+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T10:00:43.130032+00:00 2021-03-25T10:00:44.955749+00:00 0:00:01.825717 11545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T10:00:40.891037+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T09:00:00+00:00 PythonOperator 2021-03-25T10:00:21.502964+00:00 2021-03-25T10:00:24.233654+00:00 0:00:02.730690 11544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T10:00:18.872932+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T08:00:00+00:00 EmrJobFlowSensor 2021-03-25T09:11:18.004302+00:00 2021-03-25T09:21:20.890605+00:00 0:10:02.886303 11542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T09:11:15.791973+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T09:10:56.212813+00:00 2021-03-25T09:10:57.932868+00:00 0:00:01.720055 11541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T09:10:53.859376+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T08:00:00+00:00 PythonOperator 2021-03-25T09:10:34.207141+00:00 2021-03-25T09:10:37.252826+00:00 0:00:03.045685 11540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T09:10:31.741019+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T08:00:00+00:00 TriggerDagRunOperator 2021-03-25T09:10:08.177839+00:00 2021-03-25T09:10:08.673844+00:00 0:00:00.496005 11539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T09:10:05.653010+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T08:00:00+00:00 TriggerDagRunOperator 2021-03-25T09:10:08.135616+00:00 2021-03-25T09:10:08.686148+00:00 0:00:00.550532 11538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T09:10:05.653052+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T08:05:00+00:00 EmrJobFlowSensor 2021-03-25T09:05:55.459749+00:00 2021-03-25T09:13:57.864578+00:00 0:08:02.404829 11537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T09:05:53.279889+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T08:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T09:05:33.570395+00:00 2021-03-25T09:05:35.212530+00:00 0:00:01.642135 11536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T09:05:31.262284+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T08:05:00+00:00 PythonOperator 2021-03-25T09:05:11.365474+00:00 2021-03-25T09:05:14.071324+00:00 0:00:02.705850 11535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T09:05:09.244976+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T08:00:00+00:00 EmrJobFlowSensor 2021-03-25T09:00:58.843655+00:00 2021-03-25T09:10:01.519494+00:00 0:09:02.675839 11534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T09:00:56.631968+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T09:00:38.916993+00:00 2021-03-25T09:00:40.590359+00:00 0:00:01.673366 11533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T09:00:36.611991+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T08:00:00+00:00 PythonOperator 2021-03-25T09:00:17.273525+00:00 2021-03-25T09:00:20.031495+00:00 0:00:02.757970 11532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T09:00:14.662881+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T07:00:00+00:00 EmrJobFlowSensor 2021-03-25T08:11:57.595976+00:00 2021-03-25T08:23:00.486939+00:00 0:11:02.890963 11530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T08:11:55.420996+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T08:11:35.780488+00:00 2021-03-25T08:11:37.503443+00:00 0:00:01.722955 11529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T08:11:33.469494+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T07:00:00+00:00 PythonOperator 2021-03-25T08:11:13.681135+00:00 2021-03-25T08:11:16.745198+00:00 0:00:03.064063 11528 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T08:11:11.384693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T07:00:00+00:00 TriggerDagRunOperator 2021-03-25T08:10:57.673105+00:00 2021-03-25T08:10:58.067104+00:00 0:00:00.393999 11527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T08:10:55.324353+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T07:00:00+00:00 TriggerDagRunOperator 2021-03-25T08:10:57.626414+00:00 2021-03-25T08:10:58.127822+00:00 0:00:00.501408 11526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T08:10:55.324324+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T07:05:00+00:00 EmrJobFlowSensor 2021-03-25T08:06:04.963748+00:00 2021-03-25T08:14:07.384910+00:00 0:08:02.421162 11525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T08:06:02.775165+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T07:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T08:05:43.083748+00:00 2021-03-25T08:05:44.758121+00:00 0:00:01.674373 11524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T08:05:40.718616+00:00 2 default_pool