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-05-30T04:00:00+00:00 TriggerDagRunOperator 2021-05-30T05:09:24.165090+00:00 2021-05-30T05:09:24.707268+00:00 0:00:00.542178 34129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T05:09:21.733929+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-30T04:00:00+00:00 TriggerDagRunOperator 2021-05-30T05:09:24.017211+00:00 2021-05-30T05:09:24.447849+00:00 0:00:00.430638 34128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T05:09:21.733893+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-30T04:05:00+00:00 EmrJobFlowSensor 2021-05-30T05:05:55.445106+00:00 2021-05-30T05:14:58.005250+00:00 0:09:02.560144 34127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T05:05:53.302231+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-30T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-30T05:05:35.423117+00:00 2021-05-30T05:05:37.036433+00:00 0:00:01.613316 34126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T05:05:33.286860+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-30T04:05:00+00:00 PythonOperator 2021-05-30T05:05:11.464048+00:00 2021-05-30T05:05:14.677816+00:00 0:00:03.213768 34125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T05:05:09.264245+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-30T04:00:00+00:00 EmrJobFlowSensor 2021-05-30T05:01:07.201749+00:00 2021-05-30T05:09:09.761042+00:00 0:08:02.559293 34124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T05:01:04.952823+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-30T04:00:00+00:00 EmrJobFlowSensor 2021-05-30T05:01:03.115717+00:00 2021-05-30T05:10:05.740018+00:00 0:09:02.624301 34123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T05:01:00.885659+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-30T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T05:00:35.230279+00:00 2021-05-30T05:00:37.011719+00:00 0:00:01.781440 34122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-30T05:00:32.811847+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-30T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T05:00:27.226447+00:00 2021-05-30T05:00:28.912140+00:00 0:00:01.685693 34121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T05:00:24.801218+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-30T04:00:00+00:00 PythonOperator 2021-05-30T05:00:09.368451+00:00 2021-05-30T05:00:12.653548+00:00 0:00:03.285097 34120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-30T05:00:06.856338+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-30T04:00:00+00:00 PythonOperator 2021-05-30T05:00:05.716611+00:00 2021-05-30T05:00:08.937155+00:00 0:00:03.220544 34119 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T05:00:02.855708+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-30T03:00:00+00:00 EmrJobFlowSensor 2021-05-30T04:11:13.954274+00:00 2021-05-30T04:20:16.703639+00:00 0:09:02.749365 34117 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T04:11:11.450670+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-30T03:00:00+00:00 EmrJobFlowSensor 2021-05-30T04:11:03.611701+00:00 2021-05-30T04:20:06.197747+00:00 0:09:02.586046 34116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T04:11:01.436181+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-30T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T04:10:53.809786+00:00 2021-05-30T04:10:55.614353+00:00 0:00:01.804567 34115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T04:10:51.429254+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-30T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T04:10:41.619024+00:00 2021-05-30T04:10:43.420107+00:00 0:00:01.801083 34114 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T04:10:39.423968+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-30T03:00:00+00:00 PythonOperator 2021-05-30T04:10:31.698760+00:00 2021-05-30T04:10:35.209051+00:00 0:00:03.510291 34113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T04:10:29.418638+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-30T03:00:00+00:00 PythonOperator 2021-05-30T04:10:19.780543+00:00 2021-05-30T04:10:23.521461+00:00 0:00:03.740918 34112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T04:10:17.463324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-30T03:00:00+00:00 TriggerDagRunOperator 2021-05-30T04:10:15.893674+00:00 2021-05-30T04:10:16.458676+00:00 0:00:00.565002 34111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T04:10:13.397164+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-30T03:00:00+00:00 TriggerDagRunOperator 2021-05-30T04:10:15.602259+00:00 2021-05-30T04:10:16.001074+00:00 0:00:00.398815 34110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T04:10:13.397132+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-30T03:05:00+00:00 EmrJobFlowSensor 2021-05-30T04:05:51.448640+00:00 2021-05-30T04:14:54.060523+00:00 0:09:02.611883 34109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T04:05:49.148843+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-30T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-30T04:05:29.362366+00:00 2021-05-30T04:05:31.130510+00:00 0:00:01.768144 34108 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T04:05:27.048839+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-30T03:05:00+00:00 PythonOperator 2021-05-30T04:05:09.433410+00:00 2021-05-30T04:05:12.950358+00:00 0:00:03.516948 34107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T04:05:07.014967+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-30T03:00:00+00:00 EmrJobFlowSensor 2021-05-30T04:01:01.250214+00:00 2021-05-30T04:10:03.829200+00:00 0:09:02.578986 34106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T04:00:58.763826+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-30T03:00:00+00:00 EmrJobFlowSensor 2021-05-30T04:00:58.804406+00:00 2021-05-30T04:10:01.570891+00:00 0:09:02.766485 34105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T04:00:56.658078+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-30T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T04:00:39.125797+00:00 2021-05-30T04:00:40.971049+00:00 0:00:01.845252 34104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-30T04:00:36.648567+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-30T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T04:00:38.834908+00:00 2021-05-30T04:00:40.520548+00:00 0:00:01.685640 34103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T04:00:36.648597+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-30T03:00:00+00:00 PythonOperator 2021-05-30T04:00:17.606353+00:00 2021-05-30T04:00:20.827052+00:00 0:00:03.220699 34102 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T04:00:14.466494+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-30T03:00:00+00:00 PythonOperator 2021-05-30T04:00:17.337207+00:00 2021-05-30T04:00:20.605815+00:00 0:00:03.268608 34101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-30T04:00:14.466456+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-30T02:05:00+00:00 EmrJobFlowSensor 2021-05-30T03:13:21.185394+00:00 2021-05-30T03:14:22.844393+00:00 0:01:01.658999 34099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T03:13:18.967816+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-30T02:00:00+00:00 EmrJobFlowSensor 2021-05-30T03:11:29.437890+00:00 2021-05-30T03:20:32.059727+00:00 0:09:02.621837 34098 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T03:11:26.858485+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-30T02:00:00+00:00 EmrJobFlowSensor 2021-05-30T03:11:12.980729+00:00 2021-05-30T03:20:15.606703+00:00 0:09:02.625974 34097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T03:11:10.754991+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-30T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T03:11:09.113843+00:00 2021-05-30T03:11:10.942114+00:00 0:00:01.828271 34096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T03:11:06.749788+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-30T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T03:10:50.973444+00:00 2021-05-30T03:10:52.843372+00:00 0:00:01.869928 34095 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T03:10:48.721750+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-30T02:00:00+00:00 PythonOperator 2021-05-30T03:10:47.027899+00:00 2021-05-30T03:10:50.573708+00:00 0:00:03.545809 34094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T03:10:44.717795+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-30T02:00:00+00:00 PythonOperator 2021-05-30T03:10:29.445422+00:00 2021-05-30T03:10:32.640071+00:00 0:00:03.194649 34093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T03:10:26.773590+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-30T02:00:00+00:00 TriggerDagRunOperator 2021-05-30T03:10:23.051569+00:00 2021-05-30T03:10:23.571155+00:00 0:00:00.519586 34092 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T03:10:20.700645+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-30T02:00:00+00:00 TriggerDagRunOperator 2021-05-30T03:10:22.933957+00:00 2021-05-30T03:10:23.388507+00:00 0:00:00.454550 34091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T03:10:20.700677+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-30T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-30T03:05:26.292076+00:00 2021-05-30T03:05:28.012782+00:00 0:00:01.720706 34089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T03:05:24.131795+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-30T02:05:00+00:00 PythonOperator 2021-05-30T03:05:04.825311+00:00 2021-05-30T03:05:07.730904+00:00 0:00:02.905593 34088 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T03:05:02.167772+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-30T02:00:00+00:00 EmrJobFlowSensor 2021-05-30T03:00:57.758934+00:00 2021-05-30T03:10:00.390282+00:00 0:09:02.631348 34087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T03:00:55.557294+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-30T02:00:00+00:00 EmrJobFlowSensor 2021-05-30T03:00:49.904736+00:00 2021-05-30T03:09:52.662976+00:00 0:09:02.758240 34086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T03:00:47.550296+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-30T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T03:00:35.685094+00:00 2021-05-30T03:00:37.354359+00:00 0:00:01.669265 34085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-30T03:00:33.538464+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-30T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T03:00:30.213949+00:00 2021-05-30T03:00:32.038089+00:00 0:00:01.824140 34084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T03:00:27.566827+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-30T02:00:00+00:00 PythonOperator 2021-05-30T03:00:13.815993+00:00 2021-05-30T03:00:17.064320+00:00 0:00:03.248327 34083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-30T03:00:11.518371+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-30T02:00:00+00:00 PythonOperator 2021-05-30T03:00:08.252531+00:00 2021-05-30T03:00:11.555953+00:00 0:00:03.303422 34082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T03:00:05.550140+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-30T01:00:00+00:00 EmrJobFlowSensor 2021-05-30T02:11:19.786338+00:00 2021-05-30T02:20:22.338403+00:00 0:09:02.552065 34080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T02:11:17.628023+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-30T01:00:00+00:00 EmrJobFlowSensor 2021-05-30T02:11:13.812522+00:00 2021-05-30T02:20:16.482561+00:00 0:09:02.670039 34079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T02:11:11.647410+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-30T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T02:10:57.783856+00:00 2021-05-30T02:10:59.499747+00:00 0:00:01.715891 34078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T02:10:55.605479+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-30T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T02:10:51.714308+00:00 2021-05-30T02:10:53.361827+00:00 0:00:01.647519 34077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T02:10:49.599620+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-30T01:00:00+00:00 PythonOperator 2021-05-30T02:10:36.144129+00:00 2021-05-30T02:10:39.395166+00:00 0:00:03.251037 34076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T02:10:33.648530+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-30T01:00:00+00:00 PythonOperator 2021-05-30T02:10:30.256762+00:00 2021-05-30T02:10:33.779545+00:00 0:00:03.522783 34075 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T02:10:27.746937+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-30T01:00:00+00:00 TriggerDagRunOperator 2021-05-30T02:10:12.105497+00:00 2021-05-30T02:10:12.636304+00:00 0:00:00.530807 34074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T02:10:09.644292+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-30T01:00:00+00:00 TriggerDagRunOperator 2021-05-30T02:10:11.898109+00:00 2021-05-30T02:10:12.327421+00:00 0:00:00.429312 34073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T02:10:09.644240+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-30T01:05:00+00:00 EmrJobFlowSensor 2021-05-30T02:06:03.629036+00:00 2021-05-30T02:15:06.297583+00:00 0:09:02.668547 34072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T02:06:01.182207+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-30T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-30T02:05:43.306683+00:00 2021-05-30T02:05:44.939789+00:00 0:00:01.633106 34071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T02:05:41.120787+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-30T01:05:00+00:00 PythonOperator 2021-05-30T02:05:21.298192+00:00 2021-05-30T02:05:24.437072+00:00 0:00:03.138880 34070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T02:05:19.099329+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-30T01:00:00+00:00 EmrJobFlowSensor 2021-05-30T02:01:04.993614+00:00 2021-05-30T02:10:07.709868+00:00 0:09:02.716254 34069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T02:01:02.541319+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-30T01:00:00+00:00 EmrJobFlowSensor 2021-05-30T02:00:56.708659+00:00 2021-05-30T02:08:59.238818+00:00 0:08:02.530159 34068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T02:00:54.532861+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-30T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T02:00:44.936667+00:00 2021-05-30T02:00:46.692044+00:00 0:00:01.755377 34067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-30T02:00:42.525851+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-30T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T02:00:34.795857+00:00 2021-05-30T02:00:36.471492+00:00 0:00:01.675635 34066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T02:00:32.548048+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-30T01:00:00+00:00 PythonOperator 2021-05-30T02:00:23.123964+00:00 2021-05-30T02:00:26.362102+00:00 0:00:03.238138 34065 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-30T02:00:20.576137+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-30T01:00:00+00:00 PythonOperator 2021-05-30T02:00:12.958813+00:00 2021-05-30T02:00:16.256663+00:00 0:00:03.297850 34064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T02:00:10.491690+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-30T00:00:00+00:00 EmrJobFlowSensor 2021-05-30T01:11:21.329036+00:00 2021-05-30T01:20:24.032297+00:00 0:09:02.703261 34062 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T01:11:19.026247+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-30T00:00:00+00:00 EmrJobFlowSensor 2021-05-30T01:11:09.433915+00:00 2021-05-30T01:21:12.228905+00:00 0:10:02.794990 34061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T01:11:07.025790+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-30T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T01:10:53.430070+00:00 2021-05-30T01:10:55.116088+00:00 0:00:01.686018 34060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T01:10:51.067249+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-30T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T01:10:47.217553+00:00 2021-05-30T01:10:48.932466+00:00 0:00:01.714913 34059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T01:10:45.004902+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-30T00:00:00+00:00 PythonOperator 2021-05-30T01:10:31.511223+00:00 2021-05-30T01:10:35.058513+00:00 0:00:03.547290 34058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T01:10:29.066906+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-30T00:00:00+00:00 PythonOperator 2021-05-30T01:10:25.548294+00:00 2021-05-30T01:10:28.813753+00:00 0:00:03.265459 34057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T01:10:22.948650+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-30T00:00:00+00:00 TriggerDagRunOperator 2021-05-30T01:10:17.301282+00:00 2021-05-30T01:10:17.733796+00:00 0:00:00.432514 34056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T01:10:14.944017+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-30T00:00:00+00:00 TriggerDagRunOperator 2021-05-30T01:10:17.248772+00:00 2021-05-30T01:10:17.817371+00:00 0:00:00.568599 34055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T01:10:14.943987+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-30T00:05:00+00:00 EmrJobFlowSensor 2021-05-30T01:06:06.890559+00:00 2021-05-30T01:13:09.285787+00:00 0:07:02.395228 34054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T01:06:04.486490+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-30T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-30T01:05:36.608277+00:00 2021-05-30T01:05:38.346820+00:00 0:00:01.738543 34053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T01:05:34.415118+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-30T00:05:00+00:00 PythonOperator 2021-05-30T01:05:10.751147+00:00 2021-05-30T01:05:14.035037+00:00 0:00:03.283890 34052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T01:05:08.481476+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-30T00:00:00+00:00 EmrJobFlowSensor 2021-05-30T01:01:08.393169+00:00 2021-05-30T01:10:11.036412+00:00 0:09:02.643243 34051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T01:01:06.084269+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-30T00:00:00+00:00 EmrJobFlowSensor 2021-05-30T01:01:00.732202+00:00 2021-05-30T01:11:03.554773+00:00 0:10:02.822571 34050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T01:00:58.048700+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-30T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T01:00:46.556656+00:00 2021-05-30T01:00:48.259136+00:00 0:00:01.702480 34049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-30T01:00:44.071547+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-30T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T01:00:40.105146+00:00 2021-05-30T01:00:41.792495+00:00 0:00:01.687349 34048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T01:00:37.995031+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-30T00:00:00+00:00 PythonOperator 2021-05-30T01:00:24.526052+00:00 2021-05-30T01:00:27.786867+00:00 0:00:03.260815 34047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-30T01:00:21.986847+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-30T00:00:00+00:00 PythonOperator 2021-05-30T01:00:18.289603+00:00 2021-05-30T01:00:21.584981+00:00 0:00:03.295378 34046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T01:00:15.960976+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-29T23:00:00+00:00 EmrJobFlowSensor 2021-05-30T00:12:42.558993+00:00 2021-05-30T00:21:45.240062+00:00 0:09:02.681069 34044 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T00:12:40.191493+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-29T23:00:00+00:00 EmrJobFlowSensor 2021-05-30T00:12:30.720409+00:00 2021-05-30T00:21:33.435613+00:00 0:09:02.715204 34043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T00:12:28.259241+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-29T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T00:12:20.335653+00:00 2021-05-30T00:12:22.033783+00:00 0:00:01.698130 34042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T00:12:18.136716+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-29T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T00:12:10.495673+00:00 2021-05-30T00:12:12.186801+00:00 0:00:01.691128 34041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T00:12:08.145468+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-29T23:00:00+00:00 PythonOperator 2021-05-30T00:11:58.370025+00:00 2021-05-30T00:12:01.905764+00:00 0:00:03.535739 34040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T00:11:56.123934+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-29T23:00:00+00:00 PythonOperator 2021-05-30T00:11:48.423949+00:00 2021-05-30T00:11:51.675646+00:00 0:00:03.251697 34039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T00:11:46.173638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-29T23:00:00+00:00 TriggerDagRunOperator 2021-05-30T00:11:34.548614+00:00 2021-05-30T00:11:34.956101+00:00 0:00:00.407487 34038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T00:11:32.096489+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-29T23:00:00+00:00 TriggerDagRunOperator 2021-05-30T00:11:34.523002+00:00 2021-05-30T00:11:35.058642+00:00 0:00:00.535640 34037 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T00:11:32.096522+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-29T23:05:00+00:00 EmrJobFlowSensor 2021-05-30T00:05:54.112582+00:00 2021-05-30T00:14:56.660815+00:00 0:09:02.548233 34036 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T00:05:51.778825+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-29T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-30T00:05:33.994117+00:00 2021-05-30T00:05:35.698251+00:00 0:00:01.704134 34035 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T00:05:31.692892+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-29T23:05:00+00:00 PythonOperator 2021-05-30T00:05:11.663128+00:00 2021-05-30T00:05:14.885251+00:00 0:00:03.222123 34034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T00:05:09.609349+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-29T23:00:00+00:00 EmrJobFlowSensor 2021-05-30T00:01:07.335418+00:00 2021-05-30T00:10:10.064785+00:00 0:09:02.729367 34033 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-30T00:01:05.044294+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-29T23:00:00+00:00 EmrJobFlowSensor 2021-05-30T00:01:05.396047+00:00 2021-05-30T00:11:08.132735+00:00 0:10:02.736688 34032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T00:01:03.070774+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-29T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T00:00:45.381819+00:00 2021-05-30T00:00:47.177121+00:00 0:00:01.795302 34031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-30T00:00:43.018857+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-29T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-30T00:00:43.149288+00:00 2021-05-30T00:00:44.874632+00:00 0:00:01.725344 34030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-30T00:00:41.016661+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-29T23:00:00+00:00 PythonOperator 2021-05-30T00:00:25.334218+00:00 2021-05-30T00:00:28.740276+00:00 0:00:03.406058 34029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-30T00:00:23.004731+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-29T23:00:00+00:00 PythonOperator 2021-05-30T00:00:21.299125+00:00 2021-05-30T00:00:24.558639+00:00 0:00:03.259514 34028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-30T00:00:19.001573+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-29T22:00:00+00:00 EmrJobFlowSensor 2021-05-29T23:11:15.882786+00:00 2021-05-29T23:21:18.731173+00:00 0:10:02.848387 34026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-29T23:11:13.379656+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-29T22:00:00+00:00 EmrJobFlowSensor 2021-05-29T23:11:05.678808+00:00 2021-05-29T23:21:08.362651+00:00 0:10:02.683843 34025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-29T23:11:03.376229+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-29T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-29T23:10:54.018131+00:00 2021-05-29T23:10:55.813143+00:00 0:00:01.795012 34024 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-29T23:10:51.304233+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-29T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-29T23:10:41.540232+00:00 2021-05-29T23:10:43.267067+00:00 0:00:01.726835 34023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-29T23:10:39.346989+00:00 2 default_pool