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-04-17T05:05:00+00:00 EmrJobFlowSensor 2021-04-17T06:14:20.362498+00:00 2021-04-17T06:23:23.133433+00:00 0:09:02.770935 18087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T06:14:18.072180+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T06:14:00.716619+00:00 2021-04-17T06:14:02.505762+00:00 0:00:01.789143 18086 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T06:13:58.160861+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T06:13:58.163354+00:00 2021-04-17T06:13:59.793882+00:00 0:00:01.630528 18085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T06:13:55.988034+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T05:00:00+00:00 PythonOperator 2021-04-17T06:13:40.246069+00:00 2021-04-17T06:13:43.212536+00:00 0:00:02.966467 18084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T06:13:37.976030+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T05:05:00+00:00 PythonOperator 2021-04-17T06:13:36.490390+00:00 2021-04-17T06:13:39.416369+00:00 0:00:02.925979 18083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T06:13:33.985671+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T04:00:00+00:00 EmrJobFlowSensor 2021-04-17T05:13:22.679280+00:00 2021-04-17T05:21:25.375556+00:00 0:08:02.696276 18081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T05:13:20.288231+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T04:00:00+00:00 EmrJobFlowSensor 2021-04-17T05:13:16.500539+00:00 2021-04-17T05:23:19.476859+00:00 0:10:02.976320 18080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T05:13:14.233292+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T05:12:53.221098+00:00 2021-04-17T05:12:54.909514+00:00 0:00:01.688416 18079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T05:12:50.220307+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T05:12:50.525101+00:00 2021-04-17T05:12:52.648487+00:00 0:00:02.123386 18078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T05:12:48.215356+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T04:00:00+00:00 PythonOperator 2021-04-17T05:12:28.592617+00:00 2021-04-17T05:12:32.236037+00:00 0:00:03.643420 18077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T05:12:26.195734+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T04:00:00+00:00 PythonOperator 2021-04-17T05:12:28.513410+00:00 2021-04-17T05:12:31.734582+00:00 0:00:03.221172 18076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T05:12:26.195699+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T04:00:00+00:00 TriggerDagRunOperator 2021-04-17T05:12:04.512349+00:00 2021-04-17T05:12:05.296122+00:00 0:00:00.783773 18075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T05:12:02.167440+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T04:00:00+00:00 TriggerDagRunOperator 2021-04-17T05:12:04.490122+00:00 2021-04-17T05:12:05.400350+00:00 0:00:00.910228 18074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T05:12:02.167406+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T04:05:00+00:00 EmrJobFlowSensor 2021-04-17T05:06:00.559533+00:00 2021-04-17T05:16:03.380723+00:00 0:10:02.821190 18073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T05:05:57.750807+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T05:05:37.875041+00:00 2021-04-17T05:05:39.570027+00:00 0:00:01.694986 18072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T05:05:35.692195+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T04:05:00+00:00 PythonOperator 2021-04-17T05:05:15.972771+00:00 2021-04-17T05:05:18.882061+00:00 0:00:02.909290 18071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T05:05:13.660849+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T04:00:00+00:00 EmrJobFlowSensor 2021-04-17T05:00:47.562785+00:00 2021-04-17T05:11:50.429473+00:00 0:11:02.866688 18070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T05:00:45.254909+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T05:00:27.307109+00:00 2021-04-17T05:00:29.013557+00:00 0:00:01.706448 18069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T05:00:25.109637+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T04:00:00+00:00 PythonOperator 2021-04-17T05:00:05.776643+00:00 2021-04-17T05:00:08.750250+00:00 0:00:02.973607 18068 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T05:00:03.086064+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T03:00:00+00:00 EmrJobFlowSensor 2021-04-17T04:11:40.791424+00:00 2021-04-17T04:21:43.580766+00:00 0:10:02.789342 18066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T04:11:38.086790+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T03:00:00+00:00 EmrJobFlowSensor 2021-04-17T04:11:38.327605+00:00 2021-04-17T04:20:41.314341+00:00 0:09:02.986736 18065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T04:11:36.088869+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T04:11:20.190485+00:00 2021-04-17T04:11:21.962443+00:00 0:00:01.771958 18064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T04:11:18.031137+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T04:11:16.389964+00:00 2021-04-17T04:11:18.084143+00:00 0:00:01.694179 18063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T04:11:14.157881+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T03:00:00+00:00 PythonOperator 2021-04-17T04:10:58.720359+00:00 2021-04-17T04:11:02.110643+00:00 0:00:03.390284 18062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T04:10:56.068898+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T03:00:00+00:00 PythonOperator 2021-04-17T04:10:54.657712+00:00 2021-04-17T04:10:57.758994+00:00 0:00:03.101282 18061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T04:10:52.060882+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T03:00:00+00:00 TriggerDagRunOperator 2021-04-17T04:10:46.379265+00:00 2021-04-17T04:10:46.893144+00:00 0:00:00.513879 18060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T04:10:43.992123+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T03:00:00+00:00 TriggerDagRunOperator 2021-04-17T04:10:46.180663+00:00 2021-04-17T04:10:46.590625+00:00 0:00:00.409962 18059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T04:10:43.992093+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T03:05:00+00:00 EmrJobFlowSensor 2021-04-17T04:06:01.967656+00:00 2021-04-17T04:15:04.714296+00:00 0:09:02.746640 18058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T04:05:59.648932+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T04:05:39.747979+00:00 2021-04-17T04:05:41.466515+00:00 0:00:01.718536 18057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T04:05:37.554594+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T03:05:00+00:00 PythonOperator 2021-04-17T04:05:19.870477+00:00 2021-04-17T04:05:22.953845+00:00 0:00:03.083368 18056 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T04:05:17.538916+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T03:00:00+00:00 EmrJobFlowSensor 2021-04-17T04:00:59.408309+00:00 2021-04-17T04:10:02.131409+00:00 0:09:02.723100 18055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T04:00:57.204879+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T04:00:39.370412+00:00 2021-04-17T04:00:41.075990+00:00 0:00:01.705578 18054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T04:00:37.186459+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T03:00:00+00:00 PythonOperator 2021-04-17T04:00:13.544242+00:00 2021-04-17T04:00:16.584886+00:00 0:00:03.040644 18053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T04:00:11.084329+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T02:00:00+00:00 EmrJobFlowSensor 2021-04-17T03:10:23.189512+00:00 2021-04-17T03:20:25.793523+00:00 0:10:02.604011 18051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T03:10:21.013621+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T02:00:00+00:00 EmrJobFlowSensor 2021-04-17T03:10:11.458306+00:00 2021-04-17T03:19:14.159200+00:00 0:09:02.700894 18050 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T03:10:09.057333+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T03:10:01.411754+00:00 2021-04-17T03:10:03.188797+00:00 0:00:01.777043 18049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T03:09:59.063720+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T03:09:51.505340+00:00 2021-04-17T03:09:53.314742+00:00 0:00:01.809402 18048 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T03:09:49.052146+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T02:00:00+00:00 PythonOperator 2021-04-17T03:09:39.091214+00:00 2021-04-17T03:09:42.171607+00:00 0:00:03.080393 18047 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T03:09:36.929340+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T02:00:00+00:00 PythonOperator 2021-04-17T03:09:29.305384+00:00 2021-04-17T03:09:32.227964+00:00 0:00:02.922580 18046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T03:09:26.923142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T02:00:00+00:00 TriggerDagRunOperator 2021-04-17T03:09:19.474683+00:00 2021-04-17T03:09:20.055520+00:00 0:00:00.580837 18045 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T03:09:16.914819+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T02:00:00+00:00 TriggerDagRunOperator 2021-04-17T03:09:19.362304+00:00 2021-04-17T03:09:19.784620+00:00 0:00:00.422316 18044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T03:09:16.914856+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T02:05:00+00:00 EmrJobFlowSensor 2021-04-17T03:06:09.587440+00:00 2021-04-17T03:15:12.184922+00:00 0:09:02.597482 18043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T03:06:07.175898+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T03:05:47.237752+00:00 2021-04-17T03:05:48.942411+00:00 0:00:01.704659 18042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T03:05:45.090761+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T02:05:00+00:00 PythonOperator 2021-04-17T03:05:23.177876+00:00 2021-04-17T03:05:26.262606+00:00 0:00:03.084730 18041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T03:05:21.047872+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T02:00:00+00:00 EmrJobFlowSensor 2021-04-17T03:01:09.660955+00:00 2021-04-17T03:09:12.131203+00:00 0:08:02.470248 18040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T03:01:06.615207+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T03:00:44.732258+00:00 2021-04-17T03:00:46.541628+00:00 0:00:01.809370 18039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T03:00:42.591357+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T02:00:00+00:00 PythonOperator 2021-04-17T03:00:23.158739+00:00 2021-04-17T03:00:26.048437+00:00 0:00:02.889698 18038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T03:00:20.583776+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T01:00:00+00:00 EmrJobFlowSensor 2021-04-17T02:12:29.340359+00:00 2021-04-17T02:21:31.982742+00:00 0:09:02.642383 18036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T02:12:27.109150+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T01:00:00+00:00 EmrJobFlowSensor 2021-04-17T02:12:27.839416+00:00 2021-04-17T02:21:30.563877+00:00 0:09:02.724461 18035 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T02:12:25.101930+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T02:12:07.570538+00:00 2021-04-17T02:12:09.384022+00:00 0:00:01.813484 18034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T02:12:05.153242+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T02:12:03.587421+00:00 2021-04-17T02:12:05.851196+00:00 0:00:02.263775 18033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T02:12:01.159915+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T01:00:00+00:00 PythonOperator 2021-04-17T02:11:45.891088+00:00 2021-04-17T02:11:48.967553+00:00 0:00:03.076465 18032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T02:11:43.075152+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T01:00:00+00:00 PythonOperator 2021-04-17T02:11:41.325895+00:00 2021-04-17T02:11:44.666928+00:00 0:00:03.341033 18031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T02:11:39.066042+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T01:00:00+00:00 TriggerDagRunOperator 2021-04-17T02:11:19.469474+00:00 2021-04-17T02:11:19.989096+00:00 0:00:00.519622 18030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T02:11:17.004247+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T01:00:00+00:00 TriggerDagRunOperator 2021-04-17T02:11:19.213969+00:00 2021-04-17T02:11:19.626006+00:00 0:00:00.412037 18029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T02:11:17.004280+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T01:05:00+00:00 EmrJobFlowSensor 2021-04-17T02:06:04.886250+00:00 2021-04-17T02:15:07.757761+00:00 0:09:02.871511 18028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T02:06:02.521646+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T02:05:42.702420+00:00 2021-04-17T02:05:44.341930+00:00 0:00:01.639510 18027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T02:05:40.500668+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T01:05:00+00:00 PythonOperator 2021-04-17T02:05:20.742586+00:00 2021-04-17T02:05:23.667894+00:00 0:00:02.925308 18026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T02:05:18.446144+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T01:00:00+00:00 EmrJobFlowSensor 2021-04-17T02:01:06.316656+00:00 2021-04-17T02:11:09.251917+00:00 0:10:02.935261 18025 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T02:01:03.970301+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T02:00:46.143793+00:00 2021-04-17T02:00:47.958733+00:00 0:00:01.814940 18024 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T02:00:43.896283+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T01:00:00+00:00 PythonOperator 2021-04-17T02:00:24.318562+00:00 2021-04-17T02:00:27.472801+00:00 0:00:03.154239 18023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T02:00:21.947599+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T00:00:00+00:00 EmrJobFlowSensor 2021-04-17T01:12:08.773799+00:00 2021-04-17T01:21:11.471716+00:00 0:09:02.697917 18021 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:12:06.245667+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T00:00:00+00:00 EmrJobFlowSensor 2021-04-17T01:12:06.474086+00:00 2021-04-17T01:22:09.121743+00:00 0:10:02.647657 18020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:12:04.271177+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T01:11:46.470839+00:00 2021-04-17T01:11:48.284660+00:00 0:00:01.813821 18019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T01:11:44.197949+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T01:11:46.389276+00:00 2021-04-17T01:11:48.075380+00:00 0:00:01.686104 18018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T01:11:44.197975+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T00:00:00+00:00 PythonOperator 2021-04-17T01:11:26.456425+00:00 2021-04-17T01:11:29.628377+00:00 0:00:03.171952 18017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T01:11:24.164982+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T00:00:00+00:00 PythonOperator 2021-04-17T01:11:24.514238+00:00 2021-04-17T01:11:27.429718+00:00 0:00:02.915480 18016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T01:11:22.163157+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T00:00:00+00:00 TriggerDagRunOperator 2021-04-17T01:11:07.174848+00:00 2021-04-17T01:11:07.764511+00:00 0:00:00.589663 18015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:11:04.263350+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T00:00:00+00:00 TriggerDagRunOperator 2021-04-17T01:11:06.686716+00:00 2021-04-17T01:11:07.095997+00:00 0:00:00.409281 18014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:11:04.263308+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T00:05:00+00:00 EmrJobFlowSensor 2021-04-17T01:05:57.704836+00:00 2021-04-17T01:15:00.303047+00:00 0:09:02.598211 18013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:05:55.567487+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T01:05:35.800031+00:00 2021-04-17T01:05:37.892268+00:00 0:00:02.092237 18012 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T01:05:33.547898+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T00:05:00+00:00 PythonOperator 2021-04-17T01:05:13.781296+00:00 2021-04-17T01:05:16.741910+00:00 0:00:02.960614 18011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T01:05:11.530935+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T00:00:00+00:00 EmrJobFlowSensor 2021-04-17T01:00:53.306866+00:00 2021-04-17T01:10:56.213570+00:00 0:10:02.906704 18010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T01:00:51.062426+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T01:00:33.812782+00:00 2021-04-17T01:00:35.582141+00:00 0:00:01.769359 18009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T01:00:31.022968+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T00:00:00+00:00 PythonOperator 2021-04-17T01:00:10.185269+00:00 2021-04-17T01:00:13.135840+00:00 0:00:02.950571 18008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T01:00:07.064704+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T23:00:00+00:00 EmrJobFlowSensor 2021-04-17T00:11:16.099797+00:00 2021-04-17T00:20:18.854816+00:00 0:09:02.755019 18006 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:11:13.321607+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T23:00:00+00:00 EmrJobFlowSensor 2021-04-17T00:11:13.843688+00:00 2021-04-17T00:21:17.150507+00:00 0:10:03.306819 18005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:11:11.338236+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T00:10:53.477335+00:00 2021-04-17T00:10:55.194031+00:00 0:00:01.716696 18004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T00:10:51.287544+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T00:10:51.650109+00:00 2021-04-17T00:10:53.436341+00:00 0:00:01.786232 18003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T00:10:49.352051+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T23:00:00+00:00 PythonOperator 2021-04-17T00:10:34.087761+00:00 2021-04-17T00:10:37.012027+00:00 0:00:02.924266 18002 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T00:10:31.232564+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T23:00:00+00:00 PythonOperator 2021-04-17T00:10:31.562017+00:00 2021-04-17T00:10:35.332555+00:00 0:00:03.770538 18001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T00:10:29.269427+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T23:00:00+00:00 TriggerDagRunOperator 2021-04-17T00:10:17.919690+00:00 2021-04-17T00:10:18.333895+00:00 0:00:00.414205 18000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:10:15.223944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T23:00:00+00:00 TriggerDagRunOperator 2021-04-17T00:10:17.921573+00:00 2021-04-17T00:10:18.493554+00:00 0:00:00.571981 17999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:10:15.223994+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T23:05:00+00:00 EmrJobFlowSensor 2021-04-17T00:06:06.992414+00:00 2021-04-17T00:15:09.782878+00:00 0:09:02.790464 17998 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:06:04.814879+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T00:05:37.007103+00:00 2021-04-17T00:05:38.759101+00:00 0:00:01.751998 17997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T00:05:34.787677+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T23:05:00+00:00 PythonOperator 2021-04-17T00:05:09.569659+00:00 2021-04-17T00:05:12.486142+00:00 0:00:02.916483 17996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T00:05:06.691150+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T23:00:00+00:00 EmrJobFlowSensor 2021-04-17T00:01:06.497787+00:00 2021-04-17T00:10:09.198966+00:00 0:09:02.701179 17995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T00:01:04.342935+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T00:00:42.815077+00:00 2021-04-17T00:00:44.596200+00:00 0:00:01.781123 17994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T00:00:40.320549+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T23:00:00+00:00 PythonOperator 2021-04-17T00:00:22.899299+00:00 2021-04-17T00:00:26.070296+00:00 0:00:03.170997 17993 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T00:00:20.307451+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T22:00:00+00:00 EmrJobFlowSensor 2021-04-16T23:12:24.835329+00:00 2021-04-16T23:22:27.749601+00:00 0:10:02.914272 17991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:12:22.507209+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T22:00:00+00:00 EmrJobFlowSensor 2021-04-16T23:12:16.671029+00:00 2021-04-16T23:21:19.239071+00:00 0:09:02.568042 17990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:12:14.494999+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T23:12:02.971117+00:00 2021-04-16T23:12:04.811718+00:00 0:00:01.840601 17989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T23:12:00.543433+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T23:11:54.902662+00:00 2021-04-16T23:11:57.161442+00:00 0:00:02.258780 17988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T23:11:52.544163+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T22:00:00+00:00 PythonOperator 2021-04-16T23:11:36.568765+00:00 2021-04-16T23:11:40.183061+00:00 0:00:03.614296 17987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T23:11:34.412246+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T22:00:00+00:00 PythonOperator 2021-04-16T23:11:22.875491+00:00 2021-04-16T23:11:26.693556+00:00 0:00:03.818065 17986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T23:11:20.399142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T22:00:00+00:00 TriggerDagRunOperator 2021-04-16T23:11:14.863920+00:00 2021-04-16T23:11:15.404395+00:00 0:00:00.540475 17985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:11:12.397547+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T22:00:00+00:00 TriggerDagRunOperator 2021-04-16T23:11:14.642413+00:00 2021-04-16T23:11:15.079326+00:00 0:00:00.436913 17984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:11:12.397492+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T22:05:00+00:00 EmrJobFlowSensor 2021-04-16T23:05:47.892119+00:00 2021-04-16T23:14:50.507205+00:00 0:09:02.615086 17983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:05:45.789363+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T23:05:26.168154+00:00 2021-04-16T23:05:27.786628+00:00 0:00:01.618474 17982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T23:05:23.853330+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T22:05:00+00:00 PythonOperator 2021-04-16T23:05:06.057774+00:00 2021-04-16T23:05:09.093214+00:00 0:00:03.035440 17981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T23:05:03.696714+00:00 2 default_pool