Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T01:00:00+00:00 TriggerDagRunOperator 2021-04-12T02:11:17.284065+00:00 2021-04-12T02:11:17.708417+00:00 0:00:00.424352 16207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T02:11:15.200212+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T01:05:00+00:00 EmrJobFlowSensor 2021-04-12T02:06:04.756973+00:00 2021-04-12T02:14:07.396851+00:00 0:08:02.639878 16206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T02:06:02.423324+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T02:05:40.775521+00:00 2021-04-12T02:05:42.512859+00:00 0:00:01.737338 16205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T02:05:38.471837+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T01:05:00+00:00 PythonOperator 2021-04-12T02:05:20.765017+00:00 2021-04-12T02:05:23.662661+00:00 0:00:02.897644 16204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T02:05:18.460517+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T01:00:00+00:00 EmrJobFlowSensor 2021-04-12T02:02:10.402649+00:00 2021-04-12T02:11:13.133111+00:00 0:09:02.730462 16203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T02:02:08.037581+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T02:01:50.776039+00:00 2021-04-12T02:01:52.505304+00:00 0:00:01.729265 16202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T02:01:48.017044+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T01:00:00+00:00 PythonOperator 2021-04-12T02:01:28.470223+00:00 2021-04-12T02:01:31.515230+00:00 0:00:03.045007 16201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T02:01:25.998480+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T00:00:00+00:00 EmrJobFlowSensor 2021-04-12T01:12:20.389175+00:00 2021-04-12T01:22:23.264907+00:00 0:10:02.875732 16199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T01:12:18.065772+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T00:00:00+00:00 EmrJobFlowSensor 2021-04-12T01:12:10.715443+00:00 2021-04-12T01:22:13.515401+00:00 0:10:02.799958 16198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T01:12:08.081570+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T01:12:00.893191+00:00 2021-04-12T01:12:02.612508+00:00 0:00:01.719317 16197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T01:11:58.057632+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T01:11:48.348053+00:00 2021-04-12T01:11:50.050188+00:00 0:00:01.702135 16196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T01:11:45.968468+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T00:00:00+00:00 PythonOperator 2021-04-12T01:11:38.313832+00:00 2021-04-12T01:11:41.483995+00:00 0:00:03.170163 16195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T01:11:35.953771+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T00:00:00+00:00 PythonOperator 2021-04-12T01:11:28.442886+00:00 2021-04-12T01:11:31.425935+00:00 0:00:02.983049 16194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T01:11:25.953867+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T00:00:00+00:00 TriggerDagRunOperator 2021-04-12T01:11:18.575349+00:00 2021-04-12T01:11:19.005061+00:00 0:00:00.429712 16193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T01:11:15.836739+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T00:00:00+00:00 TriggerDagRunOperator 2021-04-12T01:11:18.288265+00:00 2021-04-12T01:11:18.940293+00:00 0:00:00.652028 16192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T01:11:15.836712+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T00:05:00+00:00 EmrJobFlowSensor 2021-04-12T01:05:49.683783+00:00 2021-04-12T01:14:52.127035+00:00 0:09:02.443252 16191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T01:05:47.346683+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T01:05:29.381426+00:00 2021-04-12T01:05:31.004468+00:00 0:00:01.623042 16190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T01:05:27.286523+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T00:05:00+00:00 PythonOperator 2021-04-12T01:05:07.494110+00:00 2021-04-12T01:05:10.159751+00:00 0:00:02.665641 16189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T01:05:05.218465+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T00:00:00+00:00 EmrJobFlowSensor 2021-04-12T01:01:05.144114+00:00 2021-04-12T01:11:07.937866+00:00 0:10:02.793752 16188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T01:01:02.791125+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T01:00:43.032380+00:00 2021-04-12T01:00:44.731325+00:00 0:00:01.698945 16187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T01:00:40.765276+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T00:00:00+00:00 PythonOperator 2021-04-12T01:00:23.250466+00:00 2021-04-12T01:00:26.411969+00:00 0:00:03.161503 16186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T01:00:20.748724+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T23:00:00+00:00 EmrJobFlowSensor 2021-04-12T00:12:12.883086+00:00 2021-04-12T00:21:15.585869+00:00 0:09:02.702783 16184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T00:12:10.461338+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T23:00:00+00:00 EmrJobFlowSensor 2021-04-12T00:12:10.687089+00:00 2021-04-12T00:22:13.488846+00:00 0:10:02.801757 16183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T00:12:08.461954+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T00:11:50.855505+00:00 2021-04-12T00:11:52.553984+00:00 0:00:01.698479 16182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T00:11:48.323260+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T00:11:48.513245+00:00 2021-04-12T00:11:50.495189+00:00 0:00:01.981944 16181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T00:11:46.323302+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T23:00:00+00:00 PythonOperator 2021-04-12T00:11:28.742185+00:00 2021-04-12T00:11:31.762427+00:00 0:00:03.020242 16180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T00:11:26.309370+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T23:00:00+00:00 PythonOperator 2021-04-12T00:11:26.747405+00:00 2021-04-12T00:11:29.479675+00:00 0:00:02.732270 16179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T00:11:24.364459+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T23:00:00+00:00 TriggerDagRunOperator 2021-04-12T00:11:08.911000+00:00 2021-04-12T00:11:09.429366+00:00 0:00:00.518366 16178 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T00:11:06.296617+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T23:00:00+00:00 TriggerDagRunOperator 2021-04-12T00:11:08.596519+00:00 2021-04-12T00:11:09.026696+00:00 0:00:00.430177 16177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T00:11:06.296565+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T23:05:00+00:00 EmrJobFlowSensor 2021-04-12T00:06:08.385186+00:00 2021-04-12T00:14:11.004238+00:00 0:08:02.619052 16176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T00:06:05.989709+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T00:05:30.593795+00:00 2021-04-12T00:05:32.358857+00:00 0:00:01.765062 16175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T00:05:28.058235+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T23:05:00+00:00 PythonOperator 2021-04-12T00:05:10.289740+00:00 2021-04-12T00:05:13.090308+00:00 0:00:02.800568 16174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T00:05:07.911812+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T23:00:00+00:00 EmrJobFlowSensor 2021-04-12T00:00:53.991107+00:00 2021-04-12T00:10:56.860582+00:00 0:10:02.869475 16173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T00:00:51.673586+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T00:00:28.055358+00:00 2021-04-12T00:00:29.884069+00:00 0:00:01.828711 16172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T00:00:25.645485+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T23:00:00+00:00 PythonOperator 2021-04-12T00:00:08.066161+00:00 2021-04-12T00:00:10.805244+00:00 0:00:02.739083 16171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T00:00:05.555081+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T22:00:00+00:00 EmrJobFlowSensor 2021-04-11T23:11:32.010268+00:00 2021-04-11T23:19:34.429254+00:00 0:08:02.418986 16169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T23:11:29.845225+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T22:00:00+00:00 EmrJobFlowSensor 2021-04-11T23:11:28.123613+00:00 2021-04-11T23:21:30.925006+00:00 0:10:02.801393 16168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T23:11:25.749987+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T23:11:10.347564+00:00 2021-04-11T23:11:12.042542+00:00 0:00:01.694978 16167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T23:11:07.735486+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T23:11:06.018659+00:00 2021-04-11T23:11:07.911955+00:00 0:00:01.893296 16166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T23:11:03.741382+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T22:00:00+00:00 PythonOperator 2021-04-11T23:10:40.016575+00:00 2021-04-11T23:10:43.035965+00:00 0:00:03.019390 16165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T23:10:37.711280+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T22:00:00+00:00 PythonOperator 2021-04-11T23:10:38.037605+00:00 2021-04-11T23:10:40.799351+00:00 0:00:02.761746 16164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T23:10:35.727649+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T22:00:00+00:00 TriggerDagRunOperator 2021-04-11T23:10:20.041515+00:00 2021-04-11T23:10:20.563403+00:00 0:00:00.521888 16163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T23:10:17.700812+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T22:00:00+00:00 TriggerDagRunOperator 2021-04-11T23:10:19.897942+00:00 2021-04-11T23:10:20.288932+00:00 0:00:00.390990 16162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T23:10:17.700778+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T22:05:00+00:00 EmrJobFlowSensor 2021-04-11T23:06:07.432396+00:00 2021-04-11T23:14:09.857173+00:00 0:08:02.424777 16161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T23:06:05.299364+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T23:05:45.651064+00:00 2021-04-11T23:05:47.382843+00:00 0:00:01.731779 16160 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T23:05:43.266108+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T22:05:00+00:00 PythonOperator 2021-04-11T23:05:23.396895+00:00 2021-04-11T23:05:26.263946+00:00 0:00:02.867051 16159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T23:05:21.249383+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T22:00:00+00:00 EmrJobFlowSensor 2021-04-11T23:00:55.053718+00:00 2021-04-11T23:09:57.785711+00:00 0:09:02.731993 16158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T23:00:52.702103+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T23:00:34.866605+00:00 2021-04-11T23:00:36.529579+00:00 0:00:01.662974 16157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T23:00:32.685004+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T22:00:00+00:00 PythonOperator 2021-04-11T23:00:13.015671+00:00 2021-04-11T23:00:15.779036+00:00 0:00:02.763365 16156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T23:00:10.607968+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T21:00:00+00:00 EmrJobFlowSensor 2021-04-11T22:14:21.678264+00:00 2021-04-11T22:24:24.491724+00:00 0:10:02.813460 16154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T22:14:19.503282+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T21:00:00+00:00 EmrJobFlowSensor 2021-04-11T22:14:15.878743+00:00 2021-04-11T22:23:18.726129+00:00 0:09:02.847386 16153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T22:14:13.556423+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T22:14:02.102112+00:00 2021-04-11T22:14:03.833499+00:00 0:00:01.731387 16152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T22:13:59.566457+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T22:13:55.822956+00:00 2021-04-11T22:13:57.609582+00:00 0:00:01.786626 16151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T22:13:53.437394+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T21:00:00+00:00 PythonOperator 2021-04-11T22:13:40.604694+00:00 2021-04-11T22:13:43.681403+00:00 0:00:03.076709 16150 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T22:13:37.424507+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T21:00:00+00:00 PythonOperator 2021-04-11T22:13:34.155182+00:00 2021-04-11T22:13:36.976033+00:00 0:00:02.820851 16149 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T22:13:31.418003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T21:00:00+00:00 TriggerDagRunOperator 2021-04-11T22:13:20.006324+00:00 2021-04-11T22:13:20.547549+00:00 0:00:00.541225 16148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T22:13:17.411443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T21:00:00+00:00 TriggerDagRunOperator 2021-04-11T22:13:19.688707+00:00 2021-04-11T22:13:20.122509+00:00 0:00:00.433802 16147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T22:13:17.411478+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T21:05:00+00:00 EmrJobFlowSensor 2021-04-11T22:05:54.872931+00:00 2021-04-11T22:13:57.939090+00:00 0:08:03.066159 16146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T22:05:52.602766+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T22:05:32.959350+00:00 2021-04-11T22:05:34.598751+00:00 0:00:01.639401 16145 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T22:05:30.654589+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T21:05:00+00:00 PythonOperator 2021-04-11T22:05:10.684824+00:00 2021-04-11T22:05:13.479416+00:00 0:00:02.794592 16144 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T22:05:08.522888+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T21:00:00+00:00 EmrJobFlowSensor 2021-04-11T22:00:54.501629+00:00 2021-04-11T22:12:57.593157+00:00 0:12:03.091528 16143 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T22:00:52.204707+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T22:00:34.511301+00:00 2021-04-11T22:00:36.232996+00:00 0:00:01.721695 16142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T22:00:32.184584+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T21:00:00+00:00 PythonOperator 2021-04-11T22:00:12.862849+00:00 2021-04-11T22:00:15.577912+00:00 0:00:02.715063 16141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T22:00:10.129879+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T20:00:00+00:00 EmrJobFlowSensor 2021-04-11T21:11:07.768395+00:00 2021-04-11T21:21:10.742377+00:00 0:10:02.973982 16139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T21:11:05.503787+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T20:00:00+00:00 EmrJobFlowSensor 2021-04-11T21:11:03.686580+00:00 2021-04-11T21:19:06.112076+00:00 0:08:02.425496 16138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T21:11:01.494288+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T21:10:45.801622+00:00 2021-04-11T21:10:47.505637+00:00 0:00:01.704015 16137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T21:10:43.434067+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T21:10:41.875226+00:00 2021-04-11T21:10:43.531997+00:00 0:00:01.656771 16136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T21:10:39.432920+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T20:00:00+00:00 PythonOperator 2021-04-11T21:10:26.007129+00:00 2021-04-11T21:10:29.026895+00:00 0:00:03.019766 16135 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T21:10:23.419768+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T20:00:00+00:00 PythonOperator 2021-04-11T21:10:19.747312+00:00 2021-04-11T21:10:22.709083+00:00 0:00:02.961771 16134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T21:10:17.414404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T20:00:00+00:00 TriggerDagRunOperator 2021-04-11T21:10:13.750977+00:00 2021-04-11T21:10:14.284342+00:00 0:00:00.533365 16133 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T21:10:11.409374+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T20:00:00+00:00 TriggerDagRunOperator 2021-04-11T21:10:13.601023+00:00 2021-04-11T21:10:14.088824+00:00 0:00:00.487801 16132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T21:10:11.409408+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T20:05:00+00:00 EmrJobFlowSensor 2021-04-11T21:06:01.266960+00:00 2021-04-11T21:14:03.825021+00:00 0:08:02.558061 16131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T21:05:59.053295+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T21:05:39.048350+00:00 2021-04-11T21:05:40.663130+00:00 0:00:01.614780 16130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T21:05:36.895097+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T20:05:00+00:00 PythonOperator 2021-04-11T21:05:16.975035+00:00 2021-04-11T21:05:19.617443+00:00 0:00:02.642408 16129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T21:05:14.876170+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T20:00:00+00:00 EmrJobFlowSensor 2021-04-11T21:00:54.543635+00:00 2021-04-11T21:09:57.070813+00:00 0:09:02.527178 16128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T21:00:52.307521+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T21:00:32.758167+00:00 2021-04-11T21:00:34.496809+00:00 0:00:01.738642 16127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T21:00:30.353179+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T20:00:00+00:00 PythonOperator 2021-04-11T21:00:10.629200+00:00 2021-04-11T21:00:13.329692+00:00 0:00:02.700492 16126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T21:00:08.260221+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T19:00:00+00:00 EmrJobFlowSensor 2021-04-11T20:12:12.989239+00:00 2021-04-11T20:21:15.607325+00:00 0:09:02.618086 16124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T20:12:10.746220+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T19:00:00+00:00 EmrJobFlowSensor 2021-04-11T20:11:59.228415+00:00 2021-04-11T20:22:02.103501+00:00 0:10:02.875086 16123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T20:11:56.680095+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T20:11:50.918487+00:00 2021-04-11T20:11:52.715252+00:00 0:00:01.796765 16122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T20:11:48.642220+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T20:11:39.144305+00:00 2021-04-11T20:11:40.839126+00:00 0:00:01.694821 16121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T20:11:36.757672+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T19:00:00+00:00 PythonOperator 2021-04-11T20:11:30.916665+00:00 2021-04-11T20:11:33.747213+00:00 0:00:02.830548 16120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T20:11:28.661401+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T19:00:00+00:00 PythonOperator 2021-04-11T20:11:17.147286+00:00 2021-04-11T20:11:20.478213+00:00 0:00:03.330927 16119 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T20:11:14.595764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T19:00:00+00:00 TriggerDagRunOperator 2021-04-11T20:11:04.908861+00:00 2021-04-11T20:11:05.411113+00:00 0:00:00.502252 16118 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T20:11:02.588863+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T19:00:00+00:00 TriggerDagRunOperator 2021-04-11T20:11:04.732599+00:00 2021-04-11T20:11:05.144058+00:00 0:00:00.411459 16117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T20:11:02.588896+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T19:05:00+00:00 EmrJobFlowSensor 2021-04-11T20:05:48.148358+00:00 2021-04-11T20:13:50.569278+00:00 0:08:02.420920 16116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T20:05:45.993600+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T20:05:26.320255+00:00 2021-04-11T20:05:27.951355+00:00 0:00:01.631100 16115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T20:05:23.969732+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T19:05:00+00:00 PythonOperator 2021-04-11T20:05:06.196505+00:00 2021-04-11T20:05:08.992697+00:00 0:00:02.796192 16114 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T20:05:03.944980+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T19:00:00+00:00 EmrJobFlowSensor 2021-04-11T20:00:49.867578+00:00 2021-04-11T20:10:52.770312+00:00 0:10:02.902734 16113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T20:00:47.606700+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T20:00:29.921124+00:00 2021-04-11T20:00:31.679724+00:00 0:00:01.758600 16112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T20:00:27.591950+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T19:00:00+00:00 PythonOperator 2021-04-11T20:00:08.189919+00:00 2021-04-11T20:00:10.899652+00:00 0:00:02.709733 16111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T20:00:05.564901+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T18:00:00+00:00 EmrJobFlowSensor 2021-04-11T19:21:10.621424+00:00 2021-04-11T19:31:13.293733+00:00 0:10:02.672309 16109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T19:21:07.848894+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T18:00:00+00:00 EmrJobFlowSensor 2021-04-11T19:21:07.997234+00:00 2021-04-11T19:31:11.151667+00:00 0:10:03.154433 16108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T19:21:05.777383+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T19:20:50.509541+00:00 2021-04-11T19:20:52.345793+00:00 0:00:01.836252 16107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T19:20:47.762232+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T19:20:48.236815+00:00 2021-04-11T19:20:50.315830+00:00 0:00:02.079015 16106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T19:20:45.766791+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T18:00:00+00:00 PythonOperator 2021-04-11T19:20:29.167957+00:00 2021-04-11T19:20:31.879669+00:00 0:00:02.711712 16105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T19:20:25.675162+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T18:00:00+00:00 PythonOperator 2021-04-11T19:20:26.802007+00:00 2021-04-11T19:20:30.291157+00:00 0:00:03.489150 16104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T19:20:23.665987+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T18:00:00+00:00 TriggerDagRunOperator 2021-04-11T19:20:20.011255+00:00 2021-04-11T19:20:20.526970+00:00 0:00:00.515715 16103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T19:20:17.589573+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T18:00:00+00:00 TriggerDagRunOperator 2021-04-11T19:20:19.851491+00:00 2021-04-11T19:20:20.261430+00:00 0:00:00.409939 16102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T19:20:17.589601+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T18:05:00+00:00 EmrJobFlowSensor 2021-04-11T19:05:54.716981+00:00 2021-04-11T19:13:57.207908+00:00 0:08:02.490927 16101 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T19:05:52.271829+00:00 2 default_pool