Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T19:10:38.075433+00:00 2021-04-19T19:10:39.884491+00:00 0:00:01.809058 19009 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T19:10:35.563807+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T18:00:00+00:00 PythonOperator 2021-04-19T19:10:18.213961+00:00 2021-04-19T19:10:21.393958+00:00 0:00:03.179997 19008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T19:10:15.458139+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T18:00:00+00:00 PythonOperator 2021-04-19T19:10:17.701351+00:00 2021-04-19T19:10:20.664902+00:00 0:00:02.963551 19007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T19:10:15.458105+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T18:00:00+00:00 TriggerDagRunOperator 2021-04-19T19:10:08.374055+00:00 2021-04-19T19:10:08.945271+00:00 0:00:00.571216 19006 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T19:10:05.451126+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T18:00:00+00:00 TriggerDagRunOperator 2021-04-19T19:10:07.847247+00:00 2021-04-19T19:10:08.234278+00:00 0:00:00.387031 19005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T19:10:05.451094+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T18:05:00+00:00 EmrJobFlowSensor 2021-04-19T19:06:01.265794+00:00 2021-04-19T19:15:03.819127+00:00 0:09:02.553333 19004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T19:05:59.086889+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T19:05:39.194230+00:00 2021-04-19T19:05:40.828470+00:00 0:00:01.634240 19003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T19:05:37.047623+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T18:05:00+00:00 PythonOperator 2021-04-19T19:05:09.329616+00:00 2021-04-19T19:05:12.215768+00:00 0:00:02.886152 19002 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T19:05:07.023958+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T18:00:00+00:00 EmrJobFlowSensor 2021-04-19T19:00:58.873794+00:00 2021-04-19T19:10:01.877068+00:00 0:09:03.003274 19001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T19:00:56.642991+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T19:00:39.497075+00:00 2021-04-19T19:00:41.195336+00:00 0:00:01.698261 19000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T19:00:36.659940+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T18:00:00+00:00 PythonOperator 2021-04-19T19:00:16.990654+00:00 2021-04-19T19:00:19.963816+00:00 0:00:02.973162 18999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T19:00:14.598123+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T17:00:00+00:00 EmrJobFlowSensor 2021-04-19T18:11:12.325045+00:00 2021-04-19T18:20:15.016502+00:00 0:09:02.691457 18997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T18:11:10.109170+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T17:00:00+00:00 EmrJobFlowSensor 2021-04-19T18:11:01.065540+00:00 2021-04-19T18:21:03.997064+00:00 0:10:02.931524 18996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T18:10:58.260604+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T18:10:50.526221+00:00 2021-04-19T18:10:52.313838+00:00 0:00:01.787617 18995 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T18:10:48.092726+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T18:10:39.003393+00:00 2021-04-19T18:10:40.703371+00:00 0:00:01.699978 18994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T18:10:36.078613+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T17:00:00+00:00 PythonOperator 2021-04-19T18:10:30.546046+00:00 2021-04-19T18:10:33.461503+00:00 0:00:02.915457 18993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T18:10:28.157498+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T17:00:00+00:00 PythonOperator 2021-04-19T18:10:18.231272+00:00 2021-04-19T18:10:21.469093+00:00 0:00:03.237821 18992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T18:10:15.988012+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T17:00:00+00:00 TriggerDagRunOperator 2021-04-19T18:10:06.409715+00:00 2021-04-19T18:10:06.932292+00:00 0:00:00.522577 18991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T18:10:04.047472+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T17:00:00+00:00 TriggerDagRunOperator 2021-04-19T18:10:06.365578+00:00 2021-04-19T18:10:06.781125+00:00 0:00:00.415547 18990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T18:10:04.047516+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T17:05:00+00:00 EmrJobFlowSensor 2021-04-19T18:05:55.679591+00:00 2021-04-19T18:14:58.164060+00:00 0:09:02.484469 18989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T18:05:53.550693+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T18:05:33.847442+00:00 2021-04-19T18:05:35.878714+00:00 0:00:02.031272 18988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T18:05:31.532985+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T17:05:00+00:00 PythonOperator 2021-04-19T18:05:11.741577+00:00 2021-04-19T18:05:14.673677+00:00 0:00:02.932100 18987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T18:05:09.507614+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T17:00:00+00:00 EmrJobFlowSensor 2021-04-19T18:00:49.611114+00:00 2021-04-19T18:09:52.440090+00:00 0:09:02.828976 18986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T18:00:47.047803+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T18:00:27.406721+00:00 2021-04-19T18:00:29.103601+00:00 0:00:01.696880 18985 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T18:00:24.943427+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T17:00:00+00:00 PythonOperator 2021-04-19T18:00:07.453046+00:00 2021-04-19T18:00:11.037857+00:00 0:00:03.584811 18984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T18:00:04.870500+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T16:00:00+00:00 EmrJobFlowSensor 2021-04-19T17:12:15.165799+00:00 2021-04-19T17:21:17.742773+00:00 0:09:02.576974 18982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T17:12:12.474552+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T16:00:00+00:00 EmrJobFlowSensor 2021-04-19T17:12:08.782542+00:00 2021-04-19T17:21:11.470849+00:00 0:09:02.688307 18981 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T17:12:06.469578+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T17:11:54.751809+00:00 2021-04-19T17:11:56.470106+00:00 0:00:01.718297 18980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T17:11:52.461387+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T17:11:46.674442+00:00 2021-04-19T17:11:48.498809+00:00 0:00:01.824367 18979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T17:11:44.449335+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T16:00:00+00:00 PythonOperator 2021-04-19T17:11:32.710642+00:00 2021-04-19T17:11:35.620992+00:00 0:00:02.910350 18978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T17:11:30.453353+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T16:00:00+00:00 PythonOperator 2021-04-19T17:11:24.986518+00:00 2021-04-19T17:11:28.248510+00:00 0:00:03.261992 18977 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T17:11:22.476416+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T16:00:00+00:00 TriggerDagRunOperator 2021-04-19T17:11:18.866869+00:00 2021-04-19T17:11:19.364323+00:00 0:00:00.497454 18976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T17:11:16.428112+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T16:00:00+00:00 TriggerDagRunOperator 2021-04-19T17:11:18.712855+00:00 2021-04-19T17:11:19.137774+00:00 0:00:00.424919 18975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T17:11:16.428162+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T16:05:00+00:00 EmrJobFlowSensor 2021-04-19T17:06:00.184677+00:00 2021-04-19T17:14:02.947719+00:00 0:08:02.763042 18974 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T17:05:57.840671+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T17:05:38.114912+00:00 2021-04-19T17:05:39.785838+00:00 0:00:01.670926 18973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T17:05:35.866914+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T16:05:00+00:00 PythonOperator 2021-04-19T17:05:17.961304+00:00 2021-04-19T17:05:20.938224+00:00 0:00:02.976920 18972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T17:05:15.731795+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T16:00:00+00:00 EmrJobFlowSensor 2021-04-19T17:01:00.290336+00:00 2021-04-19T17:11:03.238206+00:00 0:10:02.947870 18971 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T17:00:57.265625+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T17:00:39.474657+00:00 2021-04-19T17:00:41.154613+00:00 0:00:01.679956 18970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T17:00:37.240800+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T16:00:00+00:00 PythonOperator 2021-04-19T17:00:17.339743+00:00 2021-04-19T17:00:20.327798+00:00 0:00:02.988055 18969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T17:00:15.063509+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T15:00:00+00:00 EmrJobFlowSensor 2021-04-19T16:10:17.346567+00:00 2021-04-19T16:20:20.337655+00:00 0:10:02.991088 18967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T16:10:14.692262+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T15:00:00+00:00 EmrJobFlowSensor 2021-04-19T16:10:17.128312+00:00 2021-04-19T16:20:19.973912+00:00 0:10:02.845600 18966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T16:10:14.692211+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T16:09:55.173867+00:00 2021-04-19T16:09:56.985040+00:00 0:00:01.811173 18965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T16:09:52.606363+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T16:09:54.889054+00:00 2021-04-19T16:09:56.595483+00:00 0:00:01.706429 18964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T16:09:52.606335+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T15:00:00+00:00 PythonOperator 2021-04-19T16:09:34.962875+00:00 2021-04-19T16:09:38.080660+00:00 0:00:03.117785 18963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T16:09:32.589673+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T15:00:00+00:00 PythonOperator 2021-04-19T16:09:35.068941+00:00 2021-04-19T16:09:38.709143+00:00 0:00:03.640202 18962 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T16:09:32.589638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T15:00:00+00:00 TriggerDagRunOperator 2021-04-19T16:09:22.825844+00:00 2021-04-19T16:09:23.350992+00:00 0:00:00.525148 18961 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T16:09:20.511218+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T15:00:00+00:00 TriggerDagRunOperator 2021-04-19T16:09:22.783725+00:00 2021-04-19T16:09:23.198586+00:00 0:00:00.414861 18960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T16:09:20.511252+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T15:05:00+00:00 EmrJobFlowSensor 2021-04-19T16:05:56.157686+00:00 2021-04-19T16:14:58.772892+00:00 0:09:02.615206 18959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T16:05:54.026177+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T16:05:34.929534+00:00 2021-04-19T16:05:36.754851+00:00 0:00:01.825317 18958 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T16:05:32.056500+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T15:05:00+00:00 PythonOperator 2021-04-19T16:05:12.195605+00:00 2021-04-19T16:05:15.105867+00:00 0:00:02.910262 18957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T16:05:09.983411+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T15:00:00+00:00 EmrJobFlowSensor 2021-04-19T16:00:49.851752+00:00 2021-04-19T16:08:52.321832+00:00 0:08:02.470080 18956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T16:00:47.644028+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T16:00:30.325132+00:00 2021-04-19T16:00:32.098334+00:00 0:00:01.773202 18955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T16:00:27.676567+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T15:00:00+00:00 PythonOperator 2021-04-19T16:00:07.852613+00:00 2021-04-19T16:00:10.958013+00:00 0:00:03.105400 18954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T16:00:05.585604+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T14:00:00+00:00 EmrJobFlowSensor 2021-04-19T15:37:01.617713+00:00 2021-04-19T15:47:04.499715+00:00 0:10:02.882002 18953 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T15:36:59.343596+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T14:00:00+00:00 EmrJobFlowSensor 2021-04-19T15:36:59.900873+00:00 2021-04-19T15:46:02.521147+00:00 0:09:02.620274 18952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T15:36:57.286030+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T15:36:33.668231+00:00 2021-04-19T15:36:35.435741+00:00 0:00:01.767510 18951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T15:36:31.282704+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T15:36:33.685784+00:00 2021-04-19T15:36:35.508303+00:00 0:00:01.822519 18950 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T15:36:31.282732+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T14:00:00+00:00 PythonOperator 2021-04-19T15:36:11.518847+00:00 2021-04-19T15:36:14.907006+00:00 0:00:03.388159 18949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T15:36:09.246411+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T14:00:00+00:00 PythonOperator 2021-04-19T15:36:11.476425+00:00 2021-04-19T15:36:14.955611+00:00 0:00:03.479186 18948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T15:36:09.246446+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T14:00:00+00:00 TriggerDagRunOperator 2021-04-19T15:35:53.863070+00:00 2021-04-19T15:35:54.420680+00:00 0:00:00.557610 18947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T15:35:51.236377+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T14:00:00+00:00 TriggerDagRunOperator 2021-04-19T15:35:53.687036+00:00 2021-04-19T15:35:54.110839+00:00 0:00:00.423803 18946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T15:35:51.236429+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T14:00:00+00:00 EmrJobFlowSensor 2021-04-19T15:27:30.830746+00:00 2021-04-19T15:35:33.440825+00:00 0:08:02.610079 18945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T15:27:28.478302+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T14:05:00+00:00 EmrJobFlowSensor 2021-04-19T15:27:22.660105+00:00 2021-04-19T15:36:25.231398+00:00 0:09:02.571293 18944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T15:27:20.468417+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T14:54:45.044993+00:00 EmrJobFlowSensor 2021-04-19T15:27:16.720978+00:00 2021-04-19T15:36:19.449190+00:00 0:09:02.728212 18943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T15:27:14.463470+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T15:27:02.713366+00:00 2021-04-19T15:27:04.552154+00:00 0:00:01.838788 18942 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T15:27:00.450885+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T15:26:56.696108+00:00 2021-04-19T15:26:58.443869+00:00 0:00:01.747761 18941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T15:26:54.445002+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T14:54:45.044993+00:00 EmrCreateJobFlowOperator 2021-04-19T15:26:51.210700+00:00 2021-04-19T15:26:52.962088+00:00 0:00:01.751388 18940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T15:26:48.448580+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T14:00:00+00:00 PythonOperator 2021-04-19T15:26:36.701071+00:00 2021-04-19T15:26:39.649217+00:00 0:00:02.948146 18939 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T15:26:34.425993+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T14:05:00+00:00 PythonOperator 2021-04-19T15:26:34.682020+00:00 2021-04-19T15:26:37.730875+00:00 0:00:03.048855 18938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T15:26:32.432015+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T14:54:45.044993+00:00 PythonOperator 2021-04-19T15:26:31.161484+00:00 2021-04-19T15:26:34.144114+00:00 0:00:02.982630 18937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T15:26:28.479857+00:00 2 default_pool
success primary-audience-global-ind_v003 create_cluster 2021-04-19T14:41:24.862241+00:00 PythonOperator 2021-04-19T14:42:09.533383+00:00 2021-04-19T14:42:13.411859+00:00 0:00:03.878476 18935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T14:42:07.187472+00:00 2 default_pool
success primary-audience-global-ind_v003 validation 2021-04-19T14:41:24.862241+00:00 PythonOperator 2021-04-19T14:41:47.775540+00:00 2021-04-19T14:41:48.063067+00:00 0:00:00.287527 18934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T14:41:45.161957+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T13:00:00+00:00 EmrJobFlowSensor 2021-04-19T14:11:20.093696+00:00 2021-04-19T14:21:22.850547+00:00 0:10:02.756851 18933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T14:11:17.821252+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T13:00:00+00:00 EmrJobFlowSensor 2021-04-19T14:11:12.045206+00:00 2021-04-19T14:21:14.952572+00:00 0:10:02.907366 18932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T14:11:09.815477+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T14:11:00.196930+00:00 2021-04-19T14:11:01.981791+00:00 0:00:01.784861 18931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T14:10:57.806476+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T14:10:50.197816+00:00 2021-04-19T14:10:51.886710+00:00 0:00:01.688894 18930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T14:10:47.801535+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T13:00:00+00:00 PythonOperator 2021-04-19T14:10:38.300561+00:00 2021-04-19T14:10:41.322779+00:00 0:00:03.022218 18929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T14:10:35.860295+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T13:00:00+00:00 PythonOperator 2021-04-19T14:10:28.004615+00:00 2021-04-19T14:10:31.239104+00:00 0:00:03.234489 18928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T14:10:25.764849+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T13:00:00+00:00 TriggerDagRunOperator 2021-04-19T14:10:14.229762+00:00 2021-04-19T14:10:14.756943+00:00 0:00:00.527181 18927 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T14:10:11.717440+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T13:00:00+00:00 TriggerDagRunOperator 2021-04-19T14:10:13.990845+00:00 2021-04-19T14:10:14.411152+00:00 0:00:00.420307 18926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T14:10:11.717488+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T13:05:00+00:00 EmrJobFlowSensor 2021-04-19T14:05:53.578351+00:00 2021-04-19T14:14:56.250058+00:00 0:09:02.671707 18925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T14:05:51.288278+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T14:05:33.493451+00:00 2021-04-19T14:05:35.198703+00:00 0:00:01.705252 18924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T14:05:31.266421+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T13:05:00+00:00 PythonOperator 2021-04-19T14:05:11.319083+00:00 2021-04-19T14:05:14.511048+00:00 0:00:03.191965 18923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T14:05:09.190677+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T13:00:00+00:00 EmrJobFlowSensor 2021-04-19T14:00:56.878482+00:00 2021-04-19T14:09:59.512998+00:00 0:09:02.634516 18922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T14:00:54.708361+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T14:00:36.872802+00:00 2021-04-19T14:00:38.547174+00:00 0:00:01.674372 18921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T14:00:34.685907+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T13:00:00+00:00 PythonOperator 2021-04-19T14:00:13.116867+00:00 2021-04-19T14:00:16.068254+00:00 0:00:02.951387 18920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T14:00:10.645505+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T12:00:00+00:00 EmrJobFlowSensor 2021-04-19T13:10:22.334707+00:00 2021-04-19T13:19:25.078243+00:00 0:09:02.743536 18918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T13:10:19.925926+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T12:00:00+00:00 EmrJobFlowSensor 2021-04-19T13:10:12.146018+00:00 2021-04-19T13:18:14.737943+00:00 0:08:02.591925 18917 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T13:10:09.919454+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T13:10:02.115192+00:00 2021-04-19T13:10:03.851934+00:00 0:00:01.736742 18916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T13:09:59.909857+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T13:09:48.514032+00:00 2021-04-19T13:09:50.532515+00:00 0:00:02.018483 18915 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T13:09:45.967302+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T12:00:00+00:00 PythonOperator 2021-04-19T13:09:40.294499+00:00 2021-04-19T13:09:43.470777+00:00 0:00:03.176278 18914 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T13:09:37.968108+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T12:00:00+00:00 PythonOperator 2021-04-19T13:09:28.370112+00:00 2021-04-19T13:09:31.478339+00:00 0:00:03.108227 18913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T13:09:25.940876+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T12:00:00+00:00 TriggerDagRunOperator 2021-04-19T13:09:20.229228+00:00 2021-04-19T13:09:20.742036+00:00 0:00:00.512808 18912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T13:09:17.853033+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T12:00:00+00:00 TriggerDagRunOperator 2021-04-19T13:09:20.037912+00:00 2021-04-19T13:09:20.442251+00:00 0:00:00.404339 18911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T13:09:17.853063+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T12:05:00+00:00 EmrJobFlowSensor 2021-04-19T13:06:09.859065+00:00 2021-04-19T13:15:12.438179+00:00 0:09:02.579114 18910 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T13:06:07.655450+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T13:05:48.017234+00:00 2021-04-19T13:05:49.654779+00:00 0:00:01.637545 18909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T13:05:45.622840+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T12:05:00+00:00 PythonOperator 2021-04-19T13:05:25.791034+00:00 2021-04-19T13:05:28.682148+00:00 0:00:02.891114 18908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T13:05:23.597081+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T12:00:00+00:00 EmrJobFlowSensor 2021-04-19T13:01:03.364222+00:00 2021-04-19T13:09:05.866794+00:00 0:08:02.502572 18907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T13:01:01.116927+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T13:00:39.454032+00:00 2021-04-19T13:00:41.125241+00:00 0:00:01.671209 18906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T13:00:37.144732+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T12:00:00+00:00 PythonOperator 2021-04-19T13:00:17.486039+00:00 2021-04-19T13:00:20.492618+00:00 0:00:03.006579 18905 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T13:00:15.060343+00:00 2 default_pool