Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T14:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T15:07:11.581866+00:00 2021-03-24T15:07:13.239813+00:00 0:00:01.657947 11281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T15:07:09.390993+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T14:05:00+00:00 PythonOperator 2021-03-24T15:06:49.656817+00:00 2021-03-24T15:06:52.353779+00:00 0:00:02.696962 11280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T15:06:47.372773+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T14:00:00+00:00 EmrJobFlowSensor 2021-03-24T15:01:05.653113+00:00 2021-03-24T15:11:08.620373+00:00 0:10:02.967260 11278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T15:01:03.111201+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T15:00:41.446303+00:00 2021-03-24T15:00:43.138804+00:00 0:00:01.692501 11277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T15:00:39.161948+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T14:00:00+00:00 PythonOperator 2021-03-24T15:00:21.186396+00:00 2021-03-24T15:00:24.078532+00:00 0:00:02.892136 11276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T15:00:18.995450+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T13:00:00+00:00 EmrJobFlowSensor 2021-03-24T14:14:18.070661+00:00 2021-03-24T14:24:20.788119+00:00 0:10:02.717458 11275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T14:14:15.894137+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T13:00:00+00:00 EmrJobFlowSensor 2021-03-24T14:14:12.004829+00:00 2021-03-24T14:24:14.932020+00:00 0:10:02.927191 11274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T14:14:09.824650+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T14:13:56.180096+00:00 2021-03-24T14:13:57.851919+00:00 0:00:01.671823 11273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T14:13:53.818940+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T14:13:52.119867+00:00 2021-03-24T14:13:53.807428+00:00 0:00:01.687561 11272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T14:13:49.811613+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T13:00:00+00:00 PythonOperator 2021-03-24T14:13:34.192426+00:00 2021-03-24T14:13:37.087285+00:00 0:00:02.894859 11271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T14:13:31.864016+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T13:00:00+00:00 PythonOperator 2021-03-24T14:13:30.373064+00:00 2021-03-24T14:13:33.356546+00:00 0:00:02.983482 11270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T14:13:27.756008+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T13:00:00+00:00 TriggerDagRunOperator 2021-03-24T14:13:14.186840+00:00 2021-03-24T14:13:14.620112+00:00 0:00:00.433272 11269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T14:13:11.674663+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T13:00:00+00:00 TriggerDagRunOperator 2021-03-24T14:13:14.073065+00:00 2021-03-24T14:13:14.623526+00:00 0:00:00.550461 11268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T14:13:11.674616+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T13:05:00+00:00 EmrJobFlowSensor 2021-03-24T14:06:05.441534+00:00 2021-03-24T14:15:07.996828+00:00 0:09:02.555294 11267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T14:06:03.143673+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T13:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T14:05:43.357958+00:00 2021-03-24T14:05:45.171047+00:00 0:00:01.813089 11266 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T14:05:41.075448+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T13:05:00+00:00 PythonOperator 2021-03-24T14:05:21.229379+00:00 2021-03-24T14:05:23.965271+00:00 0:00:02.735892 11265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T14:05:19.052088+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T13:00:00+00:00 EmrJobFlowSensor 2021-03-24T14:02:55.139191+00:00 2021-03-24T14:12:57.852186+00:00 0:10:02.712995 11264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T14:02:52.773358+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T14:02:35.148490+00:00 2021-03-24T14:02:36.942857+00:00 0:00:01.794367 11263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T14:02:32.753492+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T13:00:00+00:00 PythonOperator 2021-03-24T14:02:11.084808+00:00 2021-03-24T14:02:13.859422+00:00 0:00:02.774614 11262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T14:02:08.659497+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T12:00:00+00:00 EmrJobFlowSensor 2021-03-24T13:12:04.401852+00:00 2021-03-24T13:21:07.058935+00:00 0:09:02.657083 11260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T13:12:01.969860+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T12:00:00+00:00 EmrJobFlowSensor 2021-03-24T13:11:54.261825+00:00 2021-03-24T13:21:56.998403+00:00 0:10:02.736578 11259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T13:11:51.952225+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T13:11:42.306153+00:00 2021-03-24T13:11:44.112470+00:00 0:00:01.806317 11258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T13:11:39.961458+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T13:11:34.198320+00:00 2021-03-24T13:11:35.995252+00:00 0:00:01.796932 11257 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T13:11:31.873705+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T12:00:00+00:00 PythonOperator 2021-03-24T13:11:22.068644+00:00 2021-03-24T13:11:24.990626+00:00 0:00:02.921982 11256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T13:11:19.818159+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T12:00:00+00:00 PythonOperator 2021-03-24T13:11:12.091629+00:00 2021-03-24T13:11:14.817176+00:00 0:00:02.725547 11255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T13:11:09.815352+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T12:00:00+00:00 TriggerDagRunOperator 2021-03-24T13:11:06.603807+00:00 2021-03-24T13:11:06.974099+00:00 0:00:00.370292 11254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T13:11:03.811126+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T12:00:00+00:00 TriggerDagRunOperator 2021-03-24T13:11:06.073075+00:00 2021-03-24T13:11:06.600240+00:00 0:00:00.527165 11253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T13:11:03.811168+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T12:05:00+00:00 EmrJobFlowSensor 2021-03-24T13:06:05.490067+00:00 2021-03-24T13:15:08.047583+00:00 0:09:02.557516 11252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T13:06:03.339832+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T12:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T13:05:43.636473+00:00 2021-03-24T13:05:45.371161+00:00 0:00:01.734688 11251 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T13:05:41.324413+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T12:05:00+00:00 PythonOperator 2021-03-24T13:05:23.775686+00:00 2021-03-24T13:05:26.697836+00:00 0:00:02.922150 11250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T13:05:21.304714+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T12:00:00+00:00 EmrJobFlowSensor 2021-03-24T13:00:51.133828+00:00 2021-03-24T13:10:53.986946+00:00 0:10:02.853118 11249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T13:00:48.901964+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T13:00:29.254487+00:00 2021-03-24T13:00:30.954782+00:00 0:00:01.700295 11248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T13:00:26.947298+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T12:00:00+00:00 PythonOperator 2021-03-24T13:00:09.623925+00:00 2021-03-24T13:00:12.534306+00:00 0:00:02.910381 11247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T13:00:06.863989+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T11:00:00+00:00 EmrJobFlowSensor 2021-03-24T12:12:15.305703+00:00 2021-03-24T12:22:18.120521+00:00 0:10:02.814818 11245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T12:12:12.955812+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T11:00:00+00:00 EmrJobFlowSensor 2021-03-24T12:12:13.099611+00:00 2021-03-24T12:21:15.650914+00:00 0:09:02.551303 11244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T12:12:10.885778+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T12:11:55.145590+00:00 2021-03-24T12:11:56.841529+00:00 0:00:01.695939 11243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T12:11:52.871421+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T12:11:51.123347+00:00 2021-03-24T12:11:52.919090+00:00 0:00:01.795743 11242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T12:11:48.858549+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T11:00:00+00:00 PythonOperator 2021-03-24T12:11:33.069140+00:00 2021-03-24T12:11:36.036109+00:00 0:00:02.966969 11241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T12:11:30.843389+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T11:00:00+00:00 PythonOperator 2021-03-24T12:11:31.224640+00:00 2021-03-24T12:11:34.043316+00:00 0:00:02.818676 11240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T12:11:28.858262+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T11:00:00+00:00 TriggerDagRunOperator 2021-03-24T12:11:07.375328+00:00 2021-03-24T12:11:07.928870+00:00 0:00:00.553542 11239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T12:11:04.780312+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T11:00:00+00:00 TriggerDagRunOperator 2021-03-24T12:11:07.095540+00:00 2021-03-24T12:11:07.510273+00:00 0:00:00.414733 11238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T12:11:04.780358+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T11:05:00+00:00 EmrJobFlowSensor 2021-03-24T12:06:00.705208+00:00 2021-03-24T12:14:03.117350+00:00 0:08:02.412142 11237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T12:05:58.264704+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T11:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T12:05:38.314145+00:00 2021-03-24T12:05:40.078476+00:00 0:00:01.764331 11236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T12:05:36.128095+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T11:05:00+00:00 PythonOperator 2021-03-24T12:05:16.249926+00:00 2021-03-24T12:05:18.998543+00:00 0:00:02.748617 11235 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T12:05:14.119393+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T11:00:00+00:00 EmrJobFlowSensor 2021-03-24T12:00:50.070356+00:00 2021-03-24T12:10:52.822037+00:00 0:10:02.751681 11234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T12:00:47.808438+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T12:00:28.088527+00:00 2021-03-24T12:00:29.772355+00:00 0:00:01.683828 11233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T12:00:25.790234+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T11:00:00+00:00 PythonOperator 2021-03-24T12:00:08.083656+00:00 2021-03-24T12:00:10.814935+00:00 0:00:02.731279 11232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T12:00:05.738111+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T10:00:00+00:00 EmrJobFlowSensor 2021-03-24T11:11:39.103995+00:00 2021-03-24T11:21:41.781652+00:00 0:10:02.677657 11230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T11:11:36.773501+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T10:00:00+00:00 EmrJobFlowSensor 2021-03-24T11:11:35.033510+00:00 2021-03-24T11:21:37.922879+00:00 0:10:02.889369 11229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T11:11:32.711366+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T11:11:16.988437+00:00 2021-03-24T11:11:18.907678+00:00 0:00:01.919241 11228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T11:11:14.743393+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T11:11:12.954924+00:00 2021-03-24T11:11:14.691451+00:00 0:00:01.736527 11227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T11:11:10.689095+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T10:00:00+00:00 PythonOperator 2021-03-24T11:10:45.214490+00:00 2021-03-24T11:10:47.942717+00:00 0:00:02.728227 11226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T11:10:42.595224+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T10:00:00+00:00 PythonOperator 2021-03-24T11:10:40.825614+00:00 2021-03-24T11:10:43.937767+00:00 0:00:03.112153 11225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T11:10:38.596065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T10:00:00+00:00 TriggerDagRunOperator 2021-03-24T11:10:35.157555+00:00 2021-03-24T11:10:35.685506+00:00 0:00:00.527951 11224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T11:10:32.596782+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T10:00:00+00:00 TriggerDagRunOperator 2021-03-24T11:10:35.102626+00:00 2021-03-24T11:10:35.542393+00:00 0:00:00.439767 11223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T11:10:32.596814+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T10:05:00+00:00 EmrJobFlowSensor 2021-03-24T11:06:04.675058+00:00 2021-03-24T11:15:07.294715+00:00 0:09:02.619657 11222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T11:06:02.241350+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T10:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T11:05:42.315346+00:00 2021-03-24T11:05:44.040482+00:00 0:00:01.725136 11221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T11:05:40.181619+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T10:05:00+00:00 PythonOperator 2021-03-24T11:05:20.380244+00:00 2021-03-24T11:05:23.173657+00:00 0:00:02.793413 11220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T11:05:18.145933+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T10:00:00+00:00 EmrJobFlowSensor 2021-03-24T11:01:18.295013+00:00 2021-03-24T11:10:21.186474+00:00 0:09:02.891461 11219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T11:01:15.862674+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T11:00:55.908065+00:00 2021-03-24T11:00:57.607175+00:00 0:00:01.699110 11218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T11:00:53.736226+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T10:00:00+00:00 PythonOperator 2021-03-24T11:00:26.385783+00:00 2021-03-24T11:00:29.257746+00:00 0:00:02.871963 11217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T11:00:23.728064+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T09:00:00+00:00 EmrJobFlowSensor 2021-03-24T10:11:23.973967+00:00 2021-03-24T10:20:26.644434+00:00 0:09:02.670467 11215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T10:11:21.689388+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T09:00:00+00:00 EmrJobFlowSensor 2021-03-24T10:11:17.900012+00:00 2021-03-24T10:20:20.681301+00:00 0:09:02.781289 11214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T10:11:15.687857+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T10:11:03.895294+00:00 2021-03-24T10:11:05.708349+00:00 0:00:01.813055 11213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T10:11:01.672147+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T10:10:57.889486+00:00 2021-03-24T10:10:59.647619+00:00 0:00:01.758133 11212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T10:10:55.669375+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T09:00:00+00:00 PythonOperator 2021-03-24T10:10:41.796935+00:00 2021-03-24T10:10:44.810060+00:00 0:00:03.013125 11211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T10:10:39.653905+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T09:00:00+00:00 PythonOperator 2021-03-24T10:10:28.005213+00:00 2021-03-24T10:10:30.840903+00:00 0:00:02.835690 11210 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T10:10:25.649566+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T09:00:00+00:00 TriggerDagRunOperator 2021-03-24T10:10:13.965165+00:00 2021-03-24T10:10:14.498750+00:00 0:00:00.533585 11209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T10:10:11.631480+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T09:00:00+00:00 TriggerDagRunOperator 2021-03-24T10:10:13.959410+00:00 2021-03-24T10:10:14.414180+00:00 0:00:00.454770 11208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T10:10:11.631451+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T09:05:00+00:00 EmrJobFlowSensor 2021-03-24T10:06:07.500840+00:00 2021-03-24T10:14:10.039183+00:00 0:08:02.538343 11207 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T10:06:05.143267+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T09:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T10:05:45.329093+00:00 2021-03-24T10:05:46.944756+00:00 0:00:01.615663 11206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T10:05:43.044242+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T09:05:00+00:00 PythonOperator 2021-03-24T10:05:25.117086+00:00 2021-03-24T10:05:27.809820+00:00 0:00:02.692734 11205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T10:05:22.955947+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T09:00:00+00:00 EmrJobFlowSensor 2021-03-24T10:00:50.606476+00:00 2021-03-24T10:09:53.176774+00:00 0:09:02.570298 11204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T10:00:48.441017+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T10:00:30.917730+00:00 2021-03-24T10:00:32.615047+00:00 0:00:01.697317 11203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T10:00:28.482179+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T09:00:00+00:00 PythonOperator 2021-03-24T10:00:08.795350+00:00 2021-03-24T10:00:11.623989+00:00 0:00:02.828639 11202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T10:00:06.389438+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T08:00:00+00:00 EmrJobFlowSensor 2021-03-24T09:12:28.931855+00:00 2021-03-24T09:21:31.476258+00:00 0:09:02.544403 11200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:12:26.459025+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T08:00:00+00:00 EmrJobFlowSensor 2021-03-24T09:12:12.744204+00:00 2021-03-24T09:21:15.489538+00:00 0:09:02.745334 11199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:12:10.397079+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T09:12:08.910010+00:00 2021-03-24T09:12:10.713706+00:00 0:00:01.803696 11198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T09:12:06.460112+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T09:11:50.490115+00:00 2021-03-24T09:11:52.187103+00:00 0:00:01.696988 11197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T09:11:48.332604+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T08:00:00+00:00 PythonOperator 2021-03-24T09:11:36.769487+00:00 2021-03-24T09:11:39.457397+00:00 0:00:02.687910 11196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T09:11:34.322864+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T08:00:00+00:00 PythonOperator 2021-03-24T09:11:24.611038+00:00 2021-03-24T09:11:27.570498+00:00 0:00:02.959460 11195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T09:11:22.324192+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T08:00:00+00:00 TriggerDagRunOperator 2021-03-24T09:11:18.598499+00:00 2021-03-24T09:11:19.018245+00:00 0:00:00.419746 11194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:11:16.302638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T08:00:00+00:00 TriggerDagRunOperator 2021-03-24T09:11:18.531044+00:00 2021-03-24T09:11:19.041488+00:00 0:00:00.510444 11193 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:11:16.302586+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T08:05:00+00:00 EmrJobFlowSensor 2021-03-24T09:06:05.962774+00:00 2021-03-24T09:16:08.701095+00:00 0:10:02.738321 11192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T09:06:03.635645+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T08:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T09:05:45.690581+00:00 2021-03-24T09:05:47.405186+00:00 0:00:01.714605 11191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T09:05:43.522062+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T08:05:00+00:00 PythonOperator 2021-03-24T09:05:23.855570+00:00 2021-03-24T09:05:26.689208+00:00 0:00:02.833638 11190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T09:05:21.504040+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T08:00:00+00:00 EmrJobFlowSensor 2021-03-24T09:00:55.130767+00:00 2021-03-24T09:10:57.783478+00:00 0:10:02.652711 11189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T09:00:52.902688+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T09:00:33.310815+00:00 2021-03-24T09:00:35.106140+00:00 0:00:01.795325 11188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T09:00:30.950081+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T08:00:00+00:00 PythonOperator 2021-03-24T09:00:11.624755+00:00 2021-03-24T09:00:14.405301+00:00 0:00:02.780546 11187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T09:00:08.789147+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T07:00:00+00:00 EmrJobFlowSensor 2021-03-24T08:11:10.014225+00:00 2021-03-24T08:20:12.712158+00:00 0:09:02.697933 11185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:11:07.723284+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T07:00:00+00:00 EmrJobFlowSensor 2021-03-24T08:11:03.877483+00:00 2021-03-24T08:19:06.342394+00:00 0:08:02.464911 11184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:11:01.726420+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T08:10:46.196589+00:00 2021-03-24T08:10:47.982700+00:00 0:00:01.786111 11183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T08:10:43.707879+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T08:10:42.191941+00:00 2021-03-24T08:10:44.068483+00:00 0:00:01.876542 11182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T08:10:39.766215+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T07:00:00+00:00 PythonOperator 2021-03-24T08:10:26.232697+00:00 2021-03-24T08:10:29.128485+00:00 0:00:02.895788 11181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T08:10:23.759194+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T07:00:00+00:00 PythonOperator 2021-03-24T08:10:21.824484+00:00 2021-03-24T08:10:24.642776+00:00 0:00:02.818292 11180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T08:10:19.684107+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T07:00:00+00:00 TriggerDagRunOperator 2021-03-24T08:10:08.155217+00:00 2021-03-24T08:10:08.594584+00:00 0:00:00.439367 11179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:10:05.623073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T07:00:00+00:00 TriggerDagRunOperator 2021-03-24T08:10:07.904770+00:00 2021-03-24T08:10:08.461302+00:00 0:00:00.556532 11178 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:10:05.623045+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T07:05:00+00:00 EmrJobFlowSensor 2021-03-24T08:05:51.308153+00:00 2021-03-24T08:13:53.713162+00:00 0:08:02.405009 11177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T08:05:49.160618+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T07:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T08:05:31.637411+00:00 2021-03-24T08:05:33.289917+00:00 0:00:01.652506 11176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T08:05:29.160580+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T07:05:00+00:00 PythonOperator 2021-03-24T08:05:09.552301+00:00 2021-03-24T08:05:12.262043+00:00 0:00:02.709742 11175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T08:05:07.087851+00:00 2 default_pool