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 check_cluster_status 2021-05-10T22:00:00+00:00 EmrJobFlowSensor 2021-05-10T23:01:08.716064+00:00 2021-05-10T23:10:11.680824+00:00 0:09:02.964760 26704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T23:01:06.431006+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-05-09T23:00:00+00:00 EmrJobFlowSensor 2021-05-10T23:01:06.449165+00:00 2021-05-10T23:11:09.236606+00:00 0:10:02.787441 26703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T23:01:04.427502+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T23:00:44.652409+00:00 2021-05-10T23:00:46.428766+00:00 0:00:01.776357 26702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T23:00:42.385345+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-05-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T23:00:42.585510+00:00 2021-05-10T23:00:44.347207+00:00 0:00:01.761697 26701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T23:00:40.384087+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-05-09T23:00:00+00:00 PythonOperator 2021-05-10T23:00:20.667460+00:00 2021-05-10T23:00:23.821757+00:00 0:00:03.154297 26700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T23:00:18.374433+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T22:00:00+00:00 PythonOperator 2021-05-10T23:00:14.533316+00:00 2021-05-10T23:00:17.656180+00:00 0:00:03.122864 26699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T23:00:12.360063+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T21:00:00+00:00 EmrJobFlowSensor 2021-05-10T22:10:14.067436+00:00 2021-05-10T22:21:16.943144+00:00 0:11:02.875708 26698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T22:10:11.745580+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T21:00:00+00:00 EmrJobFlowSensor 2021-05-10T22:10:11.888686+00:00 2021-05-10T22:19:14.769760+00:00 0:09:02.881074 26697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T22:10:09.739917+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T22:09:54.010985+00:00 2021-05-10T22:09:55.757230+00:00 0:00:01.746245 26696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T22:09:51.727912+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T22:09:50.143373+00:00 2021-05-10T22:09:51.982051+00:00 0:00:01.838678 26695 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T22:09:47.724588+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T21:00:00+00:00 PythonOperator 2021-05-10T22:09:30.410151+00:00 2021-05-10T22:09:33.682936+00:00 0:00:03.272785 26694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T22:09:27.769348+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T21:00:00+00:00 PythonOperator 2021-05-10T22:09:28.000567+00:00 2021-05-10T22:09:31.478529+00:00 0:00:03.477962 26693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T22:09:25.773970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T21:00:00+00:00 TriggerDagRunOperator 2021-05-10T22:09:08.302579+00:00 2021-05-10T22:09:08.848808+00:00 0:00:00.546229 26692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T22:09:05.694361+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T21:00:00+00:00 TriggerDagRunOperator 2021-05-10T22:09:08.253539+00:00 2021-05-10T22:09:08.663356+00:00 0:00:00.409817 26691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T22:09:05.694401+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T21:05:00+00:00 EmrJobFlowSensor 2021-05-10T22:06:10.050878+00:00 2021-05-10T22:15:12.668064+00:00 0:09:02.617186 26689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T22:06:07.913113+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T22:05:42.230308+00:00 2021-05-10T22:05:44.084643+00:00 0:00:01.854335 26688 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T22:05:39.948298+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T21:05:00+00:00 PythonOperator 2021-05-10T22:05:22.307419+00:00 2021-05-10T22:05:25.440669+00:00 0:00:03.133250 26687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T22:05:19.830940+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T21:00:00+00:00 EmrJobFlowSensor 2021-05-10T22:00:47.675474+00:00 2021-05-10T22:08:50.295930+00:00 0:08:02.620456 26686 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T22:00:45.320731+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T22:00:25.838668+00:00 2021-05-10T22:00:27.746770+00:00 0:00:01.908102 26685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T22:00:23.369612+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T21:00:00+00:00 PythonOperator 2021-05-10T22:00:05.526383+00:00 2021-05-10T22:00:08.610571+00:00 0:00:03.084188 26684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T22:00:03.288917+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T20:00:00+00:00 EmrJobFlowSensor 2021-05-10T21:11:12.260526+00:00 2021-05-10T21:20:15.089291+00:00 0:09:02.828765 26683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T21:11:10.034964+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T20:00:00+00:00 EmrJobFlowSensor 2021-05-10T21:11:00.343777+00:00 2021-05-10T21:19:03.068463+00:00 0:08:02.724686 26682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T21:10:58.023642+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T21:10:50.431007+00:00 2021-05-10T21:10:52.148511+00:00 0:00:01.717504 26681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T21:10:48.013849+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T21:10:38.392832+00:00 2021-05-10T21:10:40.060222+00:00 0:00:01.667390 26680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T21:10:36.052869+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T20:00:00+00:00 PythonOperator 2021-05-10T21:10:28.474725+00:00 2021-05-10T21:10:31.791238+00:00 0:00:03.316513 26679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T21:10:26.060560+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T20:00:00+00:00 PythonOperator 2021-05-10T21:10:16.734117+00:00 2021-05-10T21:10:19.947148+00:00 0:00:03.213031 26678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T21:10:14.061311+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T20:00:00+00:00 TriggerDagRunOperator 2021-05-10T21:10:08.869518+00:00 2021-05-10T21:10:09.318670+00:00 0:00:00.449152 26677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T21:10:05.855197+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T20:00:00+00:00 TriggerDagRunOperator 2021-05-10T21:10:08.819039+00:00 2021-05-10T21:10:09.382525+00:00 0:00:00.563486 26676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T21:10:05.855158+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T20:05:00+00:00 EmrJobFlowSensor 2021-05-10T21:05:55.353387+00:00 2021-05-10T21:14:57.954520+00:00 0:09:02.601133 26674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T21:05:52.973435+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T21:05:35.365477+00:00 2021-05-10T21:05:37.101413+00:00 0:00:01.735936 26673 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T21:05:32.975170+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T20:05:00+00:00 PythonOperator 2021-05-10T21:05:13.258611+00:00 2021-05-10T21:05:16.319600+00:00 0:00:03.060989 26672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T21:05:10.892296+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T20:00:00+00:00 EmrJobFlowSensor 2021-05-10T21:00:58.971648+00:00 2021-05-10T21:10:01.671800+00:00 0:09:02.700152 26671 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T21:00:56.593695+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T21:00:36.977361+00:00 2021-05-10T21:00:38.801501+00:00 0:00:01.824140 26670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T21:00:34.577946+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T20:00:00+00:00 PythonOperator 2021-05-10T21:00:15.068149+00:00 2021-05-10T21:00:18.194054+00:00 0:00:03.125905 26669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T21:00:12.543999+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T19:00:00+00:00 EmrJobFlowSensor 2021-05-10T20:11:35.561354+00:00 2021-05-10T20:20:38.124810+00:00 0:09:02.563456 26668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T20:11:33.479419+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T19:00:00+00:00 EmrJobFlowSensor 2021-05-10T20:11:21.605554+00:00 2021-05-10T20:20:24.174811+00:00 0:09:02.569257 26667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T20:11:19.463476+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T20:11:13.801319+00:00 2021-05-10T20:11:15.677760+00:00 0:00:01.876441 26666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T20:11:11.464885+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T20:10:59.571174+00:00 2021-05-10T20:11:01.261286+00:00 0:00:01.690112 26665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T20:10:57.410014+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T19:00:00+00:00 PythonOperator 2021-05-10T20:10:51.820154+00:00 2021-05-10T20:10:55.089460+00:00 0:00:03.269306 26664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T20:10:49.464103+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T19:00:00+00:00 PythonOperator 2021-05-10T20:10:37.510902+00:00 2021-05-10T20:10:40.652564+00:00 0:00:03.141662 26663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T20:10:35.385537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T19:00:00+00:00 TriggerDagRunOperator 2021-05-10T20:10:34.132349+00:00 2021-05-10T20:10:34.692267+00:00 0:00:00.559918 26662 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T20:10:31.444598+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T19:00:00+00:00 TriggerDagRunOperator 2021-05-10T20:10:33.869899+00:00 2021-05-10T20:10:34.322384+00:00 0:00:00.452485 26661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T20:10:31.444551+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T19:05:00+00:00 EmrJobFlowSensor 2021-05-10T20:06:07.500609+00:00 2021-05-10T20:15:10.193176+00:00 0:09:02.692567 26659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T20:06:05.233062+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T20:05:45.441753+00:00 2021-05-10T20:05:47.058109+00:00 0:00:01.616356 26658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T20:05:43.211040+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T19:05:00+00:00 PythonOperator 2021-05-10T20:05:23.401586+00:00 2021-05-10T20:05:26.502272+00:00 0:00:03.100686 26657 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T20:05:21.188465+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T19:00:00+00:00 EmrJobFlowSensor 2021-05-10T20:01:06.958752+00:00 2021-05-10T20:10:09.887627+00:00 0:09:02.928875 26656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T20:01:04.651609+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T20:00:46.651798+00:00 2021-05-10T20:00:48.362799+00:00 0:00:01.711001 26655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T20:00:44.522996+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T19:00:00+00:00 PythonOperator 2021-05-10T20:00:24.737697+00:00 2021-05-10T20:00:27.916606+00:00 0:00:03.178909 26654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T20:00:22.509029+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T18:00:00+00:00 EmrJobFlowSensor 2021-05-10T19:12:00.178880+00:00 2021-05-10T19:23:03.348190+00:00 0:11:03.169310 26653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T19:11:57.707829+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T18:00:00+00:00 EmrJobFlowSensor 2021-05-10T19:11:40.142127+00:00 2021-05-10T19:20:42.809785+00:00 0:09:02.667658 26652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T19:11:37.691809+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T19:11:37.832935+00:00 2021-05-10T19:11:39.802447+00:00 0:00:01.969512 26651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T19:11:35.694178+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T19:11:18.157292+00:00 2021-05-10T19:11:19.886817+00:00 0:00:01.729525 26650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T19:11:15.648913+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T18:00:00+00:00 PythonOperator 2021-05-10T19:11:15.999446+00:00 2021-05-10T19:11:19.569847+00:00 0:00:03.570401 26649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T19:11:13.646990+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T18:00:00+00:00 PythonOperator 2021-05-10T19:10:58.031984+00:00 2021-05-10T19:11:01.065474+00:00 0:00:03.033490 26648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T19:10:55.632384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T18:00:00+00:00 TriggerDagRunOperator 2021-05-10T19:10:49.995963+00:00 2021-05-10T19:10:50.518960+00:00 0:00:00.522997 26647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T19:10:47.626467+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T18:00:00+00:00 TriggerDagRunOperator 2021-05-10T19:10:49.765059+00:00 2021-05-10T19:10:50.182570+00:00 0:00:00.417511 26646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T19:10:47.626435+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T18:05:00+00:00 EmrJobFlowSensor 2021-05-10T19:07:53.681112+00:00 2021-05-10T19:15:56.302340+00:00 0:08:02.621228 26645 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T19:07:51.433418+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T18:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T19:07:25.498854+00:00 2021-05-10T19:07:27.148293+00:00 0:00:01.649439 26644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T19:07:23.408202+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T18:05:00+00:00 PythonOperator 2021-05-10T19:06:59.997035+00:00 2021-05-10T19:07:03.126042+00:00 0:00:03.129007 26643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T19:06:57.387794+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T18:00:00+00:00 EmrJobFlowSensor 2021-05-10T19:01:17.601480+00:00 2021-05-10T19:10:20.426826+00:00 0:09:02.825346 26641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T19:01:15.512621+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T19:00:47.832394+00:00 2021-05-10T19:00:49.522440+00:00 0:00:01.690046 26640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T19:00:45.490881+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T18:00:00+00:00 PythonOperator 2021-05-10T19:00:19.676189+00:00 2021-05-10T19:00:22.793685+00:00 0:00:03.117496 26639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T19:00:17.419939+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T17:00:00+00:00 EmrJobFlowSensor 2021-05-10T18:12:30.407501+00:00 2021-05-10T18:21:33.091312+00:00 0:09:02.683811 26638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T18:12:28.105291+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T17:00:00+00:00 EmrJobFlowSensor 2021-05-10T18:12:18.346635+00:00 2021-05-10T18:22:21.207274+00:00 0:10:02.860639 26637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T18:12:16.098695+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T18:12:10.410539+00:00 2021-05-10T18:12:12.219837+00:00 0:00:01.809298 26636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T18:12:08.088590+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T18:11:56.651319+00:00 2021-05-10T18:11:58.370829+00:00 0:00:01.719510 26635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T18:11:54.059273+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T17:00:00+00:00 PythonOperator 2021-05-10T18:11:48.095642+00:00 2021-05-10T18:11:51.179792+00:00 0:00:03.084150 26634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T18:11:46.020461+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T17:00:00+00:00 PythonOperator 2021-05-10T18:11:34.262994+00:00 2021-05-10T18:11:37.715218+00:00 0:00:03.452224 26633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T18:11:32.011287+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T17:00:00+00:00 TriggerDagRunOperator 2021-05-10T18:11:28.399694+00:00 2021-05-10T18:11:28.917600+00:00 0:00:00.517906 26632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T18:11:26.004118+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T17:00:00+00:00 TriggerDagRunOperator 2021-05-10T18:11:28.228802+00:00 2021-05-10T18:11:28.632407+00:00 0:00:00.403605 26631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T18:11:26.004087+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T17:05:00+00:00 EmrJobFlowSensor 2021-05-10T18:06:07.739412+00:00 2021-05-10T18:14:10.317046+00:00 0:08:02.577634 26630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T18:06:05.562893+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T18:05:45.646598+00:00 2021-05-10T18:05:47.268370+00:00 0:00:01.621772 26629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T18:05:43.484641+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T17:05:00+00:00 PythonOperator 2021-05-10T18:05:21.715979+00:00 2021-05-10T18:05:24.790632+00:00 0:00:03.074653 26628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T18:05:19.459353+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T17:00:00+00:00 EmrJobFlowSensor 2021-05-10T18:01:07.677654+00:00 2021-05-10T18:11:10.635419+00:00 0:10:02.957765 26626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T18:01:05.469377+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T18:00:41.630143+00:00 2021-05-10T18:00:43.436543+00:00 0:00:01.806400 26625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T18:00:39.448509+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T17:00:00+00:00 PythonOperator 2021-05-10T18:00:19.803620+00:00 2021-05-10T18:00:23.019777+00:00 0:00:03.216157 26624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T18:00:17.430238+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T16:00:00+00:00 EmrJobFlowSensor 2021-05-10T17:11:06.895156+00:00 2021-05-10T17:21:09.670262+00:00 0:10:02.775106 26623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T17:11:04.645287+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T16:00:00+00:00 EmrJobFlowSensor 2021-05-10T17:11:05.123951+00:00 2021-05-10T17:21:08.027421+00:00 0:10:02.903470 26622 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T17:11:02.663818+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T17:10:45.215124+00:00 2021-05-10T17:10:47.032158+00:00 0:00:01.817034 26621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T17:10:42.674075+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T17:10:42.782020+00:00 2021-05-10T17:10:44.496852+00:00 0:00:01.714832 26620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T17:10:40.615311+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T16:00:00+00:00 PythonOperator 2021-05-10T17:10:25.149101+00:00 2021-05-10T17:10:28.259963+00:00 0:00:03.110862 26619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T17:10:22.602114+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T16:00:00+00:00 PythonOperator 2021-05-10T17:10:22.931679+00:00 2021-05-10T17:10:26.552638+00:00 0:00:03.620959 26618 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T17:10:20.596690+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T16:00:00+00:00 TriggerDagRunOperator 2021-05-10T17:10:10.860845+00:00 2021-05-10T17:10:11.395288+00:00 0:00:00.534443 26617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T17:10:08.589565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T16:00:00+00:00 TriggerDagRunOperator 2021-05-10T17:10:10.787124+00:00 2021-05-10T17:10:11.202028+00:00 0:00:00.414904 26616 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T17:10:08.589539+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T16:05:00+00:00 EmrJobFlowSensor 2021-05-10T17:06:06.567618+00:00 2021-05-10T17:15:09.192736+00:00 0:09:02.625118 26615 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T17:06:04.277474+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T17:05:44.630460+00:00 2021-05-10T17:05:46.340888+00:00 0:00:01.710428 26614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T17:05:42.278917+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T16:05:00+00:00 PythonOperator 2021-05-10T17:05:22.618556+00:00 2021-05-10T17:05:25.639587+00:00 0:00:03.021031 26613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T17:05:20.205205+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T16:00:00+00:00 EmrJobFlowSensor 2021-05-10T17:00:56.056562+00:00 2021-05-10T17:09:58.809684+00:00 0:09:02.753122 26611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T17:00:53.579757+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T17:00:35.705955+00:00 2021-05-10T17:00:37.432747+00:00 0:00:01.726792 26610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T17:00:33.520528+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T16:00:00+00:00 PythonOperator 2021-05-10T17:00:13.680992+00:00 2021-05-10T17:00:16.925015+00:00 0:00:03.244023 26609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T17:00:11.498391+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T15:00:00+00:00 EmrJobFlowSensor 2021-05-10T16:12:05.907223+00:00 2021-05-10T16:21:08.852309+00:00 0:09:02.945086 26608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T16:12:03.634019+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T15:00:00+00:00 EmrJobFlowSensor 2021-05-10T16:11:57.763245+00:00 2021-05-10T16:22:00.549803+00:00 0:10:02.786558 26607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T16:11:55.630242+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T16:11:43.838147+00:00 2021-05-10T16:11:45.583213+00:00 0:00:01.745066 26606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T16:11:41.621915+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T16:11:35.998313+00:00 2021-05-10T16:11:37.807447+00:00 0:00:01.809134 26605 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T16:11:33.610762+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T15:00:00+00:00 PythonOperator 2021-05-10T16:11:22.133235+00:00 2021-05-10T16:11:25.198982+00:00 0:00:03.065747 26604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T16:11:19.596546+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T15:00:00+00:00 PythonOperator 2021-05-10T16:11:14.275265+00:00 2021-05-10T16:11:17.570532+00:00 0:00:03.295267 26603 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T16:11:11.662847+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T15:00:00+00:00 TriggerDagRunOperator 2021-05-10T16:11:08.076844+00:00 2021-05-10T16:11:08.635600+00:00 0:00:00.558756 26602 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T16:11:05.659238+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T15:00:00+00:00 TriggerDagRunOperator 2021-05-10T16:11:07.867326+00:00 2021-05-10T16:11:08.315090+00:00 0:00:00.447764 26601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T16:11:05.659187+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T15:05:00+00:00 EmrJobFlowSensor 2021-05-10T16:06:07.585108+00:00 2021-05-10T16:15:10.285870+00:00 0:09:02.700762 26600 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T16:06:05.167752+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T16:05:45.268720+00:00 2021-05-10T16:05:46.895539+00:00 0:00:01.626819 26599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T16:05:43.103916+00:00 2 default_pool