Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 create_emr_steps 2021-03-23T19:05:00+00:00 PythonOperator 2021-03-23T20:05:19.770684+00:00 2021-03-23T20:05:22.638780+00:00 0:00:02.868096 10995 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T20:05:17.455376+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T19:00:00+00:00 EmrJobFlowSensor 2021-03-23T20:00:55.204046+00:00 2021-03-23T20:10:57.987398+00:00 0:10:02.783352 10994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T20:00:53.025365+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T20:00:33.522651+00:00 2021-03-23T20:00:35.191400+00:00 0:00:01.668749 10993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T20:00:31.077774+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T19:00:00+00:00 PythonOperator 2021-03-23T20:00:11.307811+00:00 2021-03-23T20:00:14.177462+00:00 0:00:02.869651 10992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T20:00:09.052601+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T18:00:00+00:00 EmrJobFlowSensor 2021-03-23T19:13:30.916560+00:00 2021-03-23T19:30:34.508493+00:00 0:17:03.591933 10991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T19:13:28.552431+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T18:00:00+00:00 EmrJobFlowSensor 2021-03-23T19:13:28.894672+00:00 2021-03-23T19:22:31.487602+00:00 0:09:02.592930 10990 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T19:13:26.526130+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T19:13:10.964046+00:00 2021-03-23T19:13:12.664127+00:00 0:00:01.700081 10989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T19:13:08.578108+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T19:13:08.794454+00:00 2021-03-23T19:13:10.605209+00:00 0:00:01.810755 10988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T19:13:06.567924+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T18:00:00+00:00 PythonOperator 2021-03-23T19:12:49.169724+00:00 2021-03-23T19:12:51.990943+00:00 0:00:02.821219 10987 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T19:12:46.517830+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T18:00:00+00:00 PythonOperator 2021-03-23T19:12:46.843899+00:00 2021-03-23T19:12:50.204855+00:00 0:00:03.360956 10986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T19:12:44.556337+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T18:00:00+00:00 TriggerDagRunOperator 2021-03-23T19:12:23.264400+00:00 2021-03-23T19:12:24.057844+00:00 0:00:00.793444 10985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T19:12:20.513878+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T18:00:00+00:00 TriggerDagRunOperator 2021-03-23T19:12:23.188794+00:00 2021-03-23T19:12:23.879092+00:00 0:00:00.690298 10984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T19:12:20.513841+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T18:05:00+00:00 EmrJobFlowSensor 2021-03-23T19:06:06.161545+00:00 2021-03-23T19:15:08.707082+00:00 0:09:02.545537 10982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T19:06:04.003726+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T18:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T19:05:44.399110+00:00 2021-03-23T19:05:46.046974+00:00 0:00:01.647864 10981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T19:05:41.974862+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T18:05:00+00:00 PythonOperator 2021-03-23T19:05:24.316162+00:00 2021-03-23T19:05:27.122423+00:00 0:00:02.806261 10980 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T19:05:21.968005+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T18:00:00+00:00 EmrJobFlowSensor 2021-03-23T19:01:07.812058+00:00 2021-03-23T19:11:10.570196+00:00 0:10:02.758138 10979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T19:01:05.554788+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T19:00:45.721886+00:00 2021-03-23T19:00:47.420479+00:00 0:00:01.698593 10978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T19:00:43.429861+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T18:00:00+00:00 PythonOperator 2021-03-23T19:00:25.597416+00:00 2021-03-23T19:00:28.306693+00:00 0:00:02.709277 10977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T19:00:23.409017+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T17:00:00+00:00 EmrJobFlowSensor 2021-03-23T18:12:28.741413+00:00 2021-03-23T18:21:31.336537+00:00 0:09:02.595124 10976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T18:12:26.448616+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T17:00:00+00:00 EmrJobFlowSensor 2021-03-23T18:12:26.933376+00:00 2021-03-23T18:21:29.587502+00:00 0:09:02.654126 10975 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T18:12:24.472174+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T18:12:06.766473+00:00 2021-03-23T18:12:08.600538+00:00 0:00:01.834065 10974 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T18:12:04.389112+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T18:12:06.682032+00:00 2021-03-23T18:12:08.489492+00:00 0:00:01.807460 10973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T18:12:04.389071+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T17:00:00+00:00 PythonOperator 2021-03-23T18:11:46.497913+00:00 2021-03-23T18:11:49.233298+00:00 0:00:02.735385 10972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T18:11:44.311840+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T17:00:00+00:00 PythonOperator 2021-03-23T18:11:44.640580+00:00 2021-03-23T18:11:47.779936+00:00 0:00:03.139356 10971 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T18:11:42.315690+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T17:00:00+00:00 TriggerDagRunOperator 2021-03-23T18:11:30.929209+00:00 2021-03-23T18:11:31.473201+00:00 0:00:00.543992 10970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T18:11:28.294488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T17:00:00+00:00 TriggerDagRunOperator 2021-03-23T18:11:30.789158+00:00 2021-03-23T18:11:31.225830+00:00 0:00:00.436672 10969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T18:11:28.294459+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T17:05:00+00:00 EmrJobFlowSensor 2021-03-23T18:05:59.963391+00:00 2021-03-23T18:15:02.528413+00:00 0:09:02.565022 10967 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T18:05:57.653427+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T17:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T18:05:37.732645+00:00 2021-03-23T18:05:39.522909+00:00 0:00:01.790264 10966 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T18:05:35.468823+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T17:05:00+00:00 PythonOperator 2021-03-23T18:05:17.569406+00:00 2021-03-23T18:05:20.362799+00:00 0:00:02.793393 10965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T18:05:15.402832+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T17:00:00+00:00 EmrJobFlowSensor 2021-03-23T18:00:57.083862+00:00 2021-03-23T18:10:59.974377+00:00 0:10:02.890515 10964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T18:00:54.903564+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T18:00:35.304487+00:00 2021-03-23T18:00:36.982584+00:00 0:00:01.678097 10963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T18:00:32.888462+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T17:00:00+00:00 PythonOperator 2021-03-23T18:00:13.010285+00:00 2021-03-23T18:00:15.825659+00:00 0:00:02.815374 10962 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T18:00:10.819163+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T16:00:00+00:00 EmrJobFlowSensor 2021-03-23T17:11:34.635786+00:00 2021-03-23T17:20:37.190307+00:00 0:09:02.554521 10961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T17:11:32.442225+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T16:00:00+00:00 EmrJobFlowSensor 2021-03-23T17:11:32.597700+00:00 2021-03-23T17:21:35.499496+00:00 0:10:02.901796 10960 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T17:11:30.441017+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T17:11:15.094758+00:00 2021-03-23T17:11:16.781536+00:00 0:00:01.686778 10959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T17:11:12.425759+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T17:11:12.699292+00:00 2021-03-23T17:11:14.804722+00:00 0:00:02.105430 10958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T17:11:10.422915+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T16:00:00+00:00 PythonOperator 2021-03-23T17:10:53.303612+00:00 2021-03-23T17:10:56.173765+00:00 0:00:02.870153 10957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T17:10:50.406850+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T16:00:00+00:00 PythonOperator 2021-03-23T17:10:51.019304+00:00 2021-03-23T17:10:54.453149+00:00 0:00:03.433845 10956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T17:10:48.412482+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T16:00:00+00:00 TriggerDagRunOperator 2021-03-23T17:10:43.082443+00:00 2021-03-23T17:10:43.584597+00:00 0:00:00.502154 10955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T17:10:40.189334+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T16:00:00+00:00 TriggerDagRunOperator 2021-03-23T17:10:42.859095+00:00 2021-03-23T17:10:43.255738+00:00 0:00:00.396643 10954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T17:10:40.189363+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T16:05:00+00:00 EmrJobFlowSensor 2021-03-23T17:05:53.037017+00:00 2021-03-23T17:13:55.544767+00:00 0:08:02.507750 10952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T17:05:50.803989+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T16:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T17:05:31.360297+00:00 2021-03-23T17:05:33.099880+00:00 0:00:01.739583 10951 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T17:05:28.950628+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T16:05:00+00:00 PythonOperator 2021-03-23T17:05:09.243646+00:00 2021-03-23T17:05:11.925765+00:00 0:00:02.682119 10950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T17:05:06.843799+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T16:00:00+00:00 EmrJobFlowSensor 2021-03-23T17:00:50.718831+00:00 2021-03-23T17:09:53.349606+00:00 0:09:02.630775 10949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T17:00:48.231799+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T17:00:28.602446+00:00 2021-03-23T17:00:30.408922+00:00 0:00:01.806476 10948 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T17:00:26.270857+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T16:00:00+00:00 PythonOperator 2021-03-23T17:00:08.662273+00:00 2021-03-23T17:00:11.559144+00:00 0:00:02.896871 10947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T17:00:06.253434+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T15:00:00+00:00 EmrJobFlowSensor 2021-03-23T16:19:16.770646+00:00 2021-03-23T16:29:19.619186+00:00 0:10:02.848540 10946 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T16:19:13.981546+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T15:00:00+00:00 EmrJobFlowSensor 2021-03-23T16:19:14.463822+00:00 2021-03-23T16:28:17.591641+00:00 0:09:03.127819 10945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T16:19:11.985333+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T16:18:56.107080+00:00 2021-03-23T16:18:57.874507+00:00 0:00:01.767427 10944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T16:18:53.909080+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T16:18:52.118409+00:00 2021-03-23T16:18:53.981389+00:00 0:00:01.862980 10943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T16:18:49.898927+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T15:00:00+00:00 PythonOperator 2021-03-23T16:18:34.339499+00:00 2021-03-23T16:18:37.307379+00:00 0:00:02.967880 10942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T16:18:31.894498+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T15:00:00+00:00 PythonOperator 2021-03-23T16:18:30.665478+00:00 2021-03-23T16:18:33.598717+00:00 0:00:02.933239 10941 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T16:18:27.958842+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T15:00:00+00:00 TriggerDagRunOperator 2021-03-23T16:18:26.409715+00:00 2021-03-23T16:18:26.925487+00:00 0:00:00.515772 10940 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T16:18:23.950034+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T15:00:00+00:00 TriggerDagRunOperator 2021-03-23T16:18:26.251321+00:00 2021-03-23T16:18:26.667702+00:00 0:00:00.416381 10939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T16:18:23.950086+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T15:05:00+00:00 EmrJobFlowSensor 2021-03-23T16:09:35.274890+00:00 2021-03-23T16:17:37.729776+00:00 0:08:02.454886 10938 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T16:09:33.076713+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T15:00:00+00:00 EmrJobFlowSensor 2021-03-23T16:09:19.657710+00:00 2021-03-23T16:18:22.471059+00:00 0:09:02.813349 10937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T16:09:17.061445+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T15:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T16:09:07.249446+00:00 2021-03-23T16:09:09.020867+00:00 0:00:01.771421 10936 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T16:09:05.060602+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T16:08:57.208563+00:00 2021-03-23T16:08:58.889245+00:00 0:00:01.680682 10935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T16:08:55.049296+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T15:05:00+00:00 PythonOperator 2021-03-23T16:08:41.192799+00:00 2021-03-23T16:08:43.938943+00:00 0:00:02.746144 10934 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T16:08:39.030041+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T15:00:00+00:00 PythonOperator 2021-03-23T16:08:31.695037+00:00 2021-03-23T16:08:34.440762+00:00 0:00:02.745725 10933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T16:08:29.075872+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T14:00:00+00:00 EmrJobFlowSensor 2021-03-23T15:11:57.151137+00:00 2021-03-23T15:20:59.735420+00:00 0:09:02.584283 10931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T15:11:54.907579+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T14:00:00+00:00 EmrJobFlowSensor 2021-03-23T15:11:55.236794+00:00 2021-03-23T15:21:58.000726+00:00 0:10:02.763932 10930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T15:11:52.910916+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T15:11:35.298452+00:00 2021-03-23T15:11:36.970822+00:00 0:00:01.672370 10929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T15:11:32.957625+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T15:11:33.307801+00:00 2021-03-23T15:11:35.119632+00:00 0:00:01.811831 10928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T15:11:30.957960+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T14:00:00+00:00 PythonOperator 2021-03-23T15:11:13.802677+00:00 2021-03-23T15:11:16.671258+00:00 0:00:02.868581 10927 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T15:11:10.819691+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T14:00:00+00:00 PythonOperator 2021-03-23T15:11:12.156690+00:00 2021-03-23T15:11:15.469420+00:00 0:00:03.312730 10926 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T15:11:08.872673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T14:00:00+00:00 TriggerDagRunOperator 2021-03-23T15:10:59.320002+00:00 2021-03-23T15:10:59.800804+00:00 0:00:00.480802 10925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T15:10:56.811676+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T14:00:00+00:00 TriggerDagRunOperator 2021-03-23T15:10:59.144819+00:00 2021-03-23T15:10:59.564479+00:00 0:00:00.419660 10924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T15:10:56.811643+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T14:05:00+00:00 EmrJobFlowSensor 2021-03-23T15:05:56.550749+00:00 2021-03-23T15:15:59.347376+00:00 0:10:02.796627 10923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T15:05:54.337784+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T14:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T15:05:34.502204+00:00 2021-03-23T15:05:36.130648+00:00 0:00:01.628444 10922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T15:05:32.320467+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T14:05:00+00:00 PythonOperator 2021-03-23T15:05:14.589216+00:00 2021-03-23T15:05:17.307119+00:00 0:00:02.717903 10921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T15:05:12.305663+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T14:00:00+00:00 EmrJobFlowSensor 2021-03-23T15:00:50.041177+00:00 2021-03-23T15:10:52.876818+00:00 0:10:02.835641 10920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T15:00:47.790124+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T15:00:27.936948+00:00 2021-03-23T15:00:29.626019+00:00 0:00:01.689071 10919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T15:00:25.770137+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T14:00:00+00:00 PythonOperator 2021-03-23T15:00:08.178897+00:00 2021-03-23T15:00:10.931487+00:00 0:00:02.752590 10918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T15:00:05.720809+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T13:00:00+00:00 EmrJobFlowSensor 2021-03-23T14:12:18.104374+00:00 2021-03-23T14:21:20.827008+00:00 0:09:02.722634 10916 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T14:12:15.659652+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T13:00:00+00:00 EmrJobFlowSensor 2021-03-23T14:12:10.036619+00:00 2021-03-23T14:22:12.702211+00:00 0:10:02.665592 10915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T14:12:07.589972+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T14:11:55.806760+00:00 2021-03-23T14:11:57.604069+00:00 0:00:01.797309 10914 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T14:11:53.520162+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T14:11:47.674465+00:00 2021-03-23T14:11:49.372104+00:00 0:00:01.697639 10913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T14:11:45.517760+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T13:00:00+00:00 PythonOperator 2021-03-23T14:11:35.871208+00:00 2021-03-23T14:11:38.806475+00:00 0:00:02.935267 10912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T14:11:33.489239+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T13:00:00+00:00 PythonOperator 2021-03-23T14:11:28.124688+00:00 2021-03-23T14:11:31.193814+00:00 0:00:03.069126 10911 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T14:11:25.493023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T13:00:00+00:00 TriggerDagRunOperator 2021-03-23T14:11:15.675065+00:00 2021-03-23T14:11:16.066300+00:00 0:00:00.391235 10910 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T14:11:13.456209+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T13:00:00+00:00 TriggerDagRunOperator 2021-03-23T14:11:15.715022+00:00 2021-03-23T14:11:16.209846+00:00 0:00:00.494824 10909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T14:11:13.456241+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T13:05:00+00:00 EmrJobFlowSensor 2021-03-23T14:05:59.276716+00:00 2021-03-23T14:19:02.377448+00:00 0:13:03.100732 10908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T14:05:56.970148+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T13:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T14:05:39.136044+00:00 2021-03-23T14:05:40.867626+00:00 0:00:01.731582 10907 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T14:05:36.885469+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T13:05:00+00:00 PythonOperator 2021-03-23T14:05:17.179239+00:00 2021-03-23T14:05:19.983219+00:00 0:00:02.803980 10906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T14:05:14.864168+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T13:00:00+00:00 EmrJobFlowSensor 2021-03-23T14:00:54.994479+00:00 2021-03-23T14:10:57.767703+00:00 0:10:02.773224 10905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T14:00:52.321717+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T14:00:32.672992+00:00 2021-03-23T14:00:34.519209+00:00 0:00:01.846217 10904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T14:00:30.360691+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T13:00:00+00:00 PythonOperator 2021-03-23T14:00:10.674896+00:00 2021-03-23T14:00:13.527014+00:00 0:00:02.852118 10903 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T14:00:08.263729+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T12:00:00+00:00 EmrJobFlowSensor 2021-03-23T13:11:16.382932+00:00 2021-03-23T13:20:18.935212+00:00 0:09:02.552280 10901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T13:11:14.184475+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T12:00:00+00:00 EmrJobFlowSensor 2021-03-23T13:11:00.419281+00:00 2021-03-23T13:21:03.291181+00:00 0:10:02.871900 10900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T13:10:58.154273+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T13:10:54.678668+00:00 2021-03-23T13:10:56.409192+00:00 0:00:01.730524 10899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T13:10:52.244737+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T13:10:40.428448+00:00 2021-03-23T13:10:42.164574+00:00 0:00:01.736126 10898 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T13:10:38.105848+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T12:00:00+00:00 PythonOperator 2021-03-23T13:10:34.359023+00:00 2021-03-23T13:10:37.086024+00:00 0:00:02.727001 10897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T13:10:32.100764+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T12:00:00+00:00 PythonOperator 2021-03-23T13:10:18.365103+00:00 2021-03-23T13:10:21.493340+00:00 0:00:03.128237 10896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T13:10:16.090199+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T12:00:00+00:00 TriggerDagRunOperator 2021-03-23T13:10:08.649271+00:00 2021-03-23T13:10:09.117401+00:00 0:00:00.468130 10895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T13:10:06.159548+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T12:00:00+00:00 TriggerDagRunOperator 2021-03-23T13:10:08.621192+00:00 2021-03-23T13:10:09.143087+00:00 0:00:00.521895 10894 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T13:10:06.159597+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T12:05:00+00:00 EmrJobFlowSensor 2021-03-23T13:05:57.962409+00:00 2021-03-23T13:17:00.930720+00:00 0:11:02.968311 10893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T13:05:55.672179+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T12:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T13:05:35.748100+00:00 2021-03-23T13:05:37.387216+00:00 0:00:01.639116 10892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T13:05:33.600913+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T12:05:00+00:00 PythonOperator 2021-03-23T13:05:14.151981+00:00 2021-03-23T13:05:16.860719+00:00 0:00:02.708738 10891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T13:05:11.652627+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T12:00:00+00:00 EmrJobFlowSensor 2021-03-23T13:00:51.210617+00:00 2021-03-23T13:09:53.881524+00:00 0:09:02.670907 10890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T13:00:49.023585+00:00 2 default_pool