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 create_cluster_and_add_emr_steps 2021-04-09T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T11:11:10.034155+00:00 2021-04-09T11:11:11.714105+00:00 0:00:01.679950 15266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T11:11:07.458267+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T10:00:00+00:00 PythonOperator 2021-04-09T11:10:57.624995+00:00 2021-04-09T11:11:00.555464+00:00 0:00:02.930469 15265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T11:10:55.446612+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T10:00:00+00:00 PythonOperator 2021-04-09T11:10:49.907284+00:00 2021-04-09T11:10:52.760564+00:00 0:00:02.853280 15264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T11:10:47.439872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T10:00:00+00:00 TriggerDagRunOperator 2021-04-09T11:10:40.090855+00:00 2021-04-09T11:10:40.547283+00:00 0:00:00.456428 15263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T11:10:37.434516+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T10:00:00+00:00 TriggerDagRunOperator 2021-04-09T11:10:40.090632+00:00 2021-04-09T11:10:40.659770+00:00 0:00:00.569138 15262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T11:10:37.434480+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T10:05:00+00:00 EmrJobFlowSensor 2021-04-09T11:05:53.442856+00:00 2021-04-09T11:14:56.048154+00:00 0:09:02.605298 15261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T11:05:51.063457+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T11:05:33.537227+00:00 2021-04-09T11:05:35.290827+00:00 0:00:01.753600 15260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T11:05:31.150327+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T10:05:00+00:00 PythonOperator 2021-04-09T11:05:11.029146+00:00 2021-04-09T11:05:13.739396+00:00 0:00:02.710250 15259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T11:05:08.876389+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T10:00:00+00:00 EmrJobFlowSensor 2021-04-09T11:01:13.087601+00:00 2021-04-09T11:10:15.905736+00:00 0:09:02.818135 15258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T11:01:10.572700+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T11:00:42.771129+00:00 2021-04-09T11:00:44.532153+00:00 0:00:01.761024 15257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T11:00:40.499295+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T10:00:00+00:00 PythonOperator 2021-04-09T11:00:19.018399+00:00 2021-04-09T11:00:21.841059+00:00 0:00:02.822660 15256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T11:00:16.409727+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T09:00:00+00:00 EmrJobFlowSensor 2021-04-09T10:11:32.625609+00:00 2021-04-09T10:21:35.296469+00:00 0:10:02.670860 15254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T10:11:29.751291+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T09:00:00+00:00 EmrJobFlowSensor 2021-04-09T10:11:30.215123+00:00 2021-04-09T10:20:33.099162+00:00 0:09:02.884039 15253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T10:11:27.740706+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T10:11:10.520107+00:00 2021-04-09T10:11:12.248433+00:00 0:00:01.728326 15252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T10:11:07.579886+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T10:11:08.149176+00:00 2021-04-09T10:11:10.239365+00:00 0:00:02.090189 15251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T10:11:05.575577+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T09:00:00+00:00 PythonOperator 2021-04-09T10:10:47.851058+00:00 2021-04-09T10:10:50.813422+00:00 0:00:02.962364 15250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T10:10:45.499419+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T09:00:00+00:00 PythonOperator 2021-04-09T10:10:47.739566+00:00 2021-04-09T10:10:50.762353+00:00 0:00:03.022787 15249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T10:10:45.499385+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T09:00:00+00:00 TriggerDagRunOperator 2021-04-09T10:10:28.085789+00:00 2021-04-09T10:10:28.617363+00:00 0:00:00.531574 15248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T10:10:25.482998+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T09:00:00+00:00 TriggerDagRunOperator 2021-04-09T10:10:27.923973+00:00 2021-04-09T10:10:28.309864+00:00 0:00:00.385891 15247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T10:10:25.483027+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T09:05:00+00:00 EmrJobFlowSensor 2021-04-09T10:06:03.351056+00:00 2021-04-09T10:15:06.055989+00:00 0:09:02.704933 15246 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T10:06:01.036082+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T10:05:39.456922+00:00 2021-04-09T10:05:41.137807+00:00 0:00:01.680885 15245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T10:05:37.083244+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T09:05:00+00:00 PythonOperator 2021-04-09T10:05:17.326642+00:00 2021-04-09T10:05:20.148520+00:00 0:00:02.821878 15244 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T10:05:15.056161+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T09:00:00+00:00 EmrJobFlowSensor 2021-04-09T10:01:06.879768+00:00 2021-04-09T10:10:09.552830+00:00 0:09:02.673062 15243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T10:01:04.443776+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T10:00:42.722020+00:00 2021-04-09T10:00:44.542082+00:00 0:00:01.820062 15242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T10:00:40.423159+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T09:00:00+00:00 PythonOperator 2021-04-09T10:00:22.722811+00:00 2021-04-09T10:00:25.505018+00:00 0:00:02.782207 15241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T10:00:20.411017+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T08:00:00+00:00 EmrJobFlowSensor 2021-04-09T09:11:21.580725+00:00 2021-04-09T09:21:24.393801+00:00 0:10:02.813076 15239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T09:11:19.074844+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T08:00:00+00:00 EmrJobFlowSensor 2021-04-09T09:11:19.400994+00:00 2021-04-09T09:20:22.146622+00:00 0:09:02.745628 15238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T09:11:17.063124+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T09:11:01.956564+00:00 2021-04-09T09:11:03.899087+00:00 0:00:01.942523 15237 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T09:10:59.378398+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T09:10:59.324052+00:00 2021-04-09T09:11:01.246681+00:00 0:00:01.922629 15236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T09:10:56.607796+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T08:00:00+00:00 PythonOperator 2021-04-09T09:10:38.924969+00:00 2021-04-09T09:10:41.958749+00:00 0:00:03.033780 15235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T09:10:36.644078+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T08:00:00+00:00 PythonOperator 2021-04-09T09:10:37.055401+00:00 2021-04-09T09:10:39.789091+00:00 0:00:02.733690 15234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T09:10:34.650527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T08:00:00+00:00 TriggerDagRunOperator 2021-04-09T09:10:17.032487+00:00 2021-04-09T09:10:17.457444+00:00 0:00:00.424957 15233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T09:10:14.523618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T08:00:00+00:00 TriggerDagRunOperator 2021-04-09T09:10:17.046331+00:00 2021-04-09T09:10:17.602514+00:00 0:00:00.556183 15232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T09:10:14.523654+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T08:05:00+00:00 EmrJobFlowSensor 2021-04-09T09:05:54.330485+00:00 2021-04-09T09:14:56.955439+00:00 0:09:02.624954 15231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T09:05:52.021666+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T09:05:34.225113+00:00 2021-04-09T09:05:35.908506+00:00 0:00:01.683393 15230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T09:05:32.005314+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T08:05:00+00:00 PythonOperator 2021-04-09T09:05:12.074300+00:00 2021-04-09T09:05:14.735452+00:00 0:00:02.661152 15229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T09:05:09.983425+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T08:00:00+00:00 EmrJobFlowSensor 2021-04-09T09:00:55.902274+00:00 2021-04-09T09:09:58.686677+00:00 0:09:02.784403 15228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T09:00:53.521297+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T09:00:31.925006+00:00 2021-04-09T09:00:33.614555+00:00 0:00:01.689549 15227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T09:00:29.560469+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T08:00:00+00:00 PythonOperator 2021-04-09T09:00:10.115129+00:00 2021-04-09T09:00:12.868951+00:00 0:00:02.753822 15226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T09:00:07.469512+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T07:00:00+00:00 EmrJobFlowSensor 2021-04-09T08:10:29.128645+00:00 2021-04-09T08:19:31.919801+00:00 0:09:02.791156 15224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T08:10:26.834282+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T07:00:00+00:00 EmrJobFlowSensor 2021-04-09T08:10:20.995707+00:00 2021-04-09T08:20:23.702135+00:00 0:10:02.706428 15223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T08:10:18.825487+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T08:10:07.220365+00:00 2021-04-09T08:10:09.131261+00:00 0:00:01.910896 15222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T08:10:04.814883+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T08:09:59.076377+00:00 2021-04-09T08:10:00.741360+00:00 0:00:01.664983 15221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T08:09:56.805636+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T07:00:00+00:00 PythonOperator 2021-04-09T08:09:45.252628+00:00 2021-04-09T08:09:48.174694+00:00 0:00:02.922066 15220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T08:09:42.856941+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T07:00:00+00:00 PythonOperator 2021-04-09T08:09:36.907363+00:00 2021-04-09T08:09:39.609739+00:00 0:00:02.702376 15219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T08:09:34.788290+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T07:00:00+00:00 TriggerDagRunOperator 2021-04-09T08:09:21.062459+00:00 2021-04-09T08:09:21.573360+00:00 0:00:00.510901 15218 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T08:09:18.731725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T07:00:00+00:00 TriggerDagRunOperator 2021-04-09T08:09:20.917672+00:00 2021-04-09T08:09:21.330748+00:00 0:00:00.413076 15217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T08:09:18.731681+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T07:05:00+00:00 EmrJobFlowSensor 2021-04-09T08:06:02.603937+00:00 2021-04-09T08:14:05.104291+00:00 0:08:02.500354 15216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T08:06:00.432283+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T08:05:40.650634+00:00 2021-04-09T08:05:42.325393+00:00 0:00:01.674759 15215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T08:05:38.455097+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T07:05:00+00:00 PythonOperator 2021-04-09T08:05:20.685459+00:00 2021-04-09T08:05:23.389281+00:00 0:00:02.703822 15214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T08:05:18.458067+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T07:00:00+00:00 EmrJobFlowSensor 2021-04-09T08:01:02.290996+00:00 2021-04-09T08:09:04.995338+00:00 0:08:02.704342 15213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T08:00:59.894112+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T08:00:40.179261+00:00 2021-04-09T08:00:42.036689+00:00 0:00:01.857428 15212 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T08:00:37.874346+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T07:00:00+00:00 PythonOperator 2021-04-09T08:00:20.405195+00:00 2021-04-09T08:00:23.270270+00:00 0:00:02.865075 15211 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T08:00:17.858127+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T06:00:00+00:00 EmrJobFlowSensor 2021-04-09T07:10:21.514805+00:00 2021-04-09T07:19:24.234490+00:00 0:09:02.719685 15209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T07:10:19.353386+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T06:00:00+00:00 EmrJobFlowSensor 2021-04-09T07:10:03.787826+00:00 2021-04-09T07:20:06.674870+00:00 0:10:02.887044 15208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T07:10:01.282404+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T07:09:59.808007+00:00 2021-04-09T07:10:01.792750+00:00 0:00:01.984743 15207 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T07:09:57.265475+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T07:09:43.610460+00:00 2021-04-09T07:09:45.333591+00:00 0:00:01.723131 15206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T07:09:41.184197+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T06:00:00+00:00 PythonOperator 2021-04-09T07:09:39.507920+00:00 2021-04-09T07:09:42.608073+00:00 0:00:03.100153 15205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T07:09:37.190444+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T06:00:00+00:00 PythonOperator 2021-04-09T07:09:21.309653+00:00 2021-04-09T07:09:24.129228+00:00 0:00:02.819575 15204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T07:09:19.135817+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T06:00:00+00:00 TriggerDagRunOperator 2021-04-09T07:09:09.519675+00:00 2021-04-09T07:09:10.048206+00:00 0:00:00.528531 15203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T07:09:07.137584+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T06:00:00+00:00 TriggerDagRunOperator 2021-04-09T07:09:09.411847+00:00 2021-04-09T07:09:09.836986+00:00 0:00:00.425139 15202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T07:09:07.137556+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T06:05:00+00:00 EmrJobFlowSensor 2021-04-09T07:06:02.932870+00:00 2021-04-09T07:14:05.379233+00:00 0:08:02.446363 15201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T07:06:00.737776+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T07:05:41.065168+00:00 2021-04-09T07:05:42.815722+00:00 0:00:01.750554 15200 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T07:05:38.843714+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T06:05:00+00:00 PythonOperator 2021-04-09T07:05:20.975324+00:00 2021-04-09T07:05:23.758884+00:00 0:00:02.783560 15199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T07:05:18.705859+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T06:00:00+00:00 EmrJobFlowSensor 2021-04-09T07:00:50.529224+00:00 2021-04-09T07:08:53.169281+00:00 0:08:02.640057 15198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T07:00:48.296465+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T07:00:30.745367+00:00 2021-04-09T07:00:32.520161+00:00 0:00:01.774794 15197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T07:00:28.366400+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T06:00:00+00:00 PythonOperator 2021-04-09T07:00:08.902419+00:00 2021-04-09T07:00:11.754427+00:00 0:00:02.852008 15196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T07:00:06.243605+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T05:00:00+00:00 EmrJobFlowSensor 2021-04-09T06:12:08.773246+00:00 2021-04-09T06:23:11.778481+00:00 0:11:03.005235 15194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T06:12:06.299781+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T05:00:00+00:00 EmrJobFlowSensor 2021-04-09T06:12:08.552330+00:00 2021-04-09T06:21:11.270075+00:00 0:09:02.717745 15193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T06:12:06.299814+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T06:11:49.020762+00:00 2021-04-09T06:11:50.714678+00:00 0:00:01.693916 15192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T06:11:46.279940+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T06:11:46.400981+00:00 2021-04-09T06:11:48.570270+00:00 0:00:02.169289 15191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T06:11:44.278993+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T05:00:00+00:00 PythonOperator 2021-04-09T06:11:26.718971+00:00 2021-04-09T06:11:29.823334+00:00 0:00:03.104363 15190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T06:11:24.279026+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T05:00:00+00:00 PythonOperator 2021-04-09T06:11:24.748664+00:00 2021-04-09T06:11:27.442333+00:00 0:00:02.693669 15189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T06:11:22.273996+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T05:00:00+00:00 TriggerDagRunOperator 2021-04-09T06:11:06.999501+00:00 2021-04-09T06:11:07.553007+00:00 0:00:00.553506 15188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T06:11:04.256142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T05:00:00+00:00 TriggerDagRunOperator 2021-04-09T06:11:06.669046+00:00 2021-04-09T06:11:07.161902+00:00 0:00:00.492856 15187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T06:11:04.256110+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T05:05:00+00:00 EmrJobFlowSensor 2021-04-09T06:06:00.172287+00:00 2021-04-09T06:15:02.959841+00:00 0:09:02.787554 15186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T06:05:57.847518+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T06:05:39.957419+00:00 2021-04-09T06:05:41.718976+00:00 0:00:01.761557 15185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T06:05:37.717422+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T05:05:00+00:00 PythonOperator 2021-04-09T06:05:18.178780+00:00 2021-04-09T06:05:21.001207+00:00 0:00:02.822427 15184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T06:05:15.751279+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T05:00:00+00:00 EmrJobFlowSensor 2021-04-09T06:00:55.671521+00:00 2021-04-09T06:10:58.531515+00:00 0:10:02.859994 15183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T06:00:53.224595+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T06:00:35.538917+00:00 2021-04-09T06:00:37.245314+00:00 0:00:01.706397 15182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T06:00:33.213814+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T05:00:00+00:00 PythonOperator 2021-04-09T06:00:13.514450+00:00 2021-04-09T06:00:16.300855+00:00 0:00:02.786405 15181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T06:00:11.190325+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T04:00:00+00:00 EmrJobFlowSensor 2021-04-09T05:11:11.424589+00:00 2021-04-09T05:20:14.156720+00:00 0:09:02.732131 15179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T05:11:09.192601+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T04:00:00+00:00 EmrJobFlowSensor 2021-04-09T05:11:07.405103+00:00 2021-04-09T05:21:10.157612+00:00 0:10:02.752509 15178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T05:11:05.188242+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T05:10:51.260218+00:00 2021-04-09T05:10:52.933859+00:00 0:00:01.673641 15177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T05:10:49.129954+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T05:10:45.722957+00:00 2021-04-09T05:10:47.524114+00:00 0:00:01.801157 15176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T05:10:43.181199+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T04:00:00+00:00 PythonOperator 2021-04-09T05:10:29.738874+00:00 2021-04-09T05:10:32.508174+00:00 0:00:02.769300 15175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T05:10:27.117039+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T04:00:00+00:00 PythonOperator 2021-04-09T05:10:23.925650+00:00 2021-04-09T05:10:27.091442+00:00 0:00:03.165792 15174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T05:10:21.163222+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T04:00:00+00:00 TriggerDagRunOperator 2021-04-09T05:10:17.600422+00:00 2021-04-09T05:10:18.122293+00:00 0:00:00.521871 15173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T05:10:15.111916+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T04:00:00+00:00 TriggerDagRunOperator 2021-04-09T05:10:17.279832+00:00 2021-04-09T05:10:17.717649+00:00 0:00:00.437817 15172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T05:10:15.111951+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T04:05:00+00:00 EmrJobFlowSensor 2021-04-09T05:05:52.887352+00:00 2021-04-09T05:13:55.273383+00:00 0:08:02.386031 15171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T05:05:50.701582+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T05:05:32.885700+00:00 2021-04-09T05:05:34.639990+00:00 0:00:01.754290 15170 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T05:05:30.683971+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T04:05:00+00:00 PythonOperator 2021-04-09T05:05:10.804807+00:00 2021-04-09T05:05:13.529829+00:00 0:00:02.725022 15169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T05:05:08.660988+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T04:00:00+00:00 EmrJobFlowSensor 2021-04-09T05:00:52.230187+00:00 2021-04-09T05:09:54.951544+00:00 0:09:02.721357 15168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T05:00:49.983399+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T05:00:32.119843+00:00 2021-04-09T05:00:33.867925+00:00 0:00:01.748082 15167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T05:00:29.930392+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T04:00:00+00:00 PythonOperator 2021-04-09T05:00:10.547747+00:00 2021-04-09T05:00:13.401389+00:00 0:00:02.853642 15166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T05:00:07.909833+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T03:00:00+00:00 EmrJobFlowSensor 2021-04-09T04:12:21.535194+00:00 2021-04-09T04:21:24.172004+00:00 0:09:02.636810 15164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T04:12:19.394438+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T03:00:00+00:00 EmrJobFlowSensor 2021-04-09T04:12:17.679490+00:00 2021-04-09T04:23:20.645407+00:00 0:11:02.965917 15163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T04:12:15.389438+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T04:11:59.733018+00:00 2021-04-09T04:12:01.448153+00:00 0:00:01.715135 15162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T04:11:57.363068+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T04:11:55.572597+00:00 2021-04-09T04:11:57.300436+00:00 0:00:01.727839 15161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T04:11:53.296071+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T03:00:00+00:00 PythonOperator 2021-04-09T04:11:39.813388+00:00 2021-04-09T04:11:42.673261+00:00 0:00:02.859873 15160 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T04:11:37.293652+00:00 2 default_pool