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-flow-job_v002 create_emr_steps 2021-04-17T20:00:00+00:00 PythonOperator 2021-04-17T21:00:25.213323+00:00 2021-04-17T21:00:28.430236+00:00 0:00:03.216913 18306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T21:00:22.031821+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T19:00:00+00:00 EmrJobFlowSensor 2021-04-17T20:12:30.467938+00:00 2021-04-17T20:21:33.060920+00:00 0:09:02.592982 18304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T20:12:28.208218+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T19:00:00+00:00 EmrJobFlowSensor 2021-04-17T20:12:22.425918+00:00 2021-04-17T20:22:25.332710+00:00 0:10:02.906792 18303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T20:12:20.200874+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T20:12:10.388443+00:00 2021-04-17T20:12:12.104343+00:00 0:00:01.715900 18302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T20:12:08.189250+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T20:12:00.742637+00:00 2021-04-17T20:12:02.668735+00:00 0:00:01.926098 18301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T20:11:58.182486+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T19:00:00+00:00 PythonOperator 2021-04-17T20:11:48.519886+00:00 2021-04-17T20:11:51.883135+00:00 0:00:03.363249 18300 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T20:11:46.167127+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T19:00:00+00:00 PythonOperator 2021-04-17T20:11:40.394177+00:00 2021-04-17T20:11:43.786845+00:00 0:00:03.392668 18299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T20:11:38.159481+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T19:00:00+00:00 TriggerDagRunOperator 2021-04-17T20:11:22.592645+00:00 2021-04-17T20:11:23.139149+00:00 0:00:00.546504 18298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T20:11:20.147215+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T19:00:00+00:00 TriggerDagRunOperator 2021-04-17T20:11:22.378476+00:00 2021-04-17T20:11:22.808744+00:00 0:00:00.430268 18297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T20:11:20.147248+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T19:05:00+00:00 EmrJobFlowSensor 2021-04-17T20:06:08.398428+00:00 2021-04-17T20:15:11.085553+00:00 0:09:02.687125 18296 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T20:06:05.631922+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T20:05:47.686681+00:00 2021-04-17T20:05:49.528962+00:00 0:00:01.842281 18295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T20:05:45.557696+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T19:05:00+00:00 PythonOperator 2021-04-17T20:05:25.781469+00:00 2021-04-17T20:05:28.697302+00:00 0:00:02.915833 18294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T20:05:23.537778+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T19:00:00+00:00 EmrJobFlowSensor 2021-04-17T20:01:07.402190+00:00 2021-04-17T20:11:10.202611+00:00 0:10:02.800421 18293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T20:01:05.132164+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T20:00:45.393890+00:00 2021-04-17T20:00:47.214428+00:00 0:00:01.820538 18292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T20:00:43.101108+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T19:00:00+00:00 PythonOperator 2021-04-17T20:00:23.847691+00:00 2021-04-17T20:00:26.849742+00:00 0:00:03.002051 18291 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T20:00:21.140668+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T18:00:00+00:00 EmrJobFlowSensor 2021-04-17T19:12:45.177653+00:00 2021-04-17T19:21:47.767459+00:00 0:09:02.589806 18289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T19:12:42.941436+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T18:00:00+00:00 EmrJobFlowSensor 2021-04-17T19:12:37.409362+00:00 2021-04-17T19:21:40.206378+00:00 0:09:02.797016 18288 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T19:12:34.943792+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T19:12:21.094578+00:00 2021-04-17T19:12:22.839482+00:00 0:00:01.744904 18287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T19:12:18.921798+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T19:12:03.285160+00:00 2021-04-17T19:12:05.101914+00:00 0:00:01.816754 18286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T19:12:00.902288+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T18:00:00+00:00 PythonOperator 2021-04-17T19:11:55.267278+00:00 2021-04-17T19:11:58.533395+00:00 0:00:03.266117 18285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T19:11:52.895221+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T18:00:00+00:00 PythonOperator 2021-04-17T19:11:39.888963+00:00 2021-04-17T19:11:42.797351+00:00 0:00:02.908388 18284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T19:11:36.940850+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T18:00:00+00:00 TriggerDagRunOperator 2021-04-17T19:11:27.703337+00:00 2021-04-17T19:11:28.662558+00:00 0:00:00.959221 18283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T19:11:24.765743+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T18:00:00+00:00 TriggerDagRunOperator 2021-04-17T19:11:27.489458+00:00 2021-04-17T19:11:28.227116+00:00 0:00:00.737658 18282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T19:11:24.765688+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T18:05:00+00:00 EmrJobFlowSensor 2021-04-17T19:06:06.404175+00:00 2021-04-17T19:15:09.084741+00:00 0:09:02.680566 18281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T19:06:04.240853+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T19:05:40.403337+00:00 2021-04-17T19:05:42.052843+00:00 0:00:01.649506 18280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T19:05:38.223261+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T18:05:00+00:00 PythonOperator 2021-04-17T19:05:18.430338+00:00 2021-04-17T19:05:21.499083+00:00 0:00:03.068745 18279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T19:05:16.189700+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T18:00:00+00:00 EmrJobFlowSensor 2021-04-17T19:01:04.277355+00:00 2021-04-17T19:11:07.286552+00:00 0:10:03.009197 18278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T19:01:01.860087+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T19:00:42.275607+00:00 2021-04-17T19:00:44.024448+00:00 0:00:01.748841 18277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T19:00:39.872065+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T18:00:00+00:00 PythonOperator 2021-04-17T19:00:20.155388+00:00 2021-04-17T19:00:23.061447+00:00 0:00:02.906059 18276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T19:00:17.800756+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T17:00:00+00:00 EmrJobFlowSensor 2021-04-17T18:11:06.759282+00:00 2021-04-17T18:21:10.398913+00:00 0:10:03.639631 18274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T18:11:04.449238+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T17:00:00+00:00 EmrJobFlowSensor 2021-04-17T18:11:00.993712+00:00 2021-04-17T18:21:03.850765+00:00 0:10:02.857053 18273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T18:10:58.461265+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T18:10:46.502053+00:00 2021-04-17T18:10:48.160808+00:00 0:00:01.658755 18272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T18:10:44.370627+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T18:10:40.588626+00:00 2021-04-17T18:10:42.420410+00:00 0:00:01.831784 18271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T18:10:38.339691+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T17:00:00+00:00 PythonOperator 2021-04-17T18:10:25.072833+00:00 2021-04-17T18:10:28.382607+00:00 0:00:03.309774 18270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T18:10:22.331233+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T17:00:00+00:00 PythonOperator 2021-04-17T18:10:19.312312+00:00 2021-04-17T18:10:22.612590+00:00 0:00:03.300278 18269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T18:10:16.364003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T17:00:00+00:00 TriggerDagRunOperator 2021-04-17T18:10:12.923913+00:00 2021-04-17T18:10:13.346640+00:00 0:00:00.422727 18268 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T18:10:10.317371+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T17:00:00+00:00 TriggerDagRunOperator 2021-04-17T18:10:12.825029+00:00 2021-04-17T18:10:13.378784+00:00 0:00:00.553755 18267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T18:10:10.317403+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T17:05:00+00:00 EmrJobFlowSensor 2021-04-17T18:05:52.084069+00:00 2021-04-17T18:14:54.644129+00:00 0:09:02.560060 18266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T18:05:49.930281+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T18:05:32.192334+00:00 2021-04-17T18:05:33.998948+00:00 0:00:01.806614 18265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T18:05:29.918572+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T17:05:00+00:00 PythonOperator 2021-04-17T18:05:10.183738+00:00 2021-04-17T18:05:13.271557+00:00 0:00:03.087819 18264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T18:05:07.952177+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T17:00:00+00:00 EmrJobFlowSensor 2021-04-17T18:00:57.867018+00:00 2021-04-17T18:10:00.443509+00:00 0:09:02.576491 18263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T18:00:55.544005+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T18:00:37.594709+00:00 2021-04-17T18:00:39.307181+00:00 0:00:01.712472 18262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T18:00:35.469358+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T17:00:00+00:00 PythonOperator 2021-04-17T18:00:15.775193+00:00 2021-04-17T18:00:19.275401+00:00 0:00:03.500208 18261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T18:00:13.390769+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T16:00:00+00:00 EmrJobFlowSensor 2021-04-17T17:11:16.810743+00:00 2021-04-17T17:21:19.527690+00:00 0:10:02.716947 18259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T17:11:14.429226+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T16:00:00+00:00 EmrJobFlowSensor 2021-04-17T17:10:56.666736+00:00 2021-04-17T17:19:59.227634+00:00 0:09:02.560898 18258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T17:10:54.409985+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T17:10:45.655025+00:00 2021-04-17T17:10:47.463906+00:00 0:00:01.808881 18257 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T17:10:42.456913+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T17:10:34.608947+00:00 2021-04-17T17:10:36.387374+00:00 0:00:01.778427 18256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T17:10:32.388159+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T16:00:00+00:00 PythonOperator 2021-04-17T17:10:24.782703+00:00 2021-04-17T17:10:27.939350+00:00 0:00:03.156647 18255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T17:10:22.317629+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T16:00:00+00:00 PythonOperator 2021-04-17T17:10:12.717035+00:00 2021-04-17T17:10:15.665810+00:00 0:00:02.948775 18254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T17:10:10.295769+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T16:00:00+00:00 TriggerDagRunOperator 2021-04-17T17:10:04.947757+00:00 2021-04-17T17:10:05.608302+00:00 0:00:00.660545 18253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T17:10:02.291042+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T16:00:00+00:00 TriggerDagRunOperator 2021-04-17T17:10:04.886004+00:00 2021-04-17T17:10:05.464399+00:00 0:00:00.578395 18252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T17:10:02.291074+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T16:05:00+00:00 EmrJobFlowSensor 2021-04-17T17:05:47.845565+00:00 2021-04-17T17:14:50.417703+00:00 0:09:02.572138 18251 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T17:05:45.696487+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T17:05:26.027658+00:00 2021-04-17T17:05:27.778891+00:00 0:00:01.751233 18250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T17:05:23.686888+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T16:05:00+00:00 PythonOperator 2021-04-17T17:05:05.755783+00:00 2021-04-17T17:05:08.822531+00:00 0:00:03.066748 18249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T17:05:03.609544+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T16:00:00+00:00 EmrJobFlowSensor 2021-04-17T17:00:47.363127+00:00 2021-04-17T17:09:50.079142+00:00 0:09:02.716015 18248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T17:00:45.149567+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T17:00:25.425438+00:00 2021-04-17T17:00:27.451269+00:00 0:00:02.025831 18247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T17:00:23.128301+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T16:00:00+00:00 PythonOperator 2021-04-17T17:00:04.062075+00:00 2021-04-17T17:00:07.074926+00:00 0:00:03.012851 18246 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T17:00:01.176108+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T15:00:00+00:00 EmrJobFlowSensor 2021-04-17T16:12:29.513175+00:00 2021-04-17T16:21:32.511585+00:00 0:09:02.998410 18244 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T16:12:27.096129+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T15:00:00+00:00 EmrJobFlowSensor 2021-04-17T16:12:27.212986+00:00 2021-04-17T16:22:29.928078+00:00 0:10:02.715092 18243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T16:12:25.086841+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T16:12:09.285185+00:00 2021-04-17T16:12:10.988243+00:00 0:00:01.703058 18242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T16:12:07.038946+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T16:12:05.494215+00:00 2021-04-17T16:12:07.276811+00:00 0:00:01.782596 18241 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T16:12:03.036174+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T15:00:00+00:00 PythonOperator 2021-04-17T16:11:43.692102+00:00 2021-04-17T16:11:46.713808+00:00 0:00:03.021706 18240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T16:11:41.016064+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T15:00:00+00:00 PythonOperator 2021-04-17T16:11:31.388555+00:00 2021-04-17T16:11:34.667391+00:00 0:00:03.278836 18239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T16:11:29.010404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T15:00:00+00:00 TriggerDagRunOperator 2021-04-17T16:11:23.724530+00:00 2021-04-17T16:11:24.268073+00:00 0:00:00.543543 18238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T16:11:21.062566+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T15:00:00+00:00 TriggerDagRunOperator 2021-04-17T16:11:23.404383+00:00 2021-04-17T16:11:23.845886+00:00 0:00:00.441503 18237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T16:11:21.062521+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T15:05:00+00:00 EmrJobFlowSensor 2021-04-17T16:05:58.664260+00:00 2021-04-17T16:15:01.279084+00:00 0:09:02.614824 18236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T16:05:56.421760+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T16:05:36.835751+00:00 2021-04-17T16:05:38.993450+00:00 0:00:02.157699 18235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T16:05:34.462793+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T15:05:00+00:00 PythonOperator 2021-04-17T16:05:14.668754+00:00 2021-04-17T16:05:17.548512+00:00 0:00:02.879758 18234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T16:05:12.360865+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T15:00:00+00:00 EmrJobFlowSensor 2021-04-17T16:01:04.178814+00:00 2021-04-17T16:11:07.179864+00:00 0:10:03.001050 18233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T16:01:01.820347+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T16:00:42.103630+00:00 2021-04-17T16:00:43.804372+00:00 0:00:01.700742 18232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T16:00:39.856896+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T15:00:00+00:00 PythonOperator 2021-04-17T16:00:20.145334+00:00 2021-04-17T16:00:23.090385+00:00 0:00:02.945051 18231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T16:00:17.782035+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T14:00:00+00:00 EmrJobFlowSensor 2021-04-17T15:46:52.918057+00:00 2021-04-17T15:56:55.663406+00:00 0:10:02.745349 18230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T15:46:50.326587+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T14:00:00+00:00 EmrJobFlowSensor 2021-04-17T15:46:42.516928+00:00 2021-04-17T15:54:45.127474+00:00 0:08:02.610546 18229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T15:46:40.303620+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T15:46:30.910540+00:00 2021-04-17T15:46:32.700431+00:00 0:00:01.789891 18228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T15:46:28.362022+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T15:46:20.507433+00:00 2021-04-17T15:46:22.227167+00:00 0:00:01.719734 18227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T15:46:18.255337+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T14:00:00+00:00 PythonOperator 2021-04-17T15:46:11.245648+00:00 2021-04-17T15:46:14.438974+00:00 0:00:03.193326 18226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T15:46:08.183218+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T14:00:00+00:00 PythonOperator 2021-04-17T15:46:00.987886+00:00 2021-04-17T15:46:03.931318+00:00 0:00:02.943432 18225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T15:45:58.269537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T14:00:00+00:00 TriggerDagRunOperator 2021-04-17T15:45:50.399437+00:00 2021-04-17T15:45:50.923546+00:00 0:00:00.524109 18224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T15:45:48.107761+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T14:00:00+00:00 TriggerDagRunOperator 2021-04-17T15:45:50.251266+00:00 2021-04-17T15:45:50.680265+00:00 0:00:00.428999 18223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T15:45:48.107789+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T14:05:00+00:00 EmrJobFlowSensor 2021-04-17T15:35:35.569314+00:00 2021-04-17T15:44:38.291955+00:00 0:09:02.722641 18222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T15:35:33.153595+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T14:00:00+00:00 EmrJobFlowSensor 2021-04-17T15:35:25.504803+00:00 2021-04-17T15:45:28.221884+00:00 0:10:02.717081 18221 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T15:35:23.079601+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T15:35:13.720041+00:00 2021-04-17T15:35:15.390762+00:00 0:00:01.670721 18220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T15:35:11.069480+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T15:35:05.354103+00:00 2021-04-17T15:35:07.074706+00:00 0:00:01.720603 18219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T15:35:03.083531+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T14:05:00+00:00 PythonOperator 2021-04-17T15:34:53.261050+00:00 2021-04-17T15:34:56.162534+00:00 0:00:02.901484 18218 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T15:34:51.050622+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T14:00:00+00:00 PythonOperator 2021-04-17T15:34:43.803246+00:00 2021-04-17T15:34:47.002727+00:00 0:00:03.199481 18217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T15:34:41.036803+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T13:00:00+00:00 EmrJobFlowSensor 2021-04-17T14:13:07.023996+00:00 2021-04-17T14:22:09.956788+00:00 0:09:02.932792 18215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T14:13:04.788559+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T13:00:00+00:00 EmrJobFlowSensor 2021-04-17T14:13:03.398900+00:00 2021-04-17T14:23:06.197429+00:00 0:10:02.798529 18214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T14:13:00.773076+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T14:12:44.921364+00:00 2021-04-17T14:12:46.659632+00:00 0:00:01.738268 18213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T14:12:42.685226+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T14:12:40.929892+00:00 2021-04-17T14:12:42.739771+00:00 0:00:01.809879 18212 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T14:12:38.649858+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T13:00:00+00:00 PythonOperator 2021-04-17T14:12:25.307413+00:00 2021-04-17T14:12:28.184989+00:00 0:00:02.877576 18211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T14:12:22.615445+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T13:00:00+00:00 PythonOperator 2021-04-17T14:12:20.994384+00:00 2021-04-17T14:12:25.107797+00:00 0:00:04.113413 18210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T14:12:18.610009+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T13:00:00+00:00 TriggerDagRunOperator 2021-04-17T14:12:07.348774+00:00 2021-04-17T14:12:07.910649+00:00 0:00:00.561875 18209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T14:12:04.776032+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T13:00:00+00:00 TriggerDagRunOperator 2021-04-17T14:12:07.191434+00:00 2021-04-17T14:12:07.594811+00:00 0:00:00.403377 18208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T14:12:04.776083+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T13:05:00+00:00 EmrJobFlowSensor 2021-04-17T14:05:57.996872+00:00 2021-04-17T14:15:00.603100+00:00 0:09:02.606228 18207 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T14:05:55.821650+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T14:05:38.354021+00:00 2021-04-17T14:05:40.111406+00:00 0:00:01.757385 18206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T14:05:35.759785+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T13:05:00+00:00 PythonOperator 2021-04-17T14:05:15.996531+00:00 2021-04-17T14:05:18.942617+00:00 0:00:02.946086 18205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T14:05:13.722085+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T13:00:00+00:00 EmrJobFlowSensor 2021-04-17T14:00:55.739914+00:00 2021-04-17T14:11:58.796417+00:00 0:11:03.056503 18204 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T14:00:53.280335+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T14:00:33.751834+00:00 2021-04-17T14:00:35.670581+00:00 0:00:01.918747 18203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T14:00:31.257777+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T13:00:00+00:00 PythonOperator 2021-04-17T14:00:13.989006+00:00 2021-04-17T14:00:16.972956+00:00 0:00:02.983950 18202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T14:00:11.250278+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T12:00:00+00:00 EmrJobFlowSensor 2021-04-17T13:11:22.036911+00:00 2021-04-17T13:20:25.043263+00:00 0:09:03.006352 18200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T13:11:19.857661+00:00 2 default_pool