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 trigger_dagrun_booking-processing-job_v002 2021-04-17T01:00:00+00:00 TriggerDagRunOperator 2021-04-17T02:11:19.213969+00:00 2021-04-17T02:11:19.626006+00:00 0:00:00.412037 18029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T02:11:17.004280+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T01:05:00+00:00 EmrJobFlowSensor 2021-04-17T02:06:04.886250+00:00 2021-04-17T02:15:07.757761+00:00 0:09:02.871511 18028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T02:06:02.521646+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T02:05:42.702420+00:00 2021-04-17T02:05:44.341930+00:00 0:00:01.639510 18027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T02:05:40.500668+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T01:05:00+00:00 PythonOperator 2021-04-17T02:05:20.742586+00:00 2021-04-17T02:05:23.667894+00:00 0:00:02.925308 18026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T02:05:18.446144+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T01:00:00+00:00 EmrJobFlowSensor 2021-04-17T02:01:06.316656+00:00 2021-04-17T02:11:09.251917+00:00 0:10:02.935261 18025 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T02:01:03.970301+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T02:00:46.143793+00:00 2021-04-17T02:00:47.958733+00:00 0:00:01.814940 18024 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T02:00:43.896283+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T01:00:00+00:00 PythonOperator 2021-04-17T02:00:24.318562+00:00 2021-04-17T02:00:27.472801+00:00 0:00:03.154239 18023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T02:00:21.947599+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T00:00:00+00:00 EmrJobFlowSensor 2021-04-17T01:12:08.773799+00:00 2021-04-17T01:21:11.471716+00:00 0:09:02.697917 18021 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:12:06.245667+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T00:00:00+00:00 EmrJobFlowSensor 2021-04-17T01:12:06.474086+00:00 2021-04-17T01:22:09.121743+00:00 0:10:02.647657 18020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:12:04.271177+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T01:11:46.470839+00:00 2021-04-17T01:11:48.284660+00:00 0:00:01.813821 18019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T01:11:44.197949+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T01:11:46.389276+00:00 2021-04-17T01:11:48.075380+00:00 0:00:01.686104 18018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T01:11:44.197975+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T00:00:00+00:00 PythonOperator 2021-04-17T01:11:26.456425+00:00 2021-04-17T01:11:29.628377+00:00 0:00:03.171952 18017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T01:11:24.164982+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T00:00:00+00:00 PythonOperator 2021-04-17T01:11:24.514238+00:00 2021-04-17T01:11:27.429718+00:00 0:00:02.915480 18016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T01:11:22.163157+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T00:00:00+00:00 TriggerDagRunOperator 2021-04-17T01:11:07.174848+00:00 2021-04-17T01:11:07.764511+00:00 0:00:00.589663 18015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:11:04.263350+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T00:00:00+00:00 TriggerDagRunOperator 2021-04-17T01:11:06.686716+00:00 2021-04-17T01:11:07.095997+00:00 0:00:00.409281 18014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:11:04.263308+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T00:05:00+00:00 EmrJobFlowSensor 2021-04-17T01:05:57.704836+00:00 2021-04-17T01:15:00.303047+00:00 0:09:02.598211 18013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T01:05:55.567487+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T01:05:35.800031+00:00 2021-04-17T01:05:37.892268+00:00 0:00:02.092237 18012 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T01:05:33.547898+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T00:05:00+00:00 PythonOperator 2021-04-17T01:05:13.781296+00:00 2021-04-17T01:05:16.741910+00:00 0:00:02.960614 18011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T01:05:11.530935+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T00:00:00+00:00 EmrJobFlowSensor 2021-04-17T01:00:53.306866+00:00 2021-04-17T01:10:56.213570+00:00 0:10:02.906704 18010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T01:00:51.062426+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T01:00:33.812782+00:00 2021-04-17T01:00:35.582141+00:00 0:00:01.769359 18009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T01:00:31.022968+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T00:00:00+00:00 PythonOperator 2021-04-17T01:00:10.185269+00:00 2021-04-17T01:00:13.135840+00:00 0:00:02.950571 18008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T01:00:07.064704+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T23:00:00+00:00 EmrJobFlowSensor 2021-04-17T00:11:16.099797+00:00 2021-04-17T00:20:18.854816+00:00 0:09:02.755019 18006 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:11:13.321607+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T23:00:00+00:00 EmrJobFlowSensor 2021-04-17T00:11:13.843688+00:00 2021-04-17T00:21:17.150507+00:00 0:10:03.306819 18005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:11:11.338236+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T00:10:53.477335+00:00 2021-04-17T00:10:55.194031+00:00 0:00:01.716696 18004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T00:10:51.287544+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T00:10:51.650109+00:00 2021-04-17T00:10:53.436341+00:00 0:00:01.786232 18003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T00:10:49.352051+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T23:00:00+00:00 PythonOperator 2021-04-17T00:10:34.087761+00:00 2021-04-17T00:10:37.012027+00:00 0:00:02.924266 18002 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T00:10:31.232564+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T23:00:00+00:00 PythonOperator 2021-04-17T00:10:31.562017+00:00 2021-04-17T00:10:35.332555+00:00 0:00:03.770538 18001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T00:10:29.269427+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T23:00:00+00:00 TriggerDagRunOperator 2021-04-17T00:10:17.919690+00:00 2021-04-17T00:10:18.333895+00:00 0:00:00.414205 18000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:10:15.223944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T23:00:00+00:00 TriggerDagRunOperator 2021-04-17T00:10:17.921573+00:00 2021-04-17T00:10:18.493554+00:00 0:00:00.571981 17999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:10:15.223994+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T23:05:00+00:00 EmrJobFlowSensor 2021-04-17T00:06:06.992414+00:00 2021-04-17T00:15:09.782878+00:00 0:09:02.790464 17998 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T00:06:04.814879+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T00:05:37.007103+00:00 2021-04-17T00:05:38.759101+00:00 0:00:01.751998 17997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T00:05:34.787677+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T23:05:00+00:00 PythonOperator 2021-04-17T00:05:09.569659+00:00 2021-04-17T00:05:12.486142+00:00 0:00:02.916483 17996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T00:05:06.691150+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T23:00:00+00:00 EmrJobFlowSensor 2021-04-17T00:01:06.497787+00:00 2021-04-17T00:10:09.198966+00:00 0:09:02.701179 17995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T00:01:04.342935+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T00:00:42.815077+00:00 2021-04-17T00:00:44.596200+00:00 0:00:01.781123 17994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T00:00:40.320549+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T23:00:00+00:00 PythonOperator 2021-04-17T00:00:22.899299+00:00 2021-04-17T00:00:26.070296+00:00 0:00:03.170997 17993 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T00:00:20.307451+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T22:00:00+00:00 EmrJobFlowSensor 2021-04-16T23:12:24.835329+00:00 2021-04-16T23:22:27.749601+00:00 0:10:02.914272 17991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:12:22.507209+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T22:00:00+00:00 EmrJobFlowSensor 2021-04-16T23:12:16.671029+00:00 2021-04-16T23:21:19.239071+00:00 0:09:02.568042 17990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:12:14.494999+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T23:12:02.971117+00:00 2021-04-16T23:12:04.811718+00:00 0:00:01.840601 17989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T23:12:00.543433+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T23:11:54.902662+00:00 2021-04-16T23:11:57.161442+00:00 0:00:02.258780 17988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T23:11:52.544163+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T22:00:00+00:00 PythonOperator 2021-04-16T23:11:36.568765+00:00 2021-04-16T23:11:40.183061+00:00 0:00:03.614296 17987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T23:11:34.412246+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T22:00:00+00:00 PythonOperator 2021-04-16T23:11:22.875491+00:00 2021-04-16T23:11:26.693556+00:00 0:00:03.818065 17986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T23:11:20.399142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T22:00:00+00:00 TriggerDagRunOperator 2021-04-16T23:11:14.863920+00:00 2021-04-16T23:11:15.404395+00:00 0:00:00.540475 17985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:11:12.397547+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T22:00:00+00:00 TriggerDagRunOperator 2021-04-16T23:11:14.642413+00:00 2021-04-16T23:11:15.079326+00:00 0:00:00.436913 17984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:11:12.397492+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T22:05:00+00:00 EmrJobFlowSensor 2021-04-16T23:05:47.892119+00:00 2021-04-16T23:14:50.507205+00:00 0:09:02.615086 17983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T23:05:45.789363+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T23:05:26.168154+00:00 2021-04-16T23:05:27.786628+00:00 0:00:01.618474 17982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T23:05:23.853330+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T22:05:00+00:00 PythonOperator 2021-04-16T23:05:06.057774+00:00 2021-04-16T23:05:09.093214+00:00 0:00:03.035440 17981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T23:05:03.696714+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T22:00:00+00:00 EmrJobFlowSensor 2021-04-16T23:00:51.518757+00:00 2021-04-16T23:10:54.213462+00:00 0:10:02.694705 17980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T23:00:49.322403+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T23:00:29.934696+00:00 2021-04-16T23:00:31.745517+00:00 0:00:01.810821 17979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T23:00:27.374361+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T22:00:00+00:00 PythonOperator 2021-04-16T23:00:10.108217+00:00 2021-04-16T23:00:13.153618+00:00 0:00:03.045401 17978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T23:00:07.347534+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T21:00:00+00:00 EmrJobFlowSensor 2021-04-16T22:10:26.033394+00:00 2021-04-16T22:19:29.064317+00:00 0:09:03.030923 17976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T22:10:23.640811+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T21:00:00+00:00 EmrJobFlowSensor 2021-04-16T22:10:09.730517+00:00 2021-04-16T22:18:12.266853+00:00 0:08:02.536336 17975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T22:10:07.506002+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T22:10:03.820217+00:00 2021-04-16T22:10:05.550268+00:00 0:00:01.730051 17974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T22:10:01.567064+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T22:09:47.607013+00:00 2021-04-16T22:09:49.266004+00:00 0:00:01.658991 17973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T22:09:45.461795+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T21:00:00+00:00 PythonOperator 2021-04-16T22:09:41.666039+00:00 2021-04-16T22:09:45.428034+00:00 0:00:03.761995 17972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T22:09:39.437677+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T21:00:00+00:00 PythonOperator 2021-04-16T22:09:27.815943+00:00 2021-04-16T22:09:30.824698+00:00 0:00:03.008755 17971 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T22:09:25.422195+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T21:00:00+00:00 TriggerDagRunOperator 2021-04-16T22:09:20.226587+00:00 2021-04-16T22:09:20.775518+00:00 0:00:00.548931 17970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T22:09:17.551745+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T21:00:00+00:00 TriggerDagRunOperator 2021-04-16T22:09:19.941541+00:00 2021-04-16T22:09:20.357993+00:00 0:00:00.416452 17969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T22:09:17.551708+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T21:05:00+00:00 EmrJobFlowSensor 2021-04-16T22:05:49.401317+00:00 2021-04-16T22:14:52.053600+00:00 0:09:02.652283 17968 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T22:05:46.951461+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T22:05:27.295756+00:00 2021-04-16T22:05:29.016635+00:00 0:00:01.720879 17967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T22:05:24.953316+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T21:05:00+00:00 PythonOperator 2021-04-16T22:05:06.981648+00:00 2021-04-16T22:05:09.835754+00:00 0:00:02.854106 17966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T22:05:04.777255+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T21:00:00+00:00 EmrJobFlowSensor 2021-04-16T22:00:58.486177+00:00 2021-04-16T22:09:01.112145+00:00 0:08:02.625968 17965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T22:00:56.205098+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T22:00:36.311434+00:00 2021-04-16T22:00:38.041643+00:00 0:00:01.730209 17964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T22:00:34.185893+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T21:00:00+00:00 PythonOperator 2021-04-16T22:00:16.461096+00:00 2021-04-16T22:00:19.370508+00:00 0:00:02.909412 17963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T22:00:14.109327+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T20:00:00+00:00 EmrJobFlowSensor 2021-04-16T21:22:13.911058+00:00 2021-04-16T21:22:15.419023+00:00 0:00:01.507965 17961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T21:22:11.646484+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T20:00:00+00:00 EmrJobFlowSensor 2021-04-16T21:10:20.938928+00:00 2021-04-16T21:19:23.607838+00:00 0:09:02.668910 17959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T21:10:18.547884+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T21:10:02.608355+00:00 2021-04-16T21:10:04.321789+00:00 0:00:01.713434 17958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T21:10:00.391134+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T21:09:58.687306+00:00 2021-04-16T21:10:00.402976+00:00 0:00:01.715670 17957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T21:09:56.389787+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T20:00:00+00:00 PythonOperator 2021-04-16T21:09:40.895819+00:00 2021-04-16T21:09:44.087606+00:00 0:00:03.191787 17956 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T21:09:38.330889+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T20:00:00+00:00 PythonOperator 2021-04-16T21:09:38.615315+00:00 2021-04-16T21:09:41.576861+00:00 0:00:02.961546 17955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T21:09:36.328515+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T20:00:00+00:00 TriggerDagRunOperator 2021-04-16T21:09:30.825033+00:00 2021-04-16T21:09:31.355985+00:00 0:00:00.530952 17954 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T21:09:27.967631+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T20:00:00+00:00 TriggerDagRunOperator 2021-04-16T21:09:30.716780+00:00 2021-04-16T21:09:31.171815+00:00 0:00:00.455035 17953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T21:09:27.967677+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T20:05:00+00:00 EmrJobFlowSensor 2021-04-16T21:05:51.813958+00:00 2021-04-16T21:14:54.478556+00:00 0:09:02.664598 17952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T21:05:49.632492+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T21:05:25.791422+00:00 2021-04-16T21:05:27.464005+00:00 0:00:01.672583 17951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T21:05:23.612689+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T20:05:00+00:00 PythonOperator 2021-04-16T21:05:05.869612+00:00 2021-04-16T21:05:08.772610+00:00 0:00:02.902998 17950 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T21:05:03.587656+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T20:00:00+00:00 EmrJobFlowSensor 2021-04-16T21:01:01.895392+00:00 2021-04-16T21:09:04.552786+00:00 0:08:02.657394 17949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T21:00:59.166299+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T21:00:39.820884+00:00 2021-04-16T21:00:41.707118+00:00 0:00:01.886234 17948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T21:00:37.152472+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T20:00:00+00:00 PythonOperator 2021-04-16T21:00:17.310636+00:00 2021-04-16T21:00:20.237209+00:00 0:00:02.926573 17947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T21:00:15.033987+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T19:00:00+00:00 EmrJobFlowSensor 2021-04-16T20:22:12.116849+00:00 2021-04-16T20:22:13.713246+00:00 0:00:01.596397 17945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T20:22:09.855514+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T19:00:00+00:00 EmrJobFlowSensor 2021-04-16T20:22:02.147045+00:00 2021-04-16T20:22:03.653769+00:00 0:00:01.506724 17944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T20:21:59.851245+00:00 3 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T20:10:12.694062+00:00 2021-04-16T20:10:14.533651+00:00 0:00:01.839589 17941 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T20:10:10.422841+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T20:10:02.575595+00:00 2021-04-16T20:10:04.414380+00:00 0:00:01.838785 17940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T20:10:00.405127+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T19:00:00+00:00 PythonOperator 2021-04-16T20:09:52.977761+00:00 2021-04-16T20:09:56.361571+00:00 0:00:03.383810 17939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T20:09:50.460222+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T19:00:00+00:00 PythonOperator 2021-04-16T20:09:40.597462+00:00 2021-04-16T20:09:43.485727+00:00 0:00:02.888265 17938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T20:09:38.390457+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T19:00:00+00:00 TriggerDagRunOperator 2021-04-16T20:09:31.153781+00:00 2021-04-16T20:09:31.699922+00:00 0:00:00.546141 17937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T20:09:28.464637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T19:00:00+00:00 TriggerDagRunOperator 2021-04-16T20:09:31.054234+00:00 2021-04-16T20:09:31.498321+00:00 0:00:00.444087 17936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T20:09:28.464691+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T19:05:00+00:00 EmrJobFlowSensor 2021-04-16T20:05:58.102875+00:00 2021-04-16T20:15:00.622465+00:00 0:09:02.519590 17935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T20:05:55.994936+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T20:05:36.319106+00:00 2021-04-16T20:05:38.009751+00:00 0:00:01.690645 17934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T20:05:34.049597+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T19:05:00+00:00 PythonOperator 2021-04-16T20:05:15.136773+00:00 2021-04-16T20:05:18.000538+00:00 0:00:02.863765 17933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T20:05:11.985079+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T19:00:00+00:00 EmrJobFlowSensor 2021-04-16T20:01:03.965920+00:00 2021-04-16T20:09:06.560666+00:00 0:08:02.594746 17932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T20:01:01.620407+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T20:00:40.010013+00:00 2021-04-16T20:00:41.712559+00:00 0:00:01.702546 17931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T20:00:37.664296+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T19:00:00+00:00 PythonOperator 2021-04-16T20:00:18.111485+00:00 2021-04-16T20:00:21.074635+00:00 0:00:02.963150 17930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T20:00:15.650421+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T18:00:00+00:00 EmrJobFlowSensor 2021-04-16T19:10:59.464208+00:00 2021-04-16T19:21:02.151380+00:00 0:10:02.687172 17928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T19:10:57.174228+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T18:00:00+00:00 EmrJobFlowSensor 2021-04-16T19:10:51.303132+00:00 2021-04-16T19:20:54.160945+00:00 0:10:02.857813 17927 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T19:10:49.165392+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T19:10:39.603579+00:00 2021-04-16T19:10:41.317362+00:00 0:00:01.713783 17926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T19:10:37.155153+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T19:10:31.856246+00:00 2021-04-16T19:10:33.518362+00:00 0:00:01.662116 17925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T19:10:29.169336+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T18:00:00+00:00 PythonOperator 2021-04-16T19:10:17.388006+00:00 2021-04-16T19:10:20.887936+00:00 0:00:03.499930 17924 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T19:10:15.099915+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T18:00:00+00:00 PythonOperator 2021-04-16T19:10:09.567135+00:00 2021-04-16T19:10:12.428094+00:00 0:00:02.860959 17923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T19:10:07.158295+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T18:00:00+00:00 TriggerDagRunOperator 2021-04-16T19:10:03.828864+00:00 2021-04-16T19:10:04.274128+00:00 0:00:00.445264 17922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T19:10:01.156725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T18:00:00+00:00 TriggerDagRunOperator 2021-04-16T19:10:03.837504+00:00 2021-04-16T19:10:04.442519+00:00 0:00:00.605015 17921 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T19:10:01.156674+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T18:05:00+00:00 EmrJobFlowSensor 2021-04-16T19:05:56.792625+00:00 2021-04-16T19:14:59.315663+00:00 0:09:02.523038 17920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T19:05:54.647397+00:00 2 default_pool