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 booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T19:11:48.144325+00:00 2021-04-30T19:11:50.043445+00:00 0:00:01.899120 23026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T19:11:45.671274+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T19:11:33.955356+00:00 2021-04-30T19:11:35.745868+00:00 0:00:01.790512 23025 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T19:11:31.663884+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T18:00:00+00:00 PythonOperator 2021-04-30T19:11:27.806880+00:00 2021-04-30T19:11:31.059568+00:00 0:00:03.252688 23024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T19:11:25.617400+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T18:00:00+00:00 PythonOperator 2021-04-30T19:11:11.963995+00:00 2021-04-30T19:11:15.072162+00:00 0:00:03.108167 23023 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T19:11:09.603261+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T18:00:00+00:00 TriggerDagRunOperator 2021-04-30T19:11:06.369249+00:00 2021-04-30T19:11:06.825672+00:00 0:00:00.456423 23022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T19:11:03.519697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T18:00:00+00:00 TriggerDagRunOperator 2021-04-30T19:11:06.326385+00:00 2021-04-30T19:11:06.928795+00:00 0:00:00.602410 23021 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T19:11:03.519726+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-30T18:05:00+00:00 EmrJobFlowSensor 2021-04-30T19:05:55.356262+00:00 2021-04-30T19:14:57.936626+00:00 0:09:02.580364 23019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T19:05:53.077963+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T19:05:35.290082+00:00 2021-04-30T19:05:36.925474+00:00 0:00:01.635392 23018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T19:05:33.055573+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T18:05:00+00:00 PythonOperator 2021-04-30T19:05:11.194043+00:00 2021-04-30T19:05:14.363152+00:00 0:00:03.169109 23017 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T19:05:08.992136+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T18:00:00+00:00 EmrJobFlowSensor 2021-04-30T19:00:56.924354+00:00 2021-04-30T19:10:59.685594+00:00 0:10:02.761240 23016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T19:00:54.659873+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T19:00:34.998896+00:00 2021-04-30T19:00:36.896017+00:00 0:00:01.897121 23015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T19:00:32.591604+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T18:00:00+00:00 PythonOperator 2021-04-30T19:00:12.811090+00:00 2021-04-30T19:00:15.879240+00:00 0:00:03.068150 23014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T19:00:10.504081+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T17:00:00+00:00 EmrJobFlowSensor 2021-04-30T18:11:33.487293+00:00 2021-04-30T18:21:36.245634+00:00 0:10:02.758341 23013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T18:11:31.323845+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T17:00:00+00:00 EmrJobFlowSensor 2021-04-30T18:11:19.509725+00:00 2021-04-30T18:21:22.183336+00:00 0:10:02.673611 23012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T18:11:17.332491+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T18:11:09.734593+00:00 2021-04-30T18:11:11.433048+00:00 0:00:01.698455 23011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T18:11:07.441026+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T18:10:58.001930+00:00 2021-04-30T18:10:59.667308+00:00 0:00:01.665378 23010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T18:10:55.346567+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T17:00:00+00:00 PythonOperator 2021-04-30T18:10:49.606897+00:00 2021-04-30T18:10:52.678419+00:00 0:00:03.071522 23009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T18:10:47.349306+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T17:00:00+00:00 PythonOperator 2021-04-30T18:10:35.727122+00:00 2021-04-30T18:10:38.994763+00:00 0:00:03.267641 23008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T18:10:33.244485+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T17:00:00+00:00 TriggerDagRunOperator 2021-04-30T18:10:29.719417+00:00 2021-04-30T18:10:30.244830+00:00 0:00:00.525413 23007 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T18:10:27.245383+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T17:00:00+00:00 TriggerDagRunOperator 2021-04-30T18:10:29.460414+00:00 2021-04-30T18:10:29.874875+00:00 0:00:00.414461 23006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T18:10:27.245344+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-30T17:05:00+00:00 EmrJobFlowSensor 2021-04-30T18:06:55.174718+00:00 2021-04-30T18:15:57.784478+00:00 0:09:02.609760 23005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T18:06:52.974108+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T18:06:35.164469+00:00 2021-04-30T18:06:36.815769+00:00 0:00:01.651300 23004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T18:06:32.897481+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T17:05:00+00:00 PythonOperator 2021-04-30T18:06:13.590322+00:00 2021-04-30T18:06:16.699661+00:00 0:00:03.109339 23003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T18:06:10.936213+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T17:00:00+00:00 EmrJobFlowSensor 2021-04-30T18:01:06.415474+00:00 2021-04-30T18:10:09.113581+00:00 0:09:02.698107 23001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T18:01:04.289441+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T18:00:46.389158+00:00 2021-04-30T18:00:48.095177+00:00 0:00:01.706019 23000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T18:00:44.228416+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T17:00:00+00:00 PythonOperator 2021-04-30T18:00:25.109305+00:00 2021-04-30T18:00:28.095525+00:00 0:00:02.986220 22999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T18:00:22.268493+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T16:00:00+00:00 EmrJobFlowSensor 2021-04-30T17:12:27.855456+00:00 2021-04-30T17:20:30.306505+00:00 0:08:02.451049 22998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T17:12:25.591245+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T16:00:00+00:00 EmrJobFlowSensor 2021-04-30T17:12:21.738653+00:00 2021-04-30T17:21:24.396811+00:00 0:09:02.658158 22997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T17:12:19.535815+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T17:12:05.723574+00:00 2021-04-30T17:12:07.431531+00:00 0:00:01.707957 22996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T17:12:03.520849+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T17:12:00.028486+00:00 2021-04-30T17:12:01.924315+00:00 0:00:01.895829 22995 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T17:11:57.567043+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T16:00:00+00:00 PythonOperator 2021-04-30T17:11:43.705617+00:00 2021-04-30T17:11:46.697629+00:00 0:00:02.992012 22994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T17:11:41.497476+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T16:00:00+00:00 PythonOperator 2021-04-30T17:11:39.767178+00:00 2021-04-30T17:11:43.037365+00:00 0:00:03.270187 22993 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T17:11:37.501353+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T16:00:00+00:00 TriggerDagRunOperator 2021-04-30T17:11:26.168264+00:00 2021-04-30T17:11:26.566479+00:00 0:00:00.398215 22992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T17:11:23.484809+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T16:00:00+00:00 TriggerDagRunOperator 2021-04-30T17:11:25.799829+00:00 2021-04-30T17:11:26.344693+00:00 0:00:00.544864 22991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T17:11:23.484838+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-30T16:05:00+00:00 EmrJobFlowSensor 2021-04-30T17:06:06.971883+00:00 2021-04-30T17:15:09.593158+00:00 0:09:02.621275 22990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T17:06:04.771023+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T17:05:46.908509+00:00 2021-04-30T17:05:48.629906+00:00 0:00:01.721397 22989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T17:05:44.740751+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T16:05:00+00:00 PythonOperator 2021-04-30T17:05:25.030145+00:00 2021-04-30T17:05:28.083119+00:00 0:00:03.052974 22988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T17:05:22.714943+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T16:00:00+00:00 EmrJobFlowSensor 2021-04-30T17:02:14.744482+00:00 2021-04-30T17:11:17.432407+00:00 0:09:02.687925 22987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T17:02:12.380405+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T17:01:54.541232+00:00 2021-04-30T17:01:56.371092+00:00 0:00:01.829860 22986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T17:01:52.305273+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T16:00:00+00:00 PythonOperator 2021-04-30T17:01:32.933052+00:00 2021-04-30T17:01:35.967719+00:00 0:00:03.034667 22985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T17:01:30.288222+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T15:00:00+00:00 EmrJobFlowSensor 2021-04-30T16:19:27.521915+00:00 2021-04-30T16:29:30.342150+00:00 0:10:02.820235 22983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T16:19:25.206002+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T15:00:00+00:00 EmrJobFlowSensor 2021-04-30T16:19:17.429737+00:00 2021-04-30T16:38:21.667476+00:00 0:19:04.237739 22982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T16:19:15.198230+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T16:19:05.476397+00:00 2021-04-30T16:19:07.293283+00:00 0:00:01.816886 22981 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T16:19:03.186798+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T16:18:55.426917+00:00 2021-04-30T16:18:57.123607+00:00 0:00:01.696690 22980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T16:18:53.163414+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T15:00:00+00:00 PythonOperator 2021-04-30T16:18:43.548233+00:00 2021-04-30T16:18:46.893649+00:00 0:00:03.345416 22979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T16:18:41.171925+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T15:00:00+00:00 PythonOperator 2021-04-30T16:18:35.456477+00:00 2021-04-30T16:18:38.415725+00:00 0:00:02.959248 22978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T16:18:33.160659+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T15:00:00+00:00 TriggerDagRunOperator 2021-04-30T16:18:19.714108+00:00 2021-04-30T16:18:20.263511+00:00 0:00:00.549403 22977 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T16:18:17.152235+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T15:00:00+00:00 TriggerDagRunOperator 2021-04-30T16:18:19.468672+00:00 2021-04-30T16:18:19.878624+00:00 0:00:00.409952 22976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T16:18:17.152263+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-30T15:05:00+00:00 EmrJobFlowSensor 2021-04-30T16:05:46.029370+00:00 2021-04-30T16:14:48.701353+00:00 0:09:02.671983 22975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T16:05:43.657254+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T16:05:25.855183+00:00 2021-04-30T16:05:27.554130+00:00 0:00:01.698947 22974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T16:05:23.587418+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T15:05:00+00:00 PythonOperator 2021-04-30T16:05:03.680661+00:00 2021-04-30T16:05:06.701363+00:00 0:00:03.020702 22973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T16:05:01.542008+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T15:00:00+00:00 EmrJobFlowSensor 2021-04-30T16:00:59.645996+00:00 2021-04-30T16:18:03.616238+00:00 0:17:03.970242 22972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T16:00:57.060913+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T16:00:37.116585+00:00 2021-04-30T16:00:38.802683+00:00 0:00:01.686098 22971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T16:00:34.927303+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T15:00:00+00:00 PythonOperator 2021-04-30T16:00:17.533719+00:00 2021-04-30T16:00:20.549214+00:00 0:00:03.015495 22970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T16:00:14.907683+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T14:00:00+00:00 EmrJobFlowSensor 2021-04-30T15:11:07.295927+00:00 2021-04-30T15:21:10.137443+00:00 0:10:02.841516 22968 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T15:11:04.964705+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T14:00:00+00:00 EmrJobFlowSensor 2021-04-30T15:11:03.215863+00:00 2021-04-30T15:19:05.821121+00:00 0:08:02.605258 22967 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T15:11:00.893805+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T15:10:47.013507+00:00 2021-04-30T15:10:48.830478+00:00 0:00:01.816971 22966 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T15:10:44.817788+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T15:10:40.988790+00:00 2021-04-30T15:10:42.669527+00:00 0:00:01.680737 22965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T15:10:38.811626+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T14:00:00+00:00 PythonOperator 2021-04-30T15:10:25.221175+00:00 2021-04-30T15:10:28.711538+00:00 0:00:03.490363 22964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T15:10:22.801139+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T14:00:00+00:00 PythonOperator 2021-04-30T15:10:19.115282+00:00 2021-04-30T15:10:22.208265+00:00 0:00:03.092983 22963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T15:10:16.797663+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T14:00:00+00:00 TriggerDagRunOperator 2021-04-30T15:10:13.175897+00:00 2021-04-30T15:10:13.723182+00:00 0:00:00.547285 22962 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T15:10:10.865267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T14:00:00+00:00 TriggerDagRunOperator 2021-04-30T15:10:13.122230+00:00 2021-04-30T15:10:13.527558+00:00 0:00:00.405328 22961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T15:10:10.865234+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-30T14:05:00+00:00 EmrJobFlowSensor 2021-04-30T15:06:00.689873+00:00 2021-04-30T15:15:03.381663+00:00 0:09:02.691790 22960 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T15:05:58.440983+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T15:05:38.434828+00:00 2021-04-30T15:05:40.107435+00:00 0:00:01.672607 22959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T15:05:36.300273+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T14:05:00+00:00 PythonOperator 2021-04-30T15:05:16.608545+00:00 2021-04-30T15:05:19.639757+00:00 0:00:03.031212 22958 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T15:05:14.276538+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T14:00:00+00:00 EmrJobFlowSensor 2021-04-30T15:00:56.302548+00:00 2021-04-30T15:09:59.080655+00:00 0:09:02.778107 22957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T15:00:53.940085+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T15:00:32.410923+00:00 2021-04-30T15:00:34.292844+00:00 0:00:01.881921 22956 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T15:00:29.971081+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T14:00:00+00:00 PythonOperator 2021-04-30T15:00:10.189168+00:00 2021-04-30T15:00:13.194729+00:00 0:00:03.005561 22955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T15:00:07.899928+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T13:00:00+00:00 EmrJobFlowSensor 2021-04-30T14:23:54.596662+00:00 2021-04-30T14:31:57.038630+00:00 0:08:02.441968 22954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T14:23:52.310108+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T13:00:00+00:00 EmrJobFlowSensor 2021-04-30T14:23:46.417041+00:00 2021-04-30T14:33:49.100755+00:00 0:10:02.683714 22953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T14:23:44.295090+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T14:23:34.833326+00:00 2021-04-30T14:23:36.614004+00:00 0:00:01.780678 22952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T14:23:32.290742+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T14:23:24.783541+00:00 2021-04-30T14:23:26.576832+00:00 0:00:01.793291 22951 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T14:23:22.262077+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T13:00:00+00:00 PythonOperator 2021-04-30T14:23:08.464006+00:00 2021-04-30T14:23:11.591761+00:00 0:00:03.127755 22950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T14:23:06.219669+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T13:00:00+00:00 PythonOperator 2021-04-30T14:22:48.470664+00:00 2021-04-30T14:22:51.854829+00:00 0:00:03.384165 22949 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T14:22:46.203720+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T13:00:00+00:00 TriggerDagRunOperator 2021-04-30T14:22:44.557654+00:00 2021-04-30T14:22:45.141117+00:00 0:00:00.583463 22948 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T14:22:42.194950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T13:00:00+00:00 TriggerDagRunOperator 2021-04-30T14:22:44.420159+00:00 2021-04-30T14:22:44.834822+00:00 0:00:00.414663 22947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T14:22:42.194923+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-30T13:05:00+00:00 EmrJobFlowSensor 2021-04-30T14:12:35.475306+00:00 2021-04-30T14:21:38.097864+00:00 0:09:02.622558 22946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T14:12:33.301291+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T13:00:00+00:00 EmrJobFlowSensor 2021-04-30T14:12:25.664062+00:00 2021-04-30T14:22:28.571773+00:00 0:10:02.907711 22945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T14:12:23.350617+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T14:12:15.579370+00:00 2021-04-30T14:12:17.229050+00:00 0:00:01.649680 22944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T14:12:13.287006+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T14:12:03.452087+00:00 2021-04-30T14:12:05.201763+00:00 0:00:01.749676 22943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T14:12:01.231488+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T13:05:00+00:00 PythonOperator 2021-04-30T14:11:53.388847+00:00 2021-04-30T14:11:56.425246+00:00 0:00:03.036399 22942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T14:11:51.222258+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T13:00:00+00:00 PythonOperator 2021-04-30T14:11:43.838765+00:00 2021-04-30T14:11:46.935001+00:00 0:00:03.096236 22941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T14:11:41.217585+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T12:00:00+00:00 EmrJobFlowSensor 2021-04-30T13:11:57.521415+00:00 2021-04-30T13:21:00.077310+00:00 0:09:02.555895 22939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T13:11:55.368291+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T12:00:00+00:00 EmrJobFlowSensor 2021-04-30T13:11:49.720453+00:00 2021-04-30T13:21:52.639554+00:00 0:10:02.919101 22938 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T13:11:47.361173+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T13:11:37.667270+00:00 2021-04-30T13:11:39.326902+00:00 0:00:01.659632 22937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T13:11:35.356123+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T13:11:27.784872+00:00 2021-04-30T13:11:29.465774+00:00 0:00:01.680902 22936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T13:11:25.447881+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T12:00:00+00:00 PythonOperator 2021-04-30T13:11:16.253916+00:00 2021-04-30T13:11:19.322084+00:00 0:00:03.068168 22935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T13:11:13.360626+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T12:00:00+00:00 PythonOperator 2021-04-30T13:11:07.916316+00:00 2021-04-30T13:11:11.188193+00:00 0:00:03.271877 22934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T13:11:05.294263+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T12:00:00+00:00 TriggerDagRunOperator 2021-04-30T13:11:00.245305+00:00 2021-04-30T13:11:00.810342+00:00 0:00:00.565037 22933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T13:10:57.347426+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T12:00:00+00:00 TriggerDagRunOperator 2021-04-30T13:10:59.942080+00:00 2021-04-30T13:11:00.417998+00:00 0:00:00.475918 22932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T13:10:57.347374+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-30T12:05:00+00:00 EmrJobFlowSensor 2021-04-30T13:05:59.334893+00:00 2021-04-30T13:15:02.025370+00:00 0:09:02.690477 22931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T13:05:56.826824+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T13:05:36.939122+00:00 2021-04-30T13:05:38.573231+00:00 0:00:01.634109 22930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T13:05:34.790896+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T12:05:00+00:00 PythonOperator 2021-04-30T13:05:14.906359+00:00 2021-04-30T13:05:17.960929+00:00 0:00:03.054570 22929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T13:05:12.719266+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T12:00:00+00:00 EmrJobFlowSensor 2021-04-30T13:00:52.402260+00:00 2021-04-30T13:10:55.268914+00:00 0:10:02.866654 22928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T13:00:50.182464+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T13:00:32.461986+00:00 2021-04-30T13:00:34.381158+00:00 0:00:01.919172 22927 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T13:00:30.136154+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T12:00:00+00:00 PythonOperator 2021-04-30T13:00:04.762396+00:00 2021-04-30T13:00:07.850512+00:00 0:00:03.088116 22926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T13:00:02.111296+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T11:00:00+00:00 EmrJobFlowSensor 2021-04-30T12:12:20.309551+00:00 2021-04-30T12:21:23.069796+00:00 0:09:02.760245 22924 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T12:12:18.032665+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T11:00:00+00:00 EmrJobFlowSensor 2021-04-30T12:12:12.175910+00:00 2021-04-30T12:22:14.956587+00:00 0:10:02.780677 22923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T12:12:10.025949+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T12:11:59.019798+00:00 2021-04-30T12:12:00.803031+00:00 0:00:01.783233 22922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T12:11:56.060601+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T12:11:50.400920+00:00 2021-04-30T12:11:52.201351+00:00 0:00:01.800431 22921 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T12:11:48.067763+00:00 2 default_pool