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_cluster_and_add_emr_steps 2021-05-19T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T19:00:35.163930+00:00 2021-05-19T19:00:36.961192+00:00 0:00:01.797262 29907 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-19T19:00:32.758266+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-19T18:00:00+00:00 PythonOperator 2021-05-19T19:00:12.998975+00:00 2021-05-19T19:00:16.179539+00:00 0:00:03.180564 29906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-19T19:00:10.740653+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T17:00:00+00:00 EmrJobFlowSensor 2021-05-19T18:11:24.359242+00:00 2021-05-19T18:21:27.086491+00:00 0:10:02.727249 29905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T18:11:22.139752+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-19T17:00:00+00:00 EmrJobFlowSensor 2021-05-19T18:11:18.340741+00:00 2021-05-19T18:21:21.145445+00:00 0:10:02.804704 29904 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T18:11:16.133412+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-19T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T18:11:00.334477+00:00 2021-05-19T18:11:02.058895+00:00 0:00:01.724418 29903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T18:10:58.117502+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-19T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T18:10:54.538172+00:00 2021-05-19T18:10:56.311311+00:00 0:00:01.773139 29902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T18:10:52.175143+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-19T17:00:00+00:00 PythonOperator 2021-05-19T18:10:40.309366+00:00 2021-05-19T18:10:43.387543+00:00 0:00:03.078177 29901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T18:10:38.104712+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-19T17:00:00+00:00 PythonOperator 2021-05-19T18:10:34.666367+00:00 2021-05-19T18:10:38.386585+00:00 0:00:03.720218 29900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T18:10:32.166949+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-19T17:00:00+00:00 TriggerDagRunOperator 2021-05-19T18:10:12.339113+00:00 2021-05-19T18:10:12.867844+00:00 0:00:00.528731 29899 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T18:10:10.077356+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-19T17:00:00+00:00 TriggerDagRunOperator 2021-05-19T18:10:12.184713+00:00 2021-05-19T18:10:12.628303+00:00 0:00:00.443590 29898 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T18:10:10.077389+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-19T17:05:00+00:00 EmrJobFlowSensor 2021-05-19T18:06:12.066008+00:00 2021-05-19T18:15:14.837109+00:00 0:09:02.771101 29897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T18:06:09.843374+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-19T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-19T18:05:47.769678+00:00 2021-05-19T18:05:49.413819+00:00 0:00:01.644141 29896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T18:05:45.708800+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-19T17:05:00+00:00 PythonOperator 2021-05-19T18:05:20.463173+00:00 2021-05-19T18:05:23.507993+00:00 0:00:03.044820 29895 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T18:05:17.745539+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-19T17:00:00+00:00 EmrJobFlowSensor 2021-05-19T18:00:56.056390+00:00 2021-05-19T18:09:58.684473+00:00 0:09:02.628083 29893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T18:00:53.864880+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-19T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T18:00:34.102118+00:00 2021-05-19T18:00:35.760656+00:00 0:00:01.658538 29892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-19T18:00:31.812803+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-19T17:00:00+00:00 PythonOperator 2021-05-19T18:00:11.901072+00:00 2021-05-19T18:00:15.148708+00:00 0:00:03.247636 29891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-19T18:00:09.790384+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-19T16:00:00+00:00 EmrJobFlowSensor 2021-05-19T17:12:35.897639+00:00 2021-05-19T17:22:38.797865+00:00 0:10:02.900226 29890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T17:12:33.371051+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T16:00:00+00:00 EmrJobFlowSensor 2021-05-19T17:12:19.834787+00:00 2021-05-19T17:22:22.556092+00:00 0:10:02.721305 29889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T17:12:17.340949+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-19T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T17:12:13.419314+00:00 2021-05-19T17:12:15.119031+00:00 0:00:01.699717 29888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T17:12:11.258476+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-19T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T17:11:59.835337+00:00 2021-05-19T17:12:01.522642+00:00 0:00:01.687305 29887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T17:11:57.238271+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-19T16:00:00+00:00 PythonOperator 2021-05-19T17:11:51.415555+00:00 2021-05-19T17:11:54.865309+00:00 0:00:03.449754 29886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T17:11:49.232833+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-19T16:00:00+00:00 PythonOperator 2021-05-19T17:11:37.346134+00:00 2021-05-19T17:11:40.491036+00:00 0:00:03.144902 29885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T17:11:35.219784+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-19T16:00:00+00:00 TriggerDagRunOperator 2021-05-19T17:11:27.506653+00:00 2021-05-19T17:11:28.028962+00:00 0:00:00.522309 29884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T17:11:25.211756+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-19T16:00:00+00:00 TriggerDagRunOperator 2021-05-19T17:11:27.382378+00:00 2021-05-19T17:11:27.801654+00:00 0:00:00.419276 29883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T17:11:25.211720+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-19T16:05:00+00:00 EmrJobFlowSensor 2021-05-19T17:05:47.010598+00:00 2021-05-19T17:13:49.559425+00:00 0:08:02.548827 29882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T17:05:44.859626+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-19T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-19T17:05:25.063814+00:00 2021-05-19T17:05:26.697435+00:00 0:00:01.633621 29881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T17:05:22.783052+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-19T16:05:00+00:00 PythonOperator 2021-05-19T17:05:04.948229+00:00 2021-05-19T17:05:08.061881+00:00 0:00:03.113652 29880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T17:05:02.729652+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-19T16:00:00+00:00 EmrJobFlowSensor 2021-05-19T17:00:50.961968+00:00 2021-05-19T17:10:53.815907+00:00 0:10:02.853939 29878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T17:00:48.590079+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-19T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T17:00:28.815243+00:00 2021-05-19T17:00:30.502587+00:00 0:00:01.687344 29877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-19T17:00:26.518621+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-19T16:00:00+00:00 PythonOperator 2021-05-19T17:00:06.854870+00:00 2021-05-19T17:00:10.041409+00:00 0:00:03.186539 29876 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-19T17:00:04.557370+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-19T15:00:00+00:00 EmrJobFlowSensor 2021-05-19T16:11:53.546125+00:00 2021-05-19T16:21:56.284949+00:00 0:10:02.738824 29875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T16:11:51.322164+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T15:00:00+00:00 EmrJobFlowSensor 2021-05-19T16:11:43.797695+00:00 2021-05-19T16:19:46.391901+00:00 0:08:02.594206 29874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T16:11:41.388471+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-19T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T16:11:31.650619+00:00 2021-05-19T16:11:33.342372+00:00 0:00:01.691753 29873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T16:11:29.344208+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-19T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T16:11:21.573772+00:00 2021-05-19T16:11:23.320237+00:00 0:00:01.746465 29872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T16:11:19.356468+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-19T15:00:00+00:00 PythonOperator 2021-05-19T16:11:11.439538+00:00 2021-05-19T16:11:14.913131+00:00 0:00:03.473593 29871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T16:11:09.282066+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-19T15:00:00+00:00 PythonOperator 2021-05-19T16:10:59.389089+00:00 2021-05-19T16:11:02.603271+00:00 0:00:03.214182 29870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T16:10:57.262365+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-19T15:00:00+00:00 TriggerDagRunOperator 2021-05-19T16:10:47.568894+00:00 2021-05-19T16:10:48.114227+00:00 0:00:00.545333 29869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T16:10:45.225771+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-19T15:00:00+00:00 TriggerDagRunOperator 2021-05-19T16:10:47.392120+00:00 2021-05-19T16:10:47.821772+00:00 0:00:00.429652 29868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T16:10:45.225730+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-19T15:05:00+00:00 EmrJobFlowSensor 2021-05-19T16:05:50.755816+00:00 2021-05-19T16:13:53.265422+00:00 0:08:02.509606 29867 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T16:05:48.716781+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-19T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-19T16:05:30.966048+00:00 2021-05-19T16:05:32.734954+00:00 0:00:01.768906 29866 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T16:05:28.701746+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-19T15:05:00+00:00 PythonOperator 2021-05-19T16:05:07.407859+00:00 2021-05-19T16:05:10.513560+00:00 0:00:03.105701 29865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T16:05:04.750725+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-19T15:00:00+00:00 EmrJobFlowSensor 2021-05-19T16:01:15.305797+00:00 2021-05-19T16:10:18.252356+00:00 0:09:02.946559 29863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T16:01:12.756708+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-19T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T16:00:44.845640+00:00 2021-05-19T16:00:46.525350+00:00 0:00:01.679710 29862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-19T16:00:42.606942+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-19T15:00:00+00:00 PythonOperator 2021-05-19T16:00:20.776229+00:00 2021-05-19T16:00:23.945311+00:00 0:00:03.169082 29861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-19T16:00:18.582213+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T14:00:00+00:00 EmrJobFlowSensor 2021-05-19T15:13:38.097251+00:00 2021-05-19T15:23:40.827537+00:00 0:10:02.730286 29860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T15:13:35.868610+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-19T14:00:00+00:00 EmrJobFlowSensor 2021-05-19T15:13:27.946665+00:00 2021-05-19T15:23:30.570917+00:00 0:10:02.624252 29859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T15:13:25.759322+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-19T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T15:13:16.321170+00:00 2021-05-19T15:13:17.982549+00:00 0:00:01.661379 29858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T15:13:13.759352+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-19T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T15:13:07.830408+00:00 2021-05-19T15:13:09.536160+00:00 0:00:01.705752 29857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T15:13:05.732120+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-19T14:00:00+00:00 PythonOperator 2021-05-19T15:12:53.952469+00:00 2021-05-19T15:12:57.104200+00:00 0:00:03.151731 29856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T15:12:51.721210+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-19T14:00:00+00:00 PythonOperator 2021-05-19T15:12:46.254866+00:00 2021-05-19T15:12:49.604825+00:00 0:00:03.349959 29855 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T15:12:43.708412+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-19T14:00:00+00:00 TriggerDagRunOperator 2021-05-19T15:12:38.448557+00:00 2021-05-19T15:12:38.948981+00:00 0:00:00.500424 29854 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T15:12:35.768554+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-19T14:00:00+00:00 TriggerDagRunOperator 2021-05-19T15:12:38.246850+00:00 2021-05-19T15:12:38.704464+00:00 0:00:00.457614 29853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T15:12:35.768601+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-19T14:05:00+00:00 EmrJobFlowSensor 2021-05-19T15:05:49.212940+00:00 2021-05-19T15:14:51.683337+00:00 0:09:02.470397 29852 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T15:05:47.091097+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-19T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-19T15:05:29.243579+00:00 2021-05-19T15:05:30.865650+00:00 0:00:01.622071 29851 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T15:05:27.035284+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-19T14:05:00+00:00 PythonOperator 2021-05-19T15:05:07.176543+00:00 2021-05-19T15:05:10.322655+00:00 0:00:03.146112 29850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T15:05:05.014856+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-19T14:00:00+00:00 EmrJobFlowSensor 2021-05-19T15:03:13.211781+00:00 2021-05-19T15:12:15.858511+00:00 0:09:02.646730 29849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T15:03:10.957512+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-19T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T15:02:50.875360+00:00 2021-05-19T15:02:52.572092+00:00 0:00:01.696732 29848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-19T15:02:48.796421+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-19T14:00:00+00:00 PythonOperator 2021-05-19T15:02:29.000872+00:00 2021-05-19T15:02:32.230097+00:00 0:00:03.229225 29847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-19T15:02:26.762615+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T13:00:00+00:00 EmrJobFlowSensor 2021-05-19T14:10:27.243275+00:00 2021-05-19T14:19:29.970113+00:00 0:09:02.726838 29845 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T14:10:24.773141+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-19T13:00:00+00:00 EmrJobFlowSensor 2021-05-19T14:10:13.149519+00:00 2021-05-19T14:19:15.910582+00:00 0:09:02.761063 29844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T14:10:10.697554+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-19T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T14:10:06.789475+00:00 2021-05-19T14:10:08.469643+00:00 0:00:01.680168 29843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T14:10:04.691824+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-19T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T14:09:52.776308+00:00 2021-05-19T14:09:54.446213+00:00 0:00:01.669905 29842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T14:09:50.630744+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-19T13:00:00+00:00 PythonOperator 2021-05-19T14:09:42.796951+00:00 2021-05-19T14:09:45.975161+00:00 0:00:03.178210 29841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T14:09:40.621118+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-19T13:00:00+00:00 PythonOperator 2021-05-19T14:09:30.852565+00:00 2021-05-19T14:09:34.269772+00:00 0:00:03.417207 29840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T14:09:28.640834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-19T13:00:00+00:00 TriggerDagRunOperator 2021-05-19T14:09:17.185870+00:00 2021-05-19T14:09:17.646272+00:00 0:00:00.460402 29839 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T14:09:14.601612+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-19T13:00:00+00:00 TriggerDagRunOperator 2021-05-19T14:09:17.005496+00:00 2021-05-19T14:09:17.547906+00:00 0:00:00.542410 29838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T14:09:14.601581+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-19T13:05:00+00:00 EmrJobFlowSensor 2021-05-19T14:06:16.463749+00:00 2021-05-19T14:15:19.160997+00:00 0:09:02.697248 29837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T14:06:14.253886+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-19T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-19T14:05:54.207458+00:00 2021-05-19T14:05:55.941207+00:00 0:00:01.733749 29836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T14:05:52.085673+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-19T13:05:00+00:00 PythonOperator 2021-05-19T14:05:26.037036+00:00 2021-05-19T14:05:29.247344+00:00 0:00:03.210308 29835 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T14:05:24.029785+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-19T13:00:00+00:00 EmrJobFlowSensor 2021-05-19T14:00:57.895272+00:00 2021-05-19T14:09:00.579028+00:00 0:08:02.683756 29834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T14:00:55.521954+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-19T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T14:00:35.636415+00:00 2021-05-19T14:00:37.403563+00:00 0:00:01.767148 29833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-19T14:00:33.500784+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-19T13:00:00+00:00 PythonOperator 2021-05-19T14:00:15.804043+00:00 2021-05-19T14:00:18.978776+00:00 0:00:03.174733 29832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-19T14:00:13.490416+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-19T12:00:00+00:00 EmrJobFlowSensor 2021-05-19T13:12:32.677372+00:00 2021-05-19T13:21:35.485653+00:00 0:09:02.808281 29830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T13:12:29.978841+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T12:00:00+00:00 EmrJobFlowSensor 2021-05-19T13:12:18.152390+00:00 2021-05-19T13:21:21.011736+00:00 0:09:02.859346 29829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T13:12:15.823642+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-19T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T13:12:10.387689+00:00 2021-05-19T13:12:12.110229+00:00 0:00:01.722540 29828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T13:12:07.843915+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-19T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T13:11:56.190724+00:00 2021-05-19T13:11:58.123517+00:00 0:00:01.932793 29827 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T13:11:53.806785+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-19T12:00:00+00:00 PythonOperator 2021-05-19T13:11:46.181650+00:00 2021-05-19T13:11:49.562311+00:00 0:00:03.380661 29826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T13:11:43.877436+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-19T12:00:00+00:00 PythonOperator 2021-05-19T13:11:36.354225+00:00 2021-05-19T13:11:39.565650+00:00 0:00:03.211425 29825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T13:11:33.794015+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-19T12:00:00+00:00 TriggerDagRunOperator 2021-05-19T13:11:28.168351+00:00 2021-05-19T13:11:28.728542+00:00 0:00:00.560191 29824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T13:11:25.778009+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-19T12:00:00+00:00 TriggerDagRunOperator 2021-05-19T13:11:28.086977+00:00 2021-05-19T13:11:28.533238+00:00 0:00:00.446261 29823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T13:11:25.778037+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-19T12:05:00+00:00 EmrJobFlowSensor 2021-05-19T13:05:59.756506+00:00 2021-05-19T13:14:02.436383+00:00 0:08:02.679877 29822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T13:05:57.321207+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-19T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-19T13:05:37.908846+00:00 2021-05-19T13:05:39.650222+00:00 0:00:01.741376 29821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T13:05:35.357142+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-19T12:05:00+00:00 PythonOperator 2021-05-19T13:05:13.347029+00:00 2021-05-19T13:05:16.561563+00:00 0:00:03.214534 29820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T13:05:11.134159+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-19T12:00:00+00:00 EmrJobFlowSensor 2021-05-19T13:01:09.095265+00:00 2021-05-19T13:11:12.056700+00:00 0:10:02.961435 29819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T13:01:06.626367+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-19T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T13:00:44.801282+00:00 2021-05-19T13:00:46.549375+00:00 0:00:01.748093 29818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-19T13:00:42.607030+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-19T12:00:00+00:00 PythonOperator 2021-05-19T13:00:25.389381+00:00 2021-05-19T13:00:28.667504+00:00 0:00:03.278123 29817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-19T13:00:22.339685+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T11:00:00+00:00 EmrJobFlowSensor 2021-05-19T12:11:08.697926+00:00 2021-05-19T12:21:11.657109+00:00 0:10:02.959183 29815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T12:11:06.023036+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-19T11:00:00+00:00 EmrJobFlowSensor 2021-05-19T12:11:06.519793+00:00 2021-05-19T12:23:09.948421+00:00 0:12:03.428628 29814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T12:11:04.046710+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-19T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T12:10:46.204757+00:00 2021-05-19T12:10:47.888922+00:00 0:00:01.684165 29813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T12:10:44.012674+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-19T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T12:10:42.526639+00:00 2021-05-19T12:10:44.347187+00:00 0:00:01.820548 29812 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T12:10:40.064821+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-19T11:00:00+00:00 PythonOperator 2021-05-19T12:10:24.835477+00:00 2021-05-19T12:10:28.202241+00:00 0:00:03.366764 29811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T12:10:21.969404+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-19T11:00:00+00:00 PythonOperator 2021-05-19T12:10:20.115746+00:00 2021-05-19T12:10:24.407699+00:00 0:00:04.291953 29810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T12:10:17.970312+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-19T11:00:00+00:00 TriggerDagRunOperator 2021-05-19T12:10:08.336720+00:00 2021-05-19T12:10:08.853708+00:00 0:00:00.516988 29809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T12:10:05.956221+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-19T11:00:00+00:00 TriggerDagRunOperator 2021-05-19T12:10:08.074176+00:00 2021-05-19T12:10:08.513787+00:00 0:00:00.439611 29808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T12:10:05.956193+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-19T11:05:00+00:00 EmrJobFlowSensor 2021-05-19T12:05:49.692214+00:00 2021-05-19T12:14:52.260382+00:00 0:09:02.568168 29807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T12:05:47.518757+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-19T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-19T12:05:28.012637+00:00 2021-05-19T12:05:29.772927+00:00 0:00:01.760290 29806 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T12:05:25.542940+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-19T11:05:00+00:00 PythonOperator 2021-05-19T12:05:07.469416+00:00 2021-05-19T12:05:10.595007+00:00 0:00:03.125591 29805 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T12:05:05.407335+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-19T11:00:00+00:00 EmrJobFlowSensor 2021-05-19T12:00:55.166219+00:00 2021-05-19T12:09:58.016855+00:00 0:09:02.850636 29804 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T12:00:52.869132+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-19T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T12:00:34.988394+00:00 2021-05-19T12:00:36.699852+00:00 0:00:01.711458 29803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-19T12:00:32.853664+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-19T11:00:00+00:00 PythonOperator 2021-05-19T12:00:11.639642+00:00 2021-05-19T12:00:14.768696+00:00 0:00:03.129054 29802 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-19T12:00:08.846285+00:00 2 default_pool