Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 check_cluster_status 2021-04-25T14:05:00+00:00 EmrJobFlowSensor 2021-04-25T15:20:10.512368+00:00 2021-04-25T15:30:13.328349+00:00 0:10:02.815981 21139 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T15:20:08.070892+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T15:19:54.394656+00:00 2021-04-25T15:19:56.200471+00:00 0:00:01.805815 21138 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T15:19:51.996141+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T15:19:50.343547+00:00 2021-04-25T15:19:52.086631+00:00 0:00:01.743084 21137 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T15:19:47.987054+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T14:00:00+00:00 PythonOperator 2021-04-25T15:19:32.738222+00:00 2021-04-25T15:19:35.687951+00:00 0:00:02.949729 21136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T15:19:29.934464+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T14:05:00+00:00 PythonOperator 2021-04-25T15:19:28.818038+00:00 2021-04-25T15:19:32.446052+00:00 0:00:03.628014 21135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T15:19:26.005824+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T13:00:00+00:00 EmrJobFlowSensor 2021-04-25T14:12:28.099541+00:00 2021-04-25T14:21:30.649247+00:00 0:09:02.549706 21133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T14:12:25.861725+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T13:00:00+00:00 EmrJobFlowSensor 2021-04-25T14:12:20.232750+00:00 2021-04-25T14:21:22.839848+00:00 0:09:02.607098 21132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T14:12:17.862481+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T14:12:06.186657+00:00 2021-04-25T14:12:07.901398+00:00 0:00:01.714741 21131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T14:12:03.804082+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T14:11:58.069654+00:00 2021-04-25T14:11:59.991801+00:00 0:00:01.922147 21130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T14:11:55.702759+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T13:00:00+00:00 PythonOperator 2021-04-25T14:11:44.030073+00:00 2021-04-25T14:11:47.052481+00:00 0:00:03.022408 21129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T14:11:41.652259+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T13:00:00+00:00 PythonOperator 2021-04-25T14:11:37.829325+00:00 2021-04-25T14:11:41.026878+00:00 0:00:03.197553 21128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T14:11:35.651141+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T13:00:00+00:00 TriggerDagRunOperator 2021-04-25T14:11:21.930097+00:00 2021-04-25T14:11:22.449248+00:00 0:00:00.519151 21127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T14:11:19.627158+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T13:00:00+00:00 TriggerDagRunOperator 2021-04-25T14:11:21.820386+00:00 2021-04-25T14:11:22.213919+00:00 0:00:00.393533 21126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T14:11:19.627185+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T13:05:00+00:00 EmrJobFlowSensor 2021-04-25T14:05:49.100690+00:00 2021-04-25T14:14:51.664579+00:00 0:09:02.563889 21125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T14:05:46.933810+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T14:05:27.107149+00:00 2021-04-25T14:05:28.750372+00:00 0:00:01.643223 21124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T14:05:24.881494+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T13:05:00+00:00 PythonOperator 2021-04-25T14:05:06.974871+00:00 2021-04-25T14:05:09.970816+00:00 0:00:02.995945 21123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T14:05:04.817946+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T13:00:00+00:00 EmrJobFlowSensor 2021-04-25T14:00:54.505089+00:00 2021-04-25T14:10:57.365295+00:00 0:10:02.860206 21122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T14:00:52.287864+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T14:00:33.061494+00:00 2021-04-25T14:00:34.865298+00:00 0:00:01.803804 21121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T14:00:30.444529+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T13:00:00+00:00 PythonOperator 2021-04-25T14:00:10.915040+00:00 2021-04-25T14:00:13.951063+00:00 0:00:03.036023 21120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T14:00:07.948489+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T12:00:00+00:00 EmrJobFlowSensor 2021-04-25T13:12:22.323167+00:00 2021-04-25T13:22:25.269188+00:00 0:10:02.946021 21118 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T13:12:20.091136+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T12:00:00+00:00 EmrJobFlowSensor 2021-04-25T13:12:20.448988+00:00 2021-04-25T13:22:23.243625+00:00 0:10:02.794637 21117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T13:12:18.163392+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T13:12:00.778358+00:00 2021-04-25T13:12:02.760341+00:00 0:00:01.981983 21116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T13:11:58.003197+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T13:12:00.711853+00:00 2021-04-25T13:12:02.450464+00:00 0:00:01.738611 21115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T13:11:58.003238+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T12:00:00+00:00 PythonOperator 2021-04-25T13:11:41.186989+00:00 2021-04-25T13:11:44.256014+00:00 0:00:03.069025 21114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T13:11:37.974051+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T12:00:00+00:00 PythonOperator 2021-04-25T13:11:39.092077+00:00 2021-04-25T13:11:42.710263+00:00 0:00:03.618186 21113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T13:11:35.968796+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T12:00:00+00:00 TriggerDagRunOperator 2021-04-25T13:11:30.578513+00:00 2021-04-25T13:11:31.157860+00:00 0:00:00.579347 21112 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T13:11:27.975512+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T12:00:00+00:00 TriggerDagRunOperator 2021-04-25T13:11:30.367068+00:00 2021-04-25T13:11:30.825357+00:00 0:00:00.458289 21111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T13:11:27.975470+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T12:05:00+00:00 EmrJobFlowSensor 2021-04-25T13:06:05.419856+00:00 2021-04-25T13:15:07.991635+00:00 0:09:02.571779 21110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T13:06:03.259915+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T13:05:41.403698+00:00 2021-04-25T13:05:43.127461+00:00 0:00:01.723763 21109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T13:05:39.187883+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T12:05:00+00:00 PythonOperator 2021-04-25T13:05:19.547636+00:00 2021-04-25T13:05:22.558943+00:00 0:00:03.011307 21108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T13:05:17.161390+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T12:00:00+00:00 EmrJobFlowSensor 2021-04-25T13:01:07.177051+00:00 2021-04-25T13:11:10.091391+00:00 0:10:02.914340 21107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T13:01:04.555931+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T13:00:42.692671+00:00 2021-04-25T13:00:44.479271+00:00 0:00:01.786600 21106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T13:00:40.395177+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T12:00:00+00:00 PythonOperator 2021-04-25T13:00:22.505734+00:00 2021-04-25T13:00:25.482913+00:00 0:00:02.977179 21105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T13:00:20.382987+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T11:00:00+00:00 EmrJobFlowSensor 2021-04-25T12:31:23.095245+00:00 2021-04-25T12:40:25.630088+00:00 0:09:02.534843 21104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T12:31:20.743949+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T11:00:00+00:00 EmrJobFlowSensor 2021-04-25T12:31:07.220796+00:00 2021-04-25T12:41:10.010180+00:00 0:10:02.789384 21103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T12:31:04.753678+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T12:31:01.037375+00:00 2021-04-25T12:31:02.761230+00:00 0:00:01.723855 21102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T12:30:58.740939+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T12:30:45.249566+00:00 2021-04-25T12:30:47.006914+00:00 0:00:01.757348 21101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T12:30:42.750475+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T11:00:00+00:00 PythonOperator 2021-04-25T12:30:39.112225+00:00 2021-04-25T12:30:42.220571+00:00 0:00:03.108346 21100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T12:30:36.680162+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T11:00:00+00:00 PythonOperator 2021-04-25T12:30:25.170982+00:00 2021-04-25T12:30:28.442405+00:00 0:00:03.271423 21099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T12:30:22.665540+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T11:00:00+00:00 TriggerDagRunOperator 2021-04-25T12:30:19.176660+00:00 2021-04-25T12:30:19.591020+00:00 0:00:00.414360 21098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T12:30:16.575426+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T11:00:00+00:00 TriggerDagRunOperator 2021-04-25T12:30:18.889954+00:00 2021-04-25T12:30:19.419596+00:00 0:00:00.529642 21097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T12:30:16.575456+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T11:05:00+00:00 EmrJobFlowSensor 2021-04-25T12:21:07.491593+00:00 2021-04-25T12:30:10.053166+00:00 0:09:02.561573 21096 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T12:21:05.254620+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T11:00:00+00:00 EmrJobFlowSensor 2021-04-25T12:20:55.711263+00:00 2021-04-25T12:29:58.390748+00:00 0:09:02.679485 21095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T12:20:53.270575+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T12:20:47.461679+00:00 2021-04-25T12:20:49.191217+00:00 0:00:01.729538 21094 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T12:20:45.191600+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T12:20:33.518939+00:00 2021-04-25T12:20:35.320514+00:00 0:00:01.801575 21093 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T12:20:31.186087+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T11:05:00+00:00 PythonOperator 2021-04-25T12:20:25.442142+00:00 2021-04-25T12:20:28.465896+00:00 0:00:03.023754 21092 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T12:20:23.177999+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T11:00:00+00:00 PythonOperator 2021-04-25T12:20:14.009680+00:00 2021-04-25T12:20:17.010665+00:00 0:00:03.000985 21091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T12:20:11.172139+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T10:00:00+00:00 EmrJobFlowSensor 2021-04-25T11:10:56.684250+00:00 2021-04-25T11:19:59.525783+00:00 0:09:02.841533 21089 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T11:10:54.270570+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T10:00:00+00:00 EmrJobFlowSensor 2021-04-25T11:10:18.306803+00:00 2021-04-25T11:20:21.162693+00:00 0:10:02.855890 21088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T11:10:16.120453+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T11:09:56.219395+00:00 2021-04-25T11:09:57.863913+00:00 0:00:01.644518 21087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T11:09:54.105638+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T11:09:38.590600+00:00 2021-04-25T11:09:40.375719+00:00 0:00:01.785119 21086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T11:09:36.147654+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T10:00:00+00:00 PythonOperator 2021-04-25T11:09:34.504575+00:00 2021-04-25T11:09:37.479143+00:00 0:00:02.974568 21085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T11:09:32.083664+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T10:00:00+00:00 PythonOperator 2021-04-25T11:09:18.656839+00:00 2021-04-25T11:09:21.842882+00:00 0:00:03.186043 21084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T11:09:16.043790+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T10:00:00+00:00 TriggerDagRunOperator 2021-04-25T11:09:10.389963+00:00 2021-04-25T11:09:10.828938+00:00 0:00:00.438975 21083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T11:09:08.046665+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T10:00:00+00:00 TriggerDagRunOperator 2021-04-25T11:09:10.390738+00:00 2021-04-25T11:09:10.937524+00:00 0:00:00.546786 21082 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T11:09:08.046632+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T10:05:00+00:00 EmrJobFlowSensor 2021-04-25T11:06:11.969343+00:00 2021-04-25T11:14:14.544771+00:00 0:08:02.575428 21081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T11:06:09.780066+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T11:05:44.288829+00:00 2021-04-25T11:05:46.042231+00:00 0:00:01.753402 21080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T11:05:41.735372+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T10:05:00+00:00 PythonOperator 2021-04-25T11:05:16.164021+00:00 2021-04-25T11:05:19.114871+00:00 0:00:02.950850 21079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T11:05:13.855261+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T10:00:00+00:00 EmrJobFlowSensor 2021-04-25T11:00:57.434426+00:00 2021-04-25T11:08:59.974196+00:00 0:08:02.539770 21078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T11:00:55.305784+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T11:00:29.579560+00:00 2021-04-25T11:00:31.359342+00:00 0:00:01.779782 21077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T11:00:27.288739+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T10:00:00+00:00 PythonOperator 2021-04-25T11:00:09.554968+00:00 2021-04-25T11:00:12.508650+00:00 0:00:02.953682 21076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T11:00:07.227083+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T09:00:00+00:00 EmrJobFlowSensor 2021-04-25T10:24:17.535246+00:00 2021-04-25T10:24:19.116395+00:00 0:00:01.581149 21074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T10:24:15.093565+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T09:00:00+00:00 EmrJobFlowSensor 2021-04-25T10:12:14.458899+00:00 2021-04-25T10:21:17.224573+00:00 0:09:02.765674 21072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T10:12:11.962489+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T10:12:02.386931+00:00 2021-04-25T10:12:04.263550+00:00 0:00:01.876619 21071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T10:12:00.041276+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T10:11:52.042409+00:00 2021-04-25T10:11:53.835959+00:00 0:00:01.793550 21070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T10:11:49.833932+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T09:00:00+00:00 PythonOperator 2021-04-25T10:11:40.101998+00:00 2021-04-25T10:11:43.275850+00:00 0:00:03.173852 21069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T10:11:37.822914+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T09:00:00+00:00 PythonOperator 2021-04-25T10:11:30.523088+00:00 2021-04-25T10:11:33.470835+00:00 0:00:02.947747 21068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T10:11:27.957168+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T09:00:00+00:00 TriggerDagRunOperator 2021-04-25T10:11:18.803277+00:00 2021-04-25T10:11:19.211274+00:00 0:00:00.407997 21067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T10:11:15.944676+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T09:00:00+00:00 TriggerDagRunOperator 2021-04-25T10:11:18.476212+00:00 2021-04-25T10:11:18.978263+00:00 0:00:00.502051 21066 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T10:11:15.944711+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T09:05:00+00:00 EmrJobFlowSensor 2021-04-25T10:05:59.679816+00:00 2021-04-25T10:15:02.388652+00:00 0:09:02.708836 21065 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T10:05:57.315854+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T10:05:37.608705+00:00 2021-04-25T10:05:39.226250+00:00 0:00:01.617545 21064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T10:05:35.366886+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T09:05:00+00:00 PythonOperator 2021-04-25T10:05:17.507898+00:00 2021-04-25T10:05:20.436833+00:00 0:00:02.928935 21063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T10:05:15.340683+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T09:00:00+00:00 EmrJobFlowSensor 2021-04-25T10:01:07.262001+00:00 2021-04-25T10:11:10.112106+00:00 0:10:02.850105 21062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T10:01:04.848866+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T10:00:45.206967+00:00 2021-04-25T10:00:46.998646+00:00 0:00:01.791679 21061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T10:00:42.773451+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T09:00:00+00:00 PythonOperator 2021-04-25T10:00:24.991362+00:00 2021-04-25T10:00:27.997369+00:00 0:00:03.006007 21060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T10:00:22.704718+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T08:00:00+00:00 EmrJobFlowSensor 2021-04-25T09:11:17.175491+00:00 2021-04-25T09:21:19.831982+00:00 0:10:02.656491 21058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T09:11:15.001418+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T08:00:00+00:00 EmrJobFlowSensor 2021-04-25T09:11:09.398793+00:00 2021-04-25T09:19:12.025742+00:00 0:08:02.626949 21057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T09:11:06.990444+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T09:10:55.384116+00:00 2021-04-25T09:10:57.153959+00:00 0:00:01.769843 21056 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T09:10:52.936633+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T09:10:49.165354+00:00 2021-04-25T09:10:50.828095+00:00 0:00:01.662741 21055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T09:10:46.931150+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T08:00:00+00:00 PythonOperator 2021-04-25T09:10:36.072315+00:00 2021-04-25T09:10:39.237515+00:00 0:00:03.165200 21054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T09:10:32.917679+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T08:00:00+00:00 PythonOperator 2021-04-25T09:10:27.539706+00:00 2021-04-25T09:10:30.457738+00:00 0:00:02.918032 21053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T09:10:24.909716+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T08:00:00+00:00 TriggerDagRunOperator 2021-04-25T09:10:19.189712+00:00 2021-04-25T09:10:19.597363+00:00 0:00:00.407651 21052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T09:10:16.903869+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T08:00:00+00:00 TriggerDagRunOperator 2021-04-25T09:10:19.213675+00:00 2021-04-25T09:10:19.746983+00:00 0:00:00.533308 21051 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T09:10:16.903903+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T08:05:00+00:00 EmrJobFlowSensor 2021-04-25T09:05:54.692955+00:00 2021-04-25T09:14:57.286888+00:00 0:09:02.593933 21050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T09:05:52.524251+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T09:05:32.699028+00:00 2021-04-25T09:05:34.335002+00:00 0:00:01.635974 21049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T09:05:30.502532+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T08:05:00+00:00 PythonOperator 2021-04-25T09:05:10.670335+00:00 2021-04-25T09:05:13.610884+00:00 0:00:02.940549 21048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T09:05:08.488101+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T08:00:00+00:00 EmrJobFlowSensor 2021-04-25T09:01:08.210925+00:00 2021-04-25T09:10:10.887592+00:00 0:09:02.676667 21047 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T09:01:06.014601+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T09:00:46.393104+00:00 2021-04-25T09:00:48.157860+00:00 0:00:01.764756 21046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T09:00:44.068732+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T08:00:00+00:00 PythonOperator 2021-04-25T09:00:24.701266+00:00 2021-04-25T09:00:27.664946+00:00 0:00:02.963680 21045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T09:00:21.960449+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-25T07:00:00+00:00 EmrJobFlowSensor 2021-04-25T08:10:20.388548+00:00 2021-04-25T08:19:23.009679+00:00 0:09:02.621131 21043 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T08:10:18.165021+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-25T07:00:00+00:00 EmrJobFlowSensor 2021-04-25T08:10:08.431574+00:00 2021-04-25T08:20:11.305540+00:00 0:10:02.873966 21042 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T08:10:06.103261+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-25T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T08:09:58.406598+00:00 2021-04-25T08:10:00.151170+00:00 0:00:01.744572 21041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T08:09:56.160071+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-25T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T08:09:46.199343+00:00 2021-04-25T08:09:47.897556+00:00 0:00:01.698213 21040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T08:09:44.085196+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-25T07:00:00+00:00 PythonOperator 2021-04-25T08:09:36.379231+00:00 2021-04-25T08:09:39.356495+00:00 0:00:02.977264 21039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T08:09:34.078034+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-25T07:00:00+00:00 PythonOperator 2021-04-25T08:09:24.575680+00:00 2021-04-25T08:09:27.842355+00:00 0:00:03.266675 21038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T08:09:22.053093+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T07:00:00+00:00 TriggerDagRunOperator 2021-04-25T08:09:14.900109+00:00 2021-04-25T08:09:15.401014+00:00 0:00:00.500905 21037 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T08:09:12.053508+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T07:00:00+00:00 TriggerDagRunOperator 2021-04-25T08:09:14.481904+00:00 2021-04-25T08:09:14.889845+00:00 0:00:00.407941 21036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T08:09:12.053450+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-25T07:05:00+00:00 EmrJobFlowSensor 2021-04-25T08:05:52.055512+00:00 2021-04-25T08:14:54.662616+00:00 0:09:02.607104 21035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T08:05:49.748621+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-25T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-25T08:05:30.386215+00:00 2021-04-25T08:05:32.123161+00:00 0:00:01.736946 21034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-25T08:05:27.858282+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-25T07:05:00+00:00 PythonOperator 2021-04-25T08:05:07.965807+00:00 2021-04-25T08:05:10.938875+00:00 0:00:02.973068 21033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T08:05:05.748134+00:00 2 default_pool