Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 check_cluster_status 2021-04-07T19:05:00+00:00 EmrJobFlowSensor 2021-04-07T20:05:48.131261+00:00 2021-04-07T20:14:50.784345+00:00 0:09:02.653084 14677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T20:05:45.744862+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T20:05:27.809265+00:00 2021-04-07T20:05:29.517573+00:00 0:00:01.708308 14676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T20:05:25.651562+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T19:05:00+00:00 PythonOperator 2021-04-07T20:05:05.773936+00:00 2021-04-07T20:05:08.423472+00:00 0:00:02.649536 14675 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T20:05:03.584142+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T19:00:00+00:00 EmrJobFlowSensor 2021-04-07T20:00:59.515432+00:00 2021-04-07T20:10:02.155427+00:00 0:09:02.639995 14674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T20:00:57.186833+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T20:00:39.655001+00:00 2021-04-07T20:00:41.466646+00:00 0:00:01.811645 14673 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T20:00:37.164904+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T19:00:00+00:00 PythonOperator 2021-04-07T20:00:15.552077+00:00 2021-04-07T20:00:18.300577+00:00 0:00:02.748500 14672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T20:00:13.143100+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T18:00:00+00:00 EmrJobFlowSensor 2021-04-07T19:10:33.383672+00:00 2021-04-07T19:20:36.269503+00:00 0:10:02.885831 14670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:10:31.152781+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T18:00:00+00:00 EmrJobFlowSensor 2021-04-07T19:10:31.411679+00:00 2021-04-07T19:19:34.136448+00:00 0:09:02.724769 14669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:10:29.174872+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T19:10:11.308114+00:00 2021-04-07T19:10:13.116788+00:00 0:00:01.808674 14668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T19:10:09.114313+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T19:10:09.387489+00:00 2021-04-07T19:10:11.114913+00:00 0:00:01.727424 14667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T19:10:07.116825+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T18:00:00+00:00 PythonOperator 2021-04-07T19:09:49.816494+00:00 2021-04-07T19:09:52.876142+00:00 0:00:03.059648 14666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T19:09:47.102092+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T18:00:00+00:00 PythonOperator 2021-04-07T19:09:49.622129+00:00 2021-04-07T19:09:52.359347+00:00 0:00:02.737218 14665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T19:09:47.102143+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T18:00:00+00:00 TriggerDagRunOperator 2021-04-07T19:09:35.579268+00:00 2021-04-07T19:09:36.094768+00:00 0:00:00.515500 14664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:09:33.144106+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T18:00:00+00:00 TriggerDagRunOperator 2021-04-07T19:09:35.412941+00:00 2021-04-07T19:09:35.859532+00:00 0:00:00.446591 14663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:09:33.144076+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T18:05:00+00:00 EmrJobFlowSensor 2021-04-07T19:06:16.882261+00:00 2021-04-07T19:15:19.496963+00:00 0:09:02.614702 14662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:06:14.752870+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T19:05:49.022268+00:00 2021-04-07T19:05:50.747967+00:00 0:00:01.725699 14661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T19:05:46.636734+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T18:05:00+00:00 PythonOperator 2021-04-07T19:05:24.754121+00:00 2021-04-07T19:05:27.459951+00:00 0:00:02.705830 14660 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T19:05:22.615898+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T18:00:00+00:00 EmrJobFlowSensor 2021-04-07T19:01:10.311730+00:00 2021-04-07T19:09:12.844726+00:00 0:08:02.532996 14659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T19:01:08.159847+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T19:00:44.564817+00:00 2021-04-07T19:00:46.372692+00:00 0:00:01.807875 14658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T19:00:42.133849+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T18:00:00+00:00 PythonOperator 2021-04-07T19:00:14.495989+00:00 2021-04-07T19:00:17.246514+00:00 0:00:02.750525 14657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T19:00:12.109685+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T17:00:00+00:00 EmrJobFlowSensor 2021-04-07T18:11:09.893582+00:00 2021-04-07T18:22:12.827109+00:00 0:11:02.933527 14655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:11:07.675043+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T17:00:00+00:00 EmrJobFlowSensor 2021-04-07T18:10:55.862311+00:00 2021-04-07T18:19:58.443358+00:00 0:09:02.581047 14654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:10:53.602656+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T18:10:50.148475+00:00 2021-04-07T18:10:51.934596+00:00 0:00:01.786121 14653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T18:10:47.597099+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T18:10:33.930004+00:00 2021-04-07T18:10:35.695533+00:00 0:00:01.765529 14652 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T18:10:31.585915+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T17:00:00+00:00 PythonOperator 2021-04-07T18:10:27.856334+00:00 2021-04-07T18:10:30.947672+00:00 0:00:03.091338 14651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T18:10:25.545790+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T17:00:00+00:00 PythonOperator 2021-04-07T18:10:13.851731+00:00 2021-04-07T18:10:16.573404+00:00 0:00:02.721673 14650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T18:10:11.535302+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T17:00:00+00:00 TriggerDagRunOperator 2021-04-07T18:10:08.255226+00:00 2021-04-07T18:10:08.819947+00:00 0:00:00.564721 14649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:10:05.583622+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T17:00:00+00:00 TriggerDagRunOperator 2021-04-07T18:10:08.017473+00:00 2021-04-07T18:10:08.432552+00:00 0:00:00.415079 14648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:10:05.583593+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T17:05:00+00:00 EmrJobFlowSensor 2021-04-07T18:05:49.677285+00:00 2021-04-07T18:14:52.244951+00:00 0:09:02.567666 14647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:05:47.344266+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T18:05:29.777645+00:00 2021-04-07T18:05:31.527467+00:00 0:00:01.749822 14646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T18:05:27.270049+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T17:05:00+00:00 PythonOperator 2021-04-07T18:05:07.278024+00:00 2021-04-07T18:05:09.951342+00:00 0:00:02.673318 14645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T18:05:05.168534+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T17:00:00+00:00 EmrJobFlowSensor 2021-04-07T18:00:55.225364+00:00 2021-04-07T18:09:58.156020+00:00 0:09:02.930656 14644 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T18:00:52.846194+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T18:00:35.159892+00:00 2021-04-07T18:00:36.882731+00:00 0:00:01.722839 14643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T18:00:32.760426+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T17:00:00+00:00 PythonOperator 2021-04-07T18:00:12.964119+00:00 2021-04-07T18:00:15.830327+00:00 0:00:02.866208 14642 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T18:00:10.689911+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T16:00:00+00:00 EmrJobFlowSensor 2021-04-07T17:16:42.927015+00:00 2021-04-07T17:26:45.662244+00:00 0:10:02.735229 14641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:16:40.279477+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T16:00:00+00:00 EmrJobFlowSensor 2021-04-07T17:16:42.620908+00:00 2021-04-07T17:25:45.522637+00:00 0:09:02.901729 14640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:16:40.279510+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T17:16:22.860531+00:00 2021-04-07T17:16:24.676233+00:00 0:00:01.815702 14639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T17:16:20.353249+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T17:16:22.685555+00:00 2021-04-07T17:16:24.468568+00:00 0:00:01.783013 14638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T17:16:20.353208+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T16:00:00+00:00 PythonOperator 2021-04-07T17:16:01.012238+00:00 2021-04-07T17:16:03.734135+00:00 0:00:02.721897 14637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T17:15:58.271730+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T16:00:00+00:00 PythonOperator 2021-04-07T17:16:01.041145+00:00 2021-04-07T17:16:04.144649+00:00 0:00:03.103504 14636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T17:15:58.271762+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T16:00:00+00:00 TriggerDagRunOperator 2021-04-07T17:15:42.611632+00:00 2021-04-07T17:15:43.152671+00:00 0:00:00.541039 14635 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:15:40.099725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T16:00:00+00:00 TriggerDagRunOperator 2021-04-07T17:15:42.530451+00:00 2021-04-07T17:15:42.957005+00:00 0:00:00.426554 14634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:15:40.099696+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T16:05:00+00:00 EmrJobFlowSensor 2021-04-07T17:05:51.629834+00:00 2021-04-07T17:14:54.220550+00:00 0:09:02.590716 14632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:05:49.434165+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T17:05:31.843433+00:00 2021-04-07T17:05:33.511531+00:00 0:00:01.668098 14631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T17:05:29.495421+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T16:05:00+00:00 PythonOperator 2021-04-07T17:05:10.079523+00:00 2021-04-07T17:05:12.787091+00:00 0:00:02.707568 14630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T17:05:07.464762+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T16:00:00+00:00 EmrJobFlowSensor 2021-04-07T17:01:15.387521+00:00 2021-04-07T17:10:18.195064+00:00 0:09:02.807543 14629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T17:01:13.129107+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T17:00:53.311450+00:00 2021-04-07T17:00:54.998270+00:00 0:00:01.686820 14628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T17:00:51.086805+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T16:00:00+00:00 PythonOperator 2021-04-07T17:00:33.236605+00:00 2021-04-07T17:00:35.989833+00:00 0:00:02.753228 14627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T17:00:31.006505+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T15:00:00+00:00 EmrJobFlowSensor 2021-04-07T16:33:56.983140+00:00 2021-04-07T16:54:01.199776+00:00 0:20:04.216636 14626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:33:54.606304+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T15:00:00+00:00 EmrJobFlowSensor 2021-04-07T16:33:40.896475+00:00 2021-04-07T16:42:43.581240+00:00 0:09:02.684765 14625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:33:38.589747+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T16:33:35.015620+00:00 2021-04-07T16:33:36.698157+00:00 0:00:01.682537 14624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T16:33:32.644019+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T16:33:18.886927+00:00 2021-04-07T16:33:20.686412+00:00 0:00:01.799485 14623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T16:33:16.558281+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T15:00:00+00:00 PythonOperator 2021-04-07T16:33:14.791347+00:00 2021-04-07T16:33:17.548096+00:00 0:00:02.756749 14622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T16:33:12.559062+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T15:00:00+00:00 PythonOperator 2021-04-07T16:32:58.815327+00:00 2021-04-07T16:33:01.874366+00:00 0:00:03.059039 14621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T16:32:56.516227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T15:00:00+00:00 TriggerDagRunOperator 2021-04-07T16:32:48.881489+00:00 2021-04-07T16:32:49.412674+00:00 0:00:00.531185 14620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:32:46.499940+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T15:00:00+00:00 TriggerDagRunOperator 2021-04-07T16:32:48.798089+00:00 2021-04-07T16:32:49.222243+00:00 0:00:00.424154 14619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:32:46.499912+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T15:00:00+00:00 EmrJobFlowSensor 2021-04-07T16:11:10.696897+00:00 2021-04-07T16:32:14.954094+00:00 0:21:04.257197 14618 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T16:11:08.457687+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T15:05:00+00:00 EmrJobFlowSensor 2021-04-07T16:11:04.680961+00:00 2021-04-07T16:20:07.307864+00:00 0:09:02.626903 14617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:11:02.501625+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T16:10:48.796587+00:00 2021-04-07T16:10:50.611899+00:00 0:00:01.815312 14616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T16:10:46.435981+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T16:10:42.619793+00:00 2021-04-07T16:10:44.333094+00:00 0:00:01.713301 14615 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T16:10:40.436154+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T15:00:00+00:00 PythonOperator 2021-04-07T16:10:24.621203+00:00 2021-04-07T16:10:27.318326+00:00 0:00:02.697123 14614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T16:10:22.423724+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T15:05:00+00:00 PythonOperator 2021-04-07T16:10:21.061547+00:00 2021-04-07T16:10:23.869285+00:00 0:00:02.807738 14613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T16:10:18.420375+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T14:00:00+00:00 EmrJobFlowSensor 2021-04-07T15:12:09.894485+00:00 2021-04-07T15:22:12.690800+00:00 0:10:02.796315 14611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:12:07.717718+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T14:00:00+00:00 EmrJobFlowSensor 2021-04-07T15:11:58.001811+00:00 2021-04-07T15:21:00.701623+00:00 0:09:02.699812 14610 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:11:55.710107+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T15:11:50.193247+00:00 2021-04-07T15:11:51.920438+00:00 0:00:01.727191 14609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T15:11:47.697671+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T15:11:37.930898+00:00 2021-04-07T15:11:39.650691+00:00 0:00:01.719793 14608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T15:11:35.688866+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T14:00:00+00:00 PythonOperator 2021-04-07T15:11:28.580470+00:00 2021-04-07T15:11:31.530056+00:00 0:00:02.949586 14607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T15:11:25.621427+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T14:00:00+00:00 PythonOperator 2021-04-07T15:11:15.931972+00:00 2021-04-07T15:11:18.737883+00:00 0:00:02.805911 14606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T15:11:13.608289+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T14:00:00+00:00 TriggerDagRunOperator 2021-04-07T15:11:06.199579+00:00 2021-04-07T15:11:06.636861+00:00 0:00:00.437282 14605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:11:03.656827+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T14:00:00+00:00 TriggerDagRunOperator 2021-04-07T15:11:06.227702+00:00 2021-04-07T15:11:06.791951+00:00 0:00:00.564249 14604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:11:03.656874+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T14:05:00+00:00 EmrJobFlowSensor 2021-04-07T15:05:55.367491+00:00 2021-04-07T15:14:58.174032+00:00 0:09:02.806541 14603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:05:53.129880+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T15:05:33.266154+00:00 2021-04-07T15:05:34.889491+00:00 0:00:01.623337 14602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T15:05:31.111088+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T14:05:00+00:00 PythonOperator 2021-04-07T15:05:13.267404+00:00 2021-04-07T15:05:15.946557+00:00 0:00:02.679153 14601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T15:05:11.092703+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T14:00:00+00:00 EmrJobFlowSensor 2021-04-07T15:00:48.933780+00:00 2021-04-07T15:10:51.770513+00:00 0:10:02.836733 14600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T15:00:46.736687+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T15:00:29.132317+00:00 2021-04-07T15:00:30.953273+00:00 0:00:01.820956 14599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T15:00:26.717955+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T14:00:00+00:00 PythonOperator 2021-04-07T15:00:07.380463+00:00 2021-04-07T15:00:10.147688+00:00 0:00:02.767225 14598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T15:00:04.618281+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T13:00:00+00:00 EmrJobFlowSensor 2021-04-07T14:10:16.487135+00:00 2021-04-07T14:19:19.218512+00:00 0:09:02.731377 14596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T14:10:14.196365+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T13:00:00+00:00 EmrJobFlowSensor 2021-04-07T14:10:08.420778+00:00 2021-04-07T14:19:11.057520+00:00 0:09:02.636742 14595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T14:10:06.187965+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T14:09:54.442837+00:00 2021-04-07T14:09:56.237897+00:00 0:00:01.795060 14594 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T14:09:52.131203+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T14:09:46.736433+00:00 2021-04-07T14:09:48.466662+00:00 0:00:01.730229 14593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T14:09:44.127912+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T13:00:00+00:00 PythonOperator 2021-04-07T14:09:34.434700+00:00 2021-04-07T14:09:37.418924+00:00 0:00:02.984224 14592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T14:09:32.112886+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T13:00:00+00:00 PythonOperator 2021-04-07T14:09:24.535148+00:00 2021-04-07T14:09:27.344962+00:00 0:00:02.809814 14591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T14:09:22.177593+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T13:00:00+00:00 TriggerDagRunOperator 2021-04-07T14:09:12.591259+00:00 2021-04-07T14:09:13.111053+00:00 0:00:00.519794 14590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T14:09:10.097047+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T13:00:00+00:00 TriggerDagRunOperator 2021-04-07T14:09:12.216785+00:00 2021-04-07T14:09:12.641799+00:00 0:00:00.425014 14589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T14:09:10.097083+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T13:05:00+00:00 EmrJobFlowSensor 2021-04-07T14:06:04.436799+00:00 2021-04-07T14:15:07.049150+00:00 0:09:02.612351 14588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T14:06:01.866658+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T14:05:41.986110+00:00 2021-04-07T14:05:43.717136+00:00 0:00:01.731026 14587 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T14:05:39.796191+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T13:05:00+00:00 PythonOperator 2021-04-07T14:05:20.137829+00:00 2021-04-07T14:05:22.818997+00:00 0:00:02.681168 14586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T14:05:17.725671+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T13:00:00+00:00 EmrJobFlowSensor 2021-04-07T14:01:01.659823+00:00 2021-04-07T14:09:04.324513+00:00 0:08:02.664690 14585 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T14:00:59.306114+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T14:00:39.467495+00:00 2021-04-07T14:00:41.144900+00:00 0:00:01.677405 14584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T14:00:37.285103+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T13:00:00+00:00 PythonOperator 2021-04-07T14:00:20.214802+00:00 2021-04-07T14:00:22.994548+00:00 0:00:02.779746 14583 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T14:00:17.269005+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T12:00:00+00:00 EmrJobFlowSensor 2021-04-07T13:11:50.124744+00:00 2021-04-07T13:19:52.719345+00:00 0:08:02.594601 14581 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T13:11:47.788203+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T12:00:00+00:00 EmrJobFlowSensor 2021-04-07T13:11:27.982880+00:00 2021-04-07T13:21:30.687479+00:00 0:10:02.704599 14580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T13:11:25.766388+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T13:11:16.045618+00:00 2021-04-07T13:11:17.867239+00:00 0:00:01.821621 14579 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T13:11:13.769563+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T13:11:00.230415+00:00 2021-04-07T13:11:02.025205+00:00 0:00:01.794790 14578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T13:10:57.843906+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T12:00:00+00:00 PythonOperator 2021-04-07T13:10:54.324607+00:00 2021-04-07T13:10:57.199116+00:00 0:00:02.874509 14577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T13:10:51.781231+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T12:00:00+00:00 PythonOperator 2021-04-07T13:10:40.072339+00:00 2021-04-07T13:10:43.185420+00:00 0:00:03.113081 14576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T13:10:37.690067+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T12:00:00+00:00 TriggerDagRunOperator 2021-04-07T13:10:30.579222+00:00 2021-04-07T13:10:31.119525+00:00 0:00:00.540303 14575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T13:10:27.842349+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T12:00:00+00:00 TriggerDagRunOperator 2021-04-07T13:10:30.451690+00:00 2021-04-07T13:10:30.881303+00:00 0:00:00.429613 14574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T13:10:27.842401+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T12:05:00+00:00 EmrJobFlowSensor 2021-04-07T13:05:55.461290+00:00 2021-04-07T13:14:58.166022+00:00 0:09:02.704732 14573 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T13:05:53.156725+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T13:05:33.257400+00:00 2021-04-07T13:05:34.895386+00:00 0:00:01.637986 14572 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T13:05:31.060981+00:00 2 default_pool