Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-history-job_v002 check_cluster_status 2021-04-14T05:00:00+00:00 EmrJobFlowSensor 2021-04-14T06:12:14.997995+00:00 2021-04-14T06:21:17.600720+00:00 0:09:02.602725 17006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T06:12:12.816179+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T06:11:59.315142+00:00 2021-04-14T06:12:01.139569+00:00 0:00:01.824427 17005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T06:11:56.869772+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T06:11:53.684595+00:00 2021-04-14T06:11:55.347323+00:00 0:00:01.662728 17004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T06:11:50.797936+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T05:00:00+00:00 PythonOperator 2021-04-14T06:11:39.130236+00:00 2021-04-14T06:11:42.206409+00:00 0:00:03.076173 17003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T06:11:36.788624+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T05:00:00+00:00 PythonOperator 2021-04-14T06:11:31.045276+00:00 2021-04-14T06:11:34.049093+00:00 0:00:03.003817 17002 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T06:11:28.779834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T05:00:00+00:00 TriggerDagRunOperator 2021-04-14T06:11:25.151159+00:00 2021-04-14T06:11:25.559668+00:00 0:00:00.408509 17001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T06:11:22.776370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T05:00:00+00:00 TriggerDagRunOperator 2021-04-14T06:11:25.118866+00:00 2021-04-14T06:11:25.677406+00:00 0:00:00.558540 17000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T06:11:22.776403+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T05:05:00+00:00 EmrJobFlowSensor 2021-04-14T06:06:00.980412+00:00 2021-04-14T06:15:03.839656+00:00 0:09:02.859244 16999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T06:05:58.541295+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T06:05:40.557333+00:00 2021-04-14T06:05:42.261511+00:00 0:00:01.704178 16998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T06:05:38.379462+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T05:05:00+00:00 PythonOperator 2021-04-14T06:05:16.451591+00:00 2021-04-14T06:05:19.312247+00:00 0:00:02.860656 16997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T06:05:14.311967+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T05:00:00+00:00 EmrJobFlowSensor 2021-04-14T06:01:04.435622+00:00 2021-04-14T06:11:07.498167+00:00 0:10:03.062545 16996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T06:01:02.006839+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T06:00:40.240479+00:00 2021-04-14T06:00:41.965756+00:00 0:00:01.725277 16995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T06:00:38.044397+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T05:00:00+00:00 PythonOperator 2021-04-14T06:00:20.460677+00:00 2021-04-14T06:00:23.373024+00:00 0:00:02.912347 16994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T06:00:17.930326+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T04:00:00+00:00 EmrJobFlowSensor 2021-04-14T05:12:10.200127+00:00 2021-04-14T05:22:13.079178+00:00 0:10:02.879051 16992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T05:12:07.758213+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T04:00:00+00:00 EmrJobFlowSensor 2021-04-14T05:12:06.096414+00:00 2021-04-14T05:22:08.898244+00:00 0:10:02.801830 16991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T05:12:03.688594+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T05:11:48.097716+00:00 2021-04-14T05:11:49.823962+00:00 0:00:01.726246 16990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T05:11:45.636744+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T05:11:44.240102+00:00 2021-04-14T05:11:46.081169+00:00 0:00:01.841067 16989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T05:11:41.630794+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T04:00:00+00:00 PythonOperator 2021-04-14T05:11:16.435984+00:00 2021-04-14T05:11:19.342627+00:00 0:00:02.906643 16988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T05:11:13.613691+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T04:00:00+00:00 PythonOperator 2021-04-14T05:11:11.921203+00:00 2021-04-14T05:11:15.112532+00:00 0:00:03.191329 16987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T05:11:09.600497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T04:00:00+00:00 TriggerDagRunOperator 2021-04-14T05:11:04.186794+00:00 2021-04-14T05:11:04.832715+00:00 0:00:00.645921 16986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T05:11:01.596446+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T04:00:00+00:00 TriggerDagRunOperator 2021-04-14T05:11:04.032087+00:00 2021-04-14T05:11:04.776484+00:00 0:00:00.744397 16985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T05:11:01.596413+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T04:05:00+00:00 EmrJobFlowSensor 2021-04-14T05:07:03.421300+00:00 2021-04-14T05:15:06.084776+00:00 0:08:02.663476 16984 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T05:07:01.101539+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T05:05:45.287975+00:00 2021-04-14T05:05:46.916617+00:00 0:00:01.628642 16983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T05:05:42.992376+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T04:05:00+00:00 PythonOperator 2021-04-14T05:05:25.119509+00:00 2021-04-14T05:05:27.953443+00:00 0:00:02.833934 16982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T05:05:22.909965+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T04:00:00+00:00 EmrJobFlowSensor 2021-04-14T05:00:55.155211+00:00 2021-04-14T05:10:57.827618+00:00 0:10:02.672407 16981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T05:00:52.375940+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T05:00:34.715218+00:00 2021-04-14T05:00:36.485115+00:00 0:00:01.769897 16980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T05:00:32.359514+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T04:00:00+00:00 PythonOperator 2021-04-14T05:00:11.146946+00:00 2021-04-14T05:00:14.113584+00:00 0:00:02.966638 16979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T05:00:08.351122+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T03:00:00+00:00 EmrJobFlowSensor 2021-04-14T04:10:09.062442+00:00 2021-04-14T04:20:11.983415+00:00 0:10:02.920973 16977 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T04:10:06.737236+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T03:00:00+00:00 EmrJobFlowSensor 2021-04-14T04:10:06.874717+00:00 2021-04-14T04:20:09.651867+00:00 0:10:02.777150 16976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T04:10:04.756175+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T04:09:48.905421+00:00 2021-04-14T04:09:50.565002+00:00 0:00:01.659581 16975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T04:09:46.720988+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T04:09:44.934073+00:00 2021-04-14T04:09:46.737212+00:00 0:00:01.803139 16974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T04:09:42.724245+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T03:00:00+00:00 PythonOperator 2021-04-14T04:09:27.401467+00:00 2021-04-14T04:09:30.429029+00:00 0:00:03.027562 16973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T04:09:24.703235+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T03:00:00+00:00 PythonOperator 2021-04-14T04:09:22.994225+00:00 2021-04-14T04:09:26.407631+00:00 0:00:03.413406 16972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T04:09:20.705284+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T03:00:00+00:00 TriggerDagRunOperator 2021-04-14T04:09:07.075434+00:00 2021-04-14T04:09:07.588575+00:00 0:00:00.513141 16971 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T04:09:04.740145+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T03:00:00+00:00 TriggerDagRunOperator 2021-04-14T04:09:06.989093+00:00 2021-04-14T04:09:07.397107+00:00 0:00:00.408014 16970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T04:09:04.740177+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T03:05:00+00:00 EmrJobFlowSensor 2021-04-14T04:05:56.586612+00:00 2021-04-14T04:13:58.972333+00:00 0:08:02.385721 16969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T04:05:54.309531+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T04:05:36.472892+00:00 2021-04-14T04:05:38.208508+00:00 0:00:01.735616 16968 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T04:05:34.285563+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T03:05:00+00:00 PythonOperator 2021-04-14T04:05:14.624906+00:00 2021-04-14T04:05:17.695831+00:00 0:00:03.070925 16967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T04:05:12.223123+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T03:00:00+00:00 EmrJobFlowSensor 2021-04-14T04:00:56.048588+00:00 2021-04-14T04:08:58.656540+00:00 0:08:02.607952 16966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T04:00:53.653016+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T04:00:33.952338+00:00 2021-04-14T04:00:35.813962+00:00 0:00:01.861624 16965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T04:00:31.583898+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T03:00:00+00:00 PythonOperator 2021-04-14T04:00:11.845225+00:00 2021-04-14T04:00:14.692892+00:00 0:00:02.847667 16964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T04:00:09.526290+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T02:00:00+00:00 EmrJobFlowSensor 2021-04-14T03:11:16.771867+00:00 2021-04-14T03:21:19.585311+00:00 0:10:02.813444 16962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T03:11:14.120452+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T02:00:00+00:00 EmrJobFlowSensor 2021-04-14T03:11:00.736963+00:00 2021-04-14T03:20:03.640682+00:00 0:09:02.903719 16961 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T03:10:58.259837+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T03:10:48.515089+00:00 2021-04-14T03:10:50.222927+00:00 0:00:01.707838 16960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T03:10:46.088013+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T03:10:38.521560+00:00 2021-04-14T03:10:40.395151+00:00 0:00:01.873591 16959 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T03:10:36.085498+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T02:00:00+00:00 PythonOperator 2021-04-14T03:10:28.218203+00:00 2021-04-14T03:10:31.346494+00:00 0:00:03.128291 16958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T03:10:25.994360+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T02:00:00+00:00 PythonOperator 2021-04-14T03:10:18.365804+00:00 2021-04-14T03:10:21.281333+00:00 0:00:02.915529 16957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T03:10:16.046551+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T02:00:00+00:00 TriggerDagRunOperator 2021-04-14T03:10:04.856757+00:00 2021-04-14T03:10:05.426984+00:00 0:00:00.570227 16956 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T03:10:01.937553+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T02:00:00+00:00 TriggerDagRunOperator 2021-04-14T03:10:04.217827+00:00 2021-04-14T03:10:04.749965+00:00 0:00:00.532138 16955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T03:10:01.937514+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T02:05:00+00:00 EmrJobFlowSensor 2021-04-14T03:06:05.958073+00:00 2021-04-14T03:15:08.540862+00:00 0:09:02.582789 16954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T03:06:03.657311+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T03:05:43.698554+00:00 2021-04-14T03:05:45.422768+00:00 0:00:01.724214 16953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T03:05:41.540543+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T02:05:00+00:00 PythonOperator 2021-04-14T03:05:22.205787+00:00 2021-04-14T03:05:25.233267+00:00 0:00:03.027480 16952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T03:05:19.519104+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T02:00:00+00:00 EmrJobFlowSensor 2021-04-14T03:00:49.725244+00:00 2021-04-14T03:09:52.602496+00:00 0:09:02.877252 16951 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T03:00:47.221521+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T03:00:27.438044+00:00 2021-04-14T03:00:29.135733+00:00 0:00:01.697689 16950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T03:00:25.202658+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T02:00:00+00:00 PythonOperator 2021-04-14T03:00:06.079865+00:00 2021-04-14T03:00:09.831797+00:00 0:00:03.751932 16949 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T03:00:03.244137+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T01:00:00+00:00 EmrJobFlowSensor 2021-04-14T02:12:25.922750+00:00 2021-04-14T02:20:28.395539+00:00 0:08:02.472789 16947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T02:12:23.430651+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T01:00:00+00:00 EmrJobFlowSensor 2021-04-14T02:12:15.700013+00:00 2021-04-14T02:22:18.692004+00:00 0:10:02.991991 16946 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T02:12:13.424159+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T02:12:04.008302+00:00 2021-04-14T02:12:05.718310+00:00 0:00:01.710008 16945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T02:12:01.411459+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T02:11:56.230224+00:00 2021-04-14T02:11:58.039053+00:00 0:00:01.808829 16944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T02:11:53.406087+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T01:00:00+00:00 PythonOperator 2021-04-14T02:11:41.617258+00:00 2021-04-14T02:11:44.826213+00:00 0:00:03.208955 16943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T02:11:39.391358+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T01:00:00+00:00 PythonOperator 2021-04-14T02:11:33.842168+00:00 2021-04-14T02:11:37.447761+00:00 0:00:03.605593 16942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T02:11:31.391295+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T01:00:00+00:00 TriggerDagRunOperator 2021-04-14T02:11:27.852940+00:00 2021-04-14T02:11:28.266475+00:00 0:00:00.413535 16941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T02:11:25.448457+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T01:00:00+00:00 TriggerDagRunOperator 2021-04-14T02:11:27.876739+00:00 2021-04-14T02:11:28.447568+00:00 0:00:00.570829 16940 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T02:11:25.448493+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T01:05:00+00:00 EmrJobFlowSensor 2021-04-14T02:05:52.867735+00:00 2021-04-14T02:14:55.432679+00:00 0:09:02.564944 16939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T02:05:50.709494+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T02:05:31.187337+00:00 2021-04-14T02:05:32.820822+00:00 0:00:01.633485 16938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T02:05:28.844137+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T01:05:00+00:00 PythonOperator 2021-04-14T02:05:08.934555+00:00 2021-04-14T02:05:11.828794+00:00 0:00:02.894239 16937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T02:05:06.655136+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T01:00:00+00:00 EmrJobFlowSensor 2021-04-14T02:01:02.753519+00:00 2021-04-14T02:11:05.469823+00:00 0:10:02.716304 16936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T02:01:00.287224+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T02:00:40.501979+00:00 2021-04-14T02:00:42.170076+00:00 0:00:01.668097 16935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T02:00:38.272169+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T01:00:00+00:00 PythonOperator 2021-04-14T02:00:19.034455+00:00 2021-04-14T02:00:21.952745+00:00 0:00:02.918290 16934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T02:00:16.056202+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-14T00:00:00+00:00 EmrJobFlowSensor 2021-04-14T01:11:16.390879+00:00 2021-04-14T01:19:19.017935+00:00 0:08:02.627056 16932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T01:11:14.095432+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-14T00:00:00+00:00 EmrJobFlowSensor 2021-04-14T01:11:14.492567+00:00 2021-04-14T01:20:17.143904+00:00 0:09:02.651337 16931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T01:11:12.103854+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-14T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T01:10:54.655541+00:00 2021-04-14T01:10:56.500703+00:00 0:00:01.845162 16930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T01:10:52.064722+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-14T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T01:10:54.589262+00:00 2021-04-14T01:10:56.383595+00:00 0:00:01.794333 16929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T01:10:52.064771+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-14T00:00:00+00:00 PythonOperator 2021-04-14T01:10:34.319042+00:00 2021-04-14T01:10:37.264431+00:00 0:00:02.945389 16928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T01:10:31.997094+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-14T00:00:00+00:00 PythonOperator 2021-04-14T01:10:32.360972+00:00 2021-04-14T01:10:35.468783+00:00 0:00:03.107811 16927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T01:10:30.053665+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T00:00:00+00:00 TriggerDagRunOperator 2021-04-14T01:10:12.238755+00:00 2021-04-14T01:10:12.693998+00:00 0:00:00.455243 16926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T01:10:09.977438+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T00:00:00+00:00 TriggerDagRunOperator 2021-04-14T01:10:12.246265+00:00 2021-04-14T01:10:12.838764+00:00 0:00:00.592499 16925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T01:10:09.977475+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-14T00:05:00+00:00 EmrJobFlowSensor 2021-04-14T01:05:59.768455+00:00 2021-04-14T01:18:02.917819+00:00 0:12:03.149364 16924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T01:05:57.387953+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-14T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T01:05:39.556050+00:00 2021-04-14T01:05:41.262993+00:00 0:00:01.706943 16923 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T01:05:37.313128+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-14T00:05:00+00:00 PythonOperator 2021-04-14T01:05:17.403323+00:00 2021-04-14T01:05:20.227317+00:00 0:00:02.823994 16922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T01:05:15.297856+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T00:00:00+00:00 EmrJobFlowSensor 2021-04-14T01:00:57.092640+00:00 2021-04-14T01:09:59.744687+00:00 0:09:02.652047 16921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T01:00:54.831344+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T01:00:35.330981+00:00 2021-04-14T01:00:37.057220+00:00 0:00:01.726239 16920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T01:00:32.817151+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T00:00:00+00:00 PythonOperator 2021-04-14T01:00:13.210663+00:00 2021-04-14T01:00:16.081806+00:00 0:00:02.871143 16919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T01:00:10.799090+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T23:00:00+00:00 EmrJobFlowSensor 2021-04-14T00:11:07.193655+00:00 2021-04-14T00:22:10.171544+00:00 0:11:02.977889 16917 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T00:11:04.994537+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T23:00:00+00:00 EmrJobFlowSensor 2021-04-14T00:10:49.132406+00:00 2021-04-14T00:20:51.756013+00:00 0:10:02.623607 16916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T00:10:46.899968+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T00:10:47.128539+00:00 2021-04-14T00:10:49.013933+00:00 0:00:01.885394 16915 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T00:10:44.900772+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T00:10:29.229419+00:00 2021-04-14T00:10:31.006294+00:00 0:00:01.776875 16914 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T00:10:26.885033+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T23:00:00+00:00 PythonOperator 2021-04-14T00:10:25.051273+00:00 2021-04-14T00:10:28.091902+00:00 0:00:03.040629 16913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T00:10:22.877535+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T23:00:00+00:00 PythonOperator 2021-04-14T00:10:07.111411+00:00 2021-04-14T00:10:10.625903+00:00 0:00:03.514492 16912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T00:10:04.862643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T23:00:00+00:00 TriggerDagRunOperator 2021-04-14T00:10:01.262776+00:00 2021-04-14T00:10:01.753726+00:00 0:00:00.490950 16911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T00:09:58.872898+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T23:00:00+00:00 TriggerDagRunOperator 2021-04-14T00:10:01.275422+00:00 2021-04-14T00:10:01.851106+00:00 0:00:00.575684 16910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T00:09:58.872942+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T23:05:00+00:00 EmrJobFlowSensor 2021-04-14T00:05:50.556729+00:00 2021-04-14T00:13:53.191654+00:00 0:08:02.634925 16909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T00:05:48.365764+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-14T00:05:28.712274+00:00 2021-04-14T00:05:30.424882+00:00 0:00:01.712608 16908 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-14T00:05:26.329343+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T23:05:00+00:00 PythonOperator 2021-04-14T00:05:06.459340+00:00 2021-04-14T00:05:09.302649+00:00 0:00:02.843309 16907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T00:05:04.312271+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T23:00:00+00:00 EmrJobFlowSensor 2021-04-14T00:00:54.294215+00:00 2021-04-14T00:09:56.944592+00:00 0:09:02.650377 16906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T00:00:52.027064+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T00:00:32.464013+00:00 2021-04-14T00:00:34.166690+00:00 0:00:01.702677 16905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T00:00:30.052747+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T23:00:00+00:00 PythonOperator 2021-04-14T00:00:10.609626+00:00 2021-04-14T00:00:13.631506+00:00 0:00:03.021880 16904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T00:00:08.056104+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T22:00:00+00:00 EmrJobFlowSensor 2021-04-13T23:11:26.744949+00:00 2021-04-13T23:20:29.337245+00:00 0:09:02.592296 16902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T23:11:24.377772+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T22:00:00+00:00 EmrJobFlowSensor 2021-04-13T23:11:14.790894+00:00 2021-04-13T23:20:17.358537+00:00 0:09:02.567643 16901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T23:11:12.309596+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T23:11:06.632597+00:00 2021-04-13T23:11:08.354492+00:00 0:00:01.721895 16900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T23:11:04.346809+00:00 2 default_pool