Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 check_cluster_status 2021-03-31T19:05:00+00:00 EmrJobFlowSensor 2021-03-31T20:06:06.728041+00:00 2021-03-31T20:14:09.230153+00:00 0:08:02.502112 12154 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T20:06:04.531107+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T19:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T20:05:46.713067+00:00 2021-03-31T20:05:48.438350+00:00 0:00:01.725283 12153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T20:05:44.502133+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T19:05:00+00:00 PythonOperator 2021-03-31T20:05:24.607329+00:00 2021-03-31T20:05:27.297512+00:00 0:00:02.690183 12152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T20:05:22.456175+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T19:00:00+00:00 EmrJobFlowSensor 2021-03-31T20:00:58.387977+00:00 2021-03-31T20:10:01.083064+00:00 0:09:02.695087 12151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T20:00:56.106351+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T20:00:36.270580+00:00 2021-03-31T20:00:37.993227+00:00 0:00:01.722647 12150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T20:00:34.085658+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T19:00:00+00:00 PythonOperator 2021-03-31T20:00:14.559722+00:00 2021-03-31T20:00:17.276349+00:00 0:00:02.716627 12149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T20:00:12.030174+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T18:00:00+00:00 EmrJobFlowSensor 2021-03-31T19:12:23.249733+00:00 2021-03-31T19:21:25.986833+00:00 0:09:02.737100 12147 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T19:12:20.816487+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T18:00:00+00:00 EmrJobFlowSensor 2021-03-31T19:12:13.023144+00:00 2021-03-31T19:23:15.906274+00:00 0:11:02.883130 12146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T19:12:10.808321+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T19:12:01.469986+00:00 2021-03-31T19:12:03.315032+00:00 0:00:01.845046 12145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T19:11:58.954107+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T19:11:51.015303+00:00 2021-03-31T19:11:52.815613+00:00 0:00:01.800310 12144 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T19:11:48.787651+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T18:00:00+00:00 PythonOperator 2021-03-31T19:11:39.282917+00:00 2021-03-31T19:11:42.047124+00:00 0:00:02.764207 12143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T19:11:36.768202+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T18:00:00+00:00 PythonOperator 2021-03-31T19:11:29.012567+00:00 2021-03-31T19:11:31.961341+00:00 0:00:02.948774 12142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T19:11:26.729705+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T18:00:00+00:00 TriggerDagRunOperator 2021-03-31T19:11:15.270380+00:00 2021-03-31T19:11:15.817800+00:00 0:00:00.547420 12141 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T19:11:12.779686+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T18:00:00+00:00 TriggerDagRunOperator 2021-03-31T19:11:15.099605+00:00 2021-03-31T19:11:15.597340+00:00 0:00:00.497735 12140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T19:11:12.779653+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T18:05:00+00:00 EmrJobFlowSensor 2021-03-31T19:05:48.546549+00:00 2021-03-31T19:14:51.222462+00:00 0:09:02.675913 12139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T19:05:46.197262+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T18:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T19:05:28.369558+00:00 2021-03-31T19:05:30.032143+00:00 0:00:01.662585 12138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T19:05:26.170160+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T18:05:00+00:00 PythonOperator 2021-03-31T19:05:06.409059+00:00 2021-03-31T19:05:09.209503+00:00 0:00:02.800444 12137 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T19:05:04.154741+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T18:00:00+00:00 EmrJobFlowSensor 2021-03-31T19:01:08.180643+00:00 2021-03-31T19:11:10.901757+00:00 0:10:02.721114 12136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T19:01:05.891890+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T19:00:46.097055+00:00 2021-03-31T19:00:47.835019+00:00 0:00:01.737964 12135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T19:00:43.823206+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T18:00:00+00:00 PythonOperator 2021-03-31T19:00:12.206489+00:00 2021-03-31T19:00:15.036559+00:00 0:00:02.830070 12134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T19:00:09.792104+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T17:00:00+00:00 EmrJobFlowSensor 2021-03-31T18:11:12.136212+00:00 2021-03-31T18:19:14.804396+00:00 0:08:02.668184 12132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T18:11:09.908665+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T17:00:00+00:00 EmrJobFlowSensor 2021-03-31T18:11:10.204665+00:00 2021-03-31T18:21:13.060333+00:00 0:10:02.855668 12131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T18:11:07.968561+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T18:10:52.107276+00:00 2021-03-31T18:10:54.000523+00:00 0:00:01.893247 12130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T18:10:49.890779+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T18:10:48.323645+00:00 2021-03-31T18:10:50.138299+00:00 0:00:01.814654 12129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T18:10:45.890534+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T17:00:00+00:00 PythonOperator 2021-03-31T18:10:30.612257+00:00 2021-03-31T18:10:33.295820+00:00 0:00:02.683563 12128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T18:10:27.874421+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T17:00:00+00:00 PythonOperator 2021-03-31T18:10:28.163135+00:00 2021-03-31T18:10:31.623995+00:00 0:00:03.460860 12127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T18:10:25.862265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T17:00:00+00:00 TriggerDagRunOperator 2021-03-31T18:10:20.314556+00:00 2021-03-31T18:10:20.830483+00:00 0:00:00.515927 12126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T18:10:17.854863+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T17:00:00+00:00 TriggerDagRunOperator 2021-03-31T18:10:20.090964+00:00 2021-03-31T18:10:20.532889+00:00 0:00:00.441925 12125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T18:10:17.854891+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T17:05:00+00:00 EmrJobFlowSensor 2021-03-31T18:06:01.729452+00:00 2021-03-31T18:15:04.395545+00:00 0:09:02.666093 12124 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T18:05:59.463964+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T17:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T18:05:39.953482+00:00 2021-03-31T18:05:41.681347+00:00 0:00:01.727865 12123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T18:05:37.473957+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T17:05:00+00:00 PythonOperator 2021-03-31T18:05:19.900015+00:00 2021-03-31T18:05:22.681908+00:00 0:00:02.781893 12122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T18:05:17.367530+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T17:00:00+00:00 EmrJobFlowSensor 2021-03-31T18:01:03.308097+00:00 2021-03-31T18:10:06.205754+00:00 0:09:02.897657 12121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T18:01:00.943961+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T18:00:43.267585+00:00 2021-03-31T18:00:45.161177+00:00 0:00:01.893592 12120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T18:00:40.882981+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T17:00:00+00:00 PythonOperator 2021-03-31T18:00:21.123111+00:00 2021-03-31T18:00:23.923941+00:00 0:00:02.800830 12119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T18:00:18.855348+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T16:00:00+00:00 EmrJobFlowSensor 2021-03-31T17:28:28.186702+00:00 2021-03-31T17:49:32.578958+00:00 0:21:04.392256 12117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T17:28:25.754993+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T16:00:00+00:00 EmrJobFlowSensor 2021-03-31T17:28:14.027377+00:00 2021-03-31T17:38:16.800182+00:00 0:10:02.772805 12116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T17:28:11.688356+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T17:28:08.041105+00:00 2021-03-31T17:28:09.726191+00:00 0:00:01.685086 12115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T17:28:05.760256+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T17:27:54.173184+00:00 2021-03-31T17:27:56.079110+00:00 0:00:01.905926 12114 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T17:27:51.615387+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T16:00:00+00:00 PythonOperator 2021-03-31T17:27:45.998778+00:00 2021-03-31T17:27:48.858337+00:00 0:00:02.859559 12113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T17:27:43.678271+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T16:00:00+00:00 PythonOperator 2021-03-31T17:27:31.998738+00:00 2021-03-31T17:27:34.934511+00:00 0:00:02.935773 12112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T17:27:29.656258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T16:00:00+00:00 TriggerDagRunOperator 2021-03-31T17:27:26.299460+00:00 2021-03-31T17:27:26.892042+00:00 0:00:00.592582 12111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T17:27:23.674683+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T16:00:00+00:00 TriggerDagRunOperator 2021-03-31T17:27:26.092994+00:00 2021-03-31T17:27:26.527585+00:00 0:00:00.434591 12110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T17:27:23.674713+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T16:05:00+00:00 EmrJobFlowSensor 2021-03-31T17:05:57.595923+00:00 2021-03-31T17:15:00.111010+00:00 0:09:02.515087 12109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T17:05:55.346016+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T16:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T17:05:35.698156+00:00 2021-03-31T17:05:37.325995+00:00 0:00:01.627839 12108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T17:05:33.360572+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T16:05:00+00:00 PythonOperator 2021-03-31T17:05:15.660973+00:00 2021-03-31T17:05:18.343026+00:00 0:00:02.682053 12107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T17:05:13.356625+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T16:00:00+00:00 EmrJobFlowSensor 2021-03-31T17:01:05.385901+00:00 2021-03-31T17:27:10.399493+00:00 0:26:05.013592 12106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T17:01:02.843724+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T17:00:43.086545+00:00 2021-03-31T17:00:44.880048+00:00 0:00:01.793503 12105 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T17:00:40.721080+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T16:00:00+00:00 PythonOperator 2021-03-31T17:00:21.009753+00:00 2021-03-31T17:00:23.738203+00:00 0:00:02.728450 12104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T17:00:18.701915+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T15:00:00+00:00 EmrJobFlowSensor 2021-03-31T16:12:38.115493+00:00 2021-03-31T16:21:40.729656+00:00 0:09:02.614163 12102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T16:12:35.887860+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T15:00:00+00:00 EmrJobFlowSensor 2021-03-31T16:12:36.340393+00:00 2021-03-31T16:21:39.073701+00:00 0:09:02.733308 12101 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T16:12:33.950679+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T16:12:18.479967+00:00 2021-03-31T16:12:20.199808+00:00 0:00:01.719841 12100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T16:12:15.841626+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T16:12:16.148569+00:00 2021-03-31T16:12:18.188641+00:00 0:00:02.040072 12099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T16:12:13.844836+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T15:00:00+00:00 PythonOperator 2021-03-31T16:11:55.995026+00:00 2021-03-31T16:11:58.913528+00:00 0:00:02.918502 12098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T16:11:53.824418+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T15:00:00+00:00 PythonOperator 2021-03-31T16:11:54.326247+00:00 2021-03-31T16:11:57.161975+00:00 0:00:02.835728 12097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T16:11:51.821642+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T15:00:00+00:00 TriggerDagRunOperator 2021-03-31T16:11:34.282893+00:00 2021-03-31T16:11:34.847819+00:00 0:00:00.564926 12096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T16:11:31.808785+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T15:00:00+00:00 TriggerDagRunOperator 2021-03-31T16:11:34.114341+00:00 2021-03-31T16:11:34.553736+00:00 0:00:00.439395 12095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T16:11:31.808751+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T15:05:00+00:00 EmrJobFlowSensor 2021-03-31T16:05:59.755508+00:00 2021-03-31T16:15:02.422538+00:00 0:09:02.667030 12094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T16:05:57.367229+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T15:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T16:05:37.579070+00:00 2021-03-31T16:05:39.233578+00:00 0:00:01.654508 12093 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T16:05:35.355808+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T15:05:00+00:00 PythonOperator 2021-03-31T16:05:17.522758+00:00 2021-03-31T16:05:20.202522+00:00 0:00:02.679764 12092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T16:05:15.258605+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T15:00:00+00:00 EmrJobFlowSensor 2021-03-31T16:01:05.245598+00:00 2021-03-31T16:11:08.242769+00:00 0:10:02.997171 12091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T16:01:02.776896+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T16:00:42.962069+00:00 2021-03-31T16:00:44.661942+00:00 0:00:01.699873 12090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T16:00:40.692623+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T15:00:00+00:00 PythonOperator 2021-03-31T16:00:21.066791+00:00 2021-03-31T16:00:23.899277+00:00 0:00:02.832486 12089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T16:00:18.658098+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T14:00:00+00:00 EmrJobFlowSensor 2021-03-31T15:11:19.947722+00:00 2021-03-31T15:21:22.874149+00:00 0:10:02.926427 12087 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T15:11:17.405288+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T14:00:00+00:00 EmrJobFlowSensor 2021-03-31T15:11:17.610253+00:00 2021-03-31T15:20:20.278291+00:00 0:09:02.668038 12086 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T15:11:15.402042+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T15:10:57.669123+00:00 2021-03-31T15:10:59.495670+00:00 0:00:01.826547 12085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T15:10:55.382725+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T15:10:55.796892+00:00 2021-03-31T15:10:57.524311+00:00 0:00:01.727419 12084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T15:10:53.452173+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T14:00:00+00:00 PythonOperator 2021-03-31T15:10:35.699687+00:00 2021-03-31T15:10:38.870549+00:00 0:00:03.170862 12083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T15:10:33.307823+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T14:00:00+00:00 PythonOperator 2021-03-31T15:10:34.123791+00:00 2021-03-31T15:10:36.860836+00:00 0:00:02.737045 12082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T15:10:31.376563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T14:00:00+00:00 TriggerDagRunOperator 2021-03-31T15:10:21.662035+00:00 2021-03-31T15:10:22.170090+00:00 0:00:00.508055 12081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T15:10:19.300786+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T14:00:00+00:00 TriggerDagRunOperator 2021-03-31T15:10:21.586567+00:00 2021-03-31T15:10:22.022006+00:00 0:00:00.435439 12080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T15:10:19.300837+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T14:05:00+00:00 EmrJobFlowSensor 2021-03-31T15:06:03.078849+00:00 2021-03-31T15:16:05.855982+00:00 0:10:02.777133 12079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T15:06:00.913448+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T14:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T15:05:43.107104+00:00 2021-03-31T15:05:44.718020+00:00 0:00:01.610916 12078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T15:05:40.892500+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T14:05:00+00:00 PythonOperator 2021-03-31T15:05:20.961155+00:00 2021-03-31T15:05:23.726946+00:00 0:00:02.765791 12077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T15:05:18.828593+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T14:00:00+00:00 EmrJobFlowSensor 2021-03-31T15:01:04.618463+00:00 2021-03-31T15:10:07.308529+00:00 0:09:02.690066 12076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T15:01:02.391575+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T15:00:42.522598+00:00 2021-03-31T15:00:44.237748+00:00 0:00:01.715150 12075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T15:00:40.325384+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T14:00:00+00:00 PythonOperator 2021-03-31T15:00:20.517336+00:00 2021-03-31T15:00:23.269520+00:00 0:00:02.752184 12074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T15:00:18.305420+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T13:00:00+00:00 EmrJobFlowSensor 2021-03-31T14:18:40.811623+00:00 2021-03-31T14:28:43.642258+00:00 0:10:02.830635 12073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T14:18:38.509253+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T13:00:00+00:00 EmrJobFlowSensor 2021-03-31T14:18:34.903235+00:00 2021-03-31T14:27:37.555629+00:00 0:09:02.652394 12072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T14:18:32.559259+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T14:18:20.602518+00:00 2021-03-31T14:18:22.315915+00:00 0:00:01.713397 12071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T14:18:18.439061+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T14:18:06.792781+00:00 2021-03-31T14:18:08.575363+00:00 0:00:01.782582 12070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T14:18:04.416616+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T13:00:00+00:00 PythonOperator 2021-03-31T14:17:52.667832+00:00 2021-03-31T14:17:55.410590+00:00 0:00:02.742758 12069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T14:17:50.404177+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T13:00:00+00:00 PythonOperator 2021-03-31T14:17:44.715179+00:00 2021-03-31T14:17:47.865469+00:00 0:00:03.150290 12068 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T14:17:42.397710+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T13:00:00+00:00 TriggerDagRunOperator 2021-03-31T14:17:34.934192+00:00 2021-03-31T14:17:35.481378+00:00 0:00:00.547186 12067 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T14:17:32.404366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T13:00:00+00:00 TriggerDagRunOperator 2021-03-31T14:17:34.807514+00:00 2021-03-31T14:17:35.250163+00:00 0:00:00.442649 12066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T14:17:32.404335+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T13:05:00+00:00 EmrJobFlowSensor 2021-03-31T14:06:03.996064+00:00 2021-03-31T14:15:06.583548+00:00 0:09:02.587484 12064 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T14:06:01.716885+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T13:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T14:05:41.998415+00:00 2021-03-31T14:05:43.849091+00:00 0:00:01.850676 12063 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T14:05:39.675618+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T13:05:00+00:00 PythonOperator 2021-03-31T14:05:20.075749+00:00 2021-03-31T14:05:22.837395+00:00 0:00:02.761646 12062 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T14:05:17.646474+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T13:00:00+00:00 EmrJobFlowSensor 2021-03-31T14:00:55.304952+00:00 2021-03-31T14:10:58.144259+00:00 0:10:02.839307 12061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T14:00:53.094295+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T14:00:35.244500+00:00 2021-03-31T14:00:36.974174+00:00 0:00:01.729674 12060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T14:00:33.060922+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T13:00:00+00:00 PythonOperator 2021-03-31T14:00:13.248581+00:00 2021-03-31T14:00:16.004005+00:00 0:00:02.755424 12059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T14:00:11.046014+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T12:00:00+00:00 EmrJobFlowSensor 2021-03-31T13:12:34.785949+00:00 2021-03-31T13:20:37.329401+00:00 0:08:02.543452 12058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T13:12:32.400920+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T12:00:00+00:00 EmrJobFlowSensor 2021-03-31T13:12:22.662187+00:00 2021-03-31T13:22:25.531334+00:00 0:10:02.869147 12057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T13:12:20.388381+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T13:12:12.935375+00:00 2021-03-31T13:12:14.682029+00:00 0:00:01.746654 12056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T13:12:10.353894+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T13:12:00.733208+00:00 2021-03-31T13:12:02.624208+00:00 0:00:01.891000 12055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T13:11:58.289953+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T12:00:00+00:00 PythonOperator 2021-03-31T13:11:52.744409+00:00 2021-03-31T13:11:55.549045+00:00 0:00:02.804636 12054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T13:11:50.344308+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T12:00:00+00:00 PythonOperator 2021-03-31T13:11:38.649211+00:00 2021-03-31T13:11:41.587408+00:00 0:00:02.938197 12053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T13:11:36.271817+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T12:00:00+00:00 TriggerDagRunOperator 2021-03-31T13:11:33.174975+00:00 2021-03-31T13:11:33.740574+00:00 0:00:00.565599 12052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T13:11:30.077872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T12:00:00+00:00 TriggerDagRunOperator 2021-03-31T13:11:33.102520+00:00 2021-03-31T13:11:33.615403+00:00 0:00:00.512883 12051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T13:11:30.077829+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T12:05:00+00:00 EmrJobFlowSensor 2021-03-31T13:06:06.828385+00:00 2021-03-31T13:15:09.451783+00:00 0:09:02.623398 12049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T13:06:04.555200+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T12:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T13:05:44.665941+00:00 2021-03-31T13:05:46.300659+00:00 0:00:01.634718 12048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T13:05:42.538743+00:00 2 default_pool