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-history-job_v002 check_cluster_status 2021-04-28T07:00:00+00:00 EmrJobFlowSensor 2021-04-28T08:11:21.821195+00:00 2021-04-28T08:21:24.603280+00:00 0:10:02.782085 22135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T08:11:19.599191+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T08:11:11.889849+00:00 2021-04-28T08:11:13.660385+00:00 0:00:01.770536 22134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T08:11:09.591129+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T08:11:00.108026+00:00 2021-04-28T08:11:01.794049+00:00 0:00:01.686023 22133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T08:10:57.561069+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T07:00:00+00:00 PythonOperator 2021-04-28T08:10:49.801567+00:00 2021-04-28T08:10:53.086889+00:00 0:00:03.285322 22132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T08:10:47.443138+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T07:00:00+00:00 PythonOperator 2021-04-28T08:10:40.085211+00:00 2021-04-28T08:10:43.113893+00:00 0:00:03.028682 22131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T08:10:37.546479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T07:00:00+00:00 TriggerDagRunOperator 2021-04-28T08:10:33.949428+00:00 2021-04-28T08:10:34.506853+00:00 0:00:00.557425 22130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T08:10:31.481141+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T07:00:00+00:00 TriggerDagRunOperator 2021-04-28T08:10:33.928335+00:00 2021-04-28T08:10:34.404895+00:00 0:00:00.476560 22129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T08:10:31.481107+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T07:05:00+00:00 EmrJobFlowSensor 2021-04-28T08:05:56.952213+00:00 2021-04-28T08:14:59.597642+00:00 0:09:02.645429 22128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T08:05:54.809478+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T08:05:35.207784+00:00 2021-04-28T08:05:36.984895+00:00 0:00:01.777111 22127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T08:05:32.786607+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T07:05:00+00:00 PythonOperator 2021-04-28T08:05:10.880976+00:00 2021-04-28T08:05:13.856895+00:00 0:00:02.975919 22126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T08:05:08.726465+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T07:00:00+00:00 EmrJobFlowSensor 2021-04-28T08:01:06.593184+00:00 2021-04-28T08:10:09.423368+00:00 0:09:02.830184 22125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T08:01:04.246528+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T08:00:44.620082+00:00 2021-04-28T08:00:46.346131+00:00 0:00:01.726049 22124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T08:00:42.280573+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T07:00:00+00:00 PythonOperator 2021-04-28T08:00:25.208881+00:00 2021-04-28T08:00:28.176293+00:00 0:00:02.967412 22123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T08:00:22.263727+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T06:00:00+00:00 EmrJobFlowSensor 2021-04-28T07:12:39.735751+00:00 2021-04-28T07:22:42.405957+00:00 0:10:02.670206 22121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T07:12:37.562484+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T06:00:00+00:00 EmrJobFlowSensor 2021-04-28T07:12:37.857824+00:00 2021-04-28T07:22:40.733205+00:00 0:10:02.875381 22120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T07:12:35.563485+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T07:12:18.346144+00:00 2021-04-28T07:12:20.155167+00:00 0:00:01.809023 22119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T07:12:15.574320+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T07:12:16.117641+00:00 2021-04-28T07:12:18.118423+00:00 0:00:02.000782 22118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T07:12:13.567594+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T06:00:00+00:00 PythonOperator 2021-04-28T07:11:55.879906+00:00 2021-04-28T07:11:59.111960+00:00 0:00:03.232054 22117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T07:11:53.555704+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T06:00:00+00:00 PythonOperator 2021-04-28T07:11:54.126029+00:00 2021-04-28T07:11:57.125305+00:00 0:00:02.999276 22116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T07:11:51.543786+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T06:00:00+00:00 TriggerDagRunOperator 2021-04-28T07:11:33.794375+00:00 2021-04-28T07:11:34.331457+00:00 0:00:00.537082 22115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T07:11:31.471436+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T06:00:00+00:00 TriggerDagRunOperator 2021-04-28T07:11:33.736169+00:00 2021-04-28T07:11:34.230664+00:00 0:00:00.494495 22114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T07:11:31.471406+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T06:05:00+00:00 EmrJobFlowSensor 2021-04-28T07:05:49.401353+00:00 2021-04-28T07:14:52.000101+00:00 0:09:02.598748 22113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T07:05:46.984554+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T07:05:26.910696+00:00 2021-04-28T07:05:28.512845+00:00 0:00:01.602149 22112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T07:05:24.803258+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T06:05:00+00:00 PythonOperator 2021-04-28T07:05:06.986107+00:00 2021-04-28T07:05:10.018893+00:00 0:00:03.032786 22111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T07:05:04.791107+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T06:00:00+00:00 EmrJobFlowSensor 2021-04-28T07:01:08.755812+00:00 2021-04-28T07:11:11.554386+00:00 0:10:02.798574 22110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T07:01:06.261422+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T07:00:44.855186+00:00 2021-04-28T07:00:46.688950+00:00 0:00:01.833764 22109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T07:00:42.244726+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T06:00:00+00:00 PythonOperator 2021-04-28T07:00:23.107873+00:00 2021-04-28T07:00:26.219222+00:00 0:00:03.111349 22108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T07:00:20.276379+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T05:00:00+00:00 EmrJobFlowSensor 2021-04-28T06:12:10.634222+00:00 2021-04-28T06:22:13.475993+00:00 0:10:02.841771 22106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T06:12:08.214262+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T05:00:00+00:00 EmrJobFlowSensor 2021-04-28T06:11:58.597190+00:00 2021-04-28T06:21:01.169463+00:00 0:09:02.572273 22105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T06:11:56.207883+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T06:11:48.725510+00:00 2021-04-28T06:11:50.512489+00:00 0:00:01.786979 22104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T06:11:46.201743+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T06:11:38.379246+00:00 2021-04-28T06:11:40.066772+00:00 0:00:01.687526 22103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T06:11:36.189068+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T05:00:00+00:00 PythonOperator 2021-04-28T06:11:28.331000+00:00 2021-04-28T06:11:31.640933+00:00 0:00:03.309933 22102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T06:11:26.114752+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T05:00:00+00:00 PythonOperator 2021-04-28T06:11:16.273273+00:00 2021-04-28T06:11:19.275917+00:00 0:00:03.002644 22101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T06:11:14.104295+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T05:00:00+00:00 TriggerDagRunOperator 2021-04-28T06:11:12.437918+00:00 2021-04-28T06:11:12.865886+00:00 0:00:00.427968 22100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T06:11:10.104589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T05:00:00+00:00 TriggerDagRunOperator 2021-04-28T06:11:12.413879+00:00 2021-04-28T06:11:12.999395+00:00 0:00:00.585516 22099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T06:11:10.104557+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T05:05:00+00:00 EmrJobFlowSensor 2021-04-28T06:05:49.751239+00:00 2021-04-28T06:14:52.321387+00:00 0:09:02.570148 22098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T06:05:47.503171+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T06:05:29.766015+00:00 2021-04-28T06:05:31.438307+00:00 0:00:01.672292 22097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T06:05:27.484469+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T05:05:00+00:00 PythonOperator 2021-04-28T06:05:08.091424+00:00 2021-04-28T06:05:11.093534+00:00 0:00:03.002110 22096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T06:05:05.470584+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T05:00:00+00:00 EmrJobFlowSensor 2021-04-28T06:00:51.073389+00:00 2021-04-28T06:10:53.798664+00:00 0:10:02.725275 22095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T06:00:48.903255+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T06:00:31.141104+00:00 2021-04-28T06:00:32.921866+00:00 0:00:01.780762 22094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T06:00:28.885473+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T05:00:00+00:00 PythonOperator 2021-04-28T06:00:09.191033+00:00 2021-04-28T06:00:12.230419+00:00 0:00:03.039386 22093 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T06:00:06.827796+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T04:00:00+00:00 EmrJobFlowSensor 2021-04-28T05:13:24.981079+00:00 2021-04-28T05:22:27.502880+00:00 0:09:02.521801 22091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T05:13:22.745945+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T04:00:00+00:00 EmrJobFlowSensor 2021-04-28T05:12:22.981893+00:00 2021-04-28T05:21:25.737651+00:00 0:09:02.755758 22090 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T05:12:20.692246+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T05:12:06.961728+00:00 2021-04-28T05:12:08.719134+00:00 0:00:01.757406 22089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T05:12:04.742481+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T05:12:02.941993+00:00 2021-04-28T05:12:04.761500+00:00 0:00:01.819507 22088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T05:12:00.672848+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T04:00:00+00:00 PythonOperator 2021-04-28T05:11:46.989299+00:00 2021-04-28T05:11:50.340558+00:00 0:00:03.351259 22087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T05:11:44.659146+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T04:00:00+00:00 PythonOperator 2021-04-28T05:11:41.008803+00:00 2021-04-28T05:11:44.075590+00:00 0:00:03.066787 22086 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T05:11:38.656153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T04:00:00+00:00 TriggerDagRunOperator 2021-04-28T05:11:20.957838+00:00 2021-04-28T05:11:21.470389+00:00 0:00:00.512551 22085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T05:11:18.585830+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T04:00:00+00:00 TriggerDagRunOperator 2021-04-28T05:11:20.823771+00:00 2021-04-28T05:11:21.242431+00:00 0:00:00.418660 22084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T05:11:18.585863+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T04:05:00+00:00 EmrJobFlowSensor 2021-04-28T05:06:08.544108+00:00 2021-04-28T05:15:11.142713+00:00 0:09:02.598605 22083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T05:06:06.089583+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T05:05:46.205060+00:00 2021-04-28T05:05:47.868761+00:00 0:00:01.663701 22082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T05:05:44.055599+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T04:05:00+00:00 PythonOperator 2021-04-28T05:05:24.043407+00:00 2021-04-28T05:05:27.046529+00:00 0:00:03.003122 22081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T05:05:21.956479+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T04:00:00+00:00 EmrJobFlowSensor 2021-04-28T05:01:00.364612+00:00 2021-04-28T05:11:03.300559+00:00 0:10:02.935947 22080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T05:00:57.652700+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T05:00:38.061692+00:00 2021-04-28T05:00:39.766238+00:00 0:00:01.704546 22079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T05:00:35.652241+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T04:00:00+00:00 PythonOperator 2021-04-28T05:00:17.925890+00:00 2021-04-28T05:00:20.895831+00:00 0:00:02.969941 22078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T05:00:15.569881+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T03:00:00+00:00 EmrJobFlowSensor 2021-04-28T04:11:14.419436+00:00 2021-04-28T04:19:16.915318+00:00 0:08:02.495882 22076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T04:11:11.986677+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T03:00:00+00:00 EmrJobFlowSensor 2021-04-28T04:11:10.379174+00:00 2021-04-28T04:20:13.131118+00:00 0:09:02.751944 22075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T04:11:07.984047+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T04:10:52.095306+00:00 2021-04-28T04:10:53.833083+00:00 0:00:01.737777 22074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T04:10:49.959915+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T04:10:48.196794+00:00 2021-04-28T04:10:49.935992+00:00 0:00:01.739198 22073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T04:10:45.956389+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T03:00:00+00:00 PythonOperator 2021-04-28T04:10:30.747501+00:00 2021-04-28T04:10:34.040805+00:00 0:00:03.293304 22072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T04:10:27.946161+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T03:00:00+00:00 PythonOperator 2021-04-28T04:10:26.236053+00:00 2021-04-28T04:10:29.828060+00:00 0:00:03.592007 22071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T04:10:23.933369+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T03:00:00+00:00 TriggerDagRunOperator 2021-04-28T04:10:14.448487+00:00 2021-04-28T04:10:14.879254+00:00 0:00:00.430767 22070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T04:10:11.922237+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T03:00:00+00:00 TriggerDagRunOperator 2021-04-28T04:10:14.229285+00:00 2021-04-28T04:10:14.827979+00:00 0:00:00.598694 22069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T04:10:11.922269+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T03:05:00+00:00 EmrJobFlowSensor 2021-04-28T04:05:53.857460+00:00 2021-04-28T04:15:56.484581+00:00 0:10:02.627121 22068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T04:05:51.654394+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T04:05:33.909233+00:00 2021-04-28T04:05:35.663613+00:00 0:00:01.754380 22067 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T04:05:31.573859+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T03:05:00+00:00 PythonOperator 2021-04-28T04:05:11.703595+00:00 2021-04-28T04:05:14.695933+00:00 0:00:02.992338 22066 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T04:05:09.516176+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T03:00:00+00:00 EmrJobFlowSensor 2021-04-28T04:01:03.026255+00:00 2021-04-28T04:10:05.608461+00:00 0:09:02.582206 22065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T04:01:00.853944+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T04:00:41.239213+00:00 2021-04-28T04:00:42.955146+00:00 0:00:01.715933 22064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T04:00:38.815066+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T03:00:00+00:00 PythonOperator 2021-04-28T04:00:19.693468+00:00 2021-04-28T04:00:22.690842+00:00 0:00:02.997374 22063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T04:00:16.851003+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T02:00:00+00:00 EmrJobFlowSensor 2021-04-28T03:12:16.013735+00:00 2021-04-28T03:21:18.671772+00:00 0:09:02.658037 22061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T03:12:13.565876+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T02:00:00+00:00 EmrJobFlowSensor 2021-04-28T03:12:07.910148+00:00 2021-04-28T03:21:10.662859+00:00 0:09:02.752711 22060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T03:12:05.555722+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T03:11:53.831924+00:00 2021-04-28T03:11:55.659797+00:00 0:00:01.827873 22059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T03:11:51.432172+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T03:11:47.665834+00:00 2021-04-28T03:11:49.358908+00:00 0:00:01.693074 22058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T03:11:45.425093+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T02:00:00+00:00 PythonOperator 2021-04-28T03:11:33.698761+00:00 2021-04-28T03:11:36.952391+00:00 0:00:03.253630 22057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T03:11:31.413221+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T02:00:00+00:00 PythonOperator 2021-04-28T03:11:25.637567+00:00 2021-04-28T03:11:28.662756+00:00 0:00:03.025189 22056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T03:11:23.406105+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T02:00:00+00:00 TriggerDagRunOperator 2021-04-28T03:11:15.822441+00:00 2021-04-28T03:11:16.238728+00:00 0:00:00.416287 22055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T03:11:13.406499+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T02:00:00+00:00 TriggerDagRunOperator 2021-04-28T03:11:15.675147+00:00 2021-04-28T03:11:16.233534+00:00 0:00:00.558387 22054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T03:11:13.406449+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T02:05:00+00:00 EmrJobFlowSensor 2021-04-28T03:06:08.983061+00:00 2021-04-28T03:14:11.509564+00:00 0:08:02.526503 22053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T03:06:06.646263+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T03:05:44.772882+00:00 2021-04-28T03:05:46.450474+00:00 0:00:01.677592 22052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T03:05:42.600445+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T02:05:00+00:00 PythonOperator 2021-04-28T03:05:22.811067+00:00 2021-04-28T03:05:25.784539+00:00 0:00:02.973472 22051 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T03:05:20.528945+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T02:00:00+00:00 EmrJobFlowSensor 2021-04-28T03:01:06.410961+00:00 2021-04-28T03:11:09.293084+00:00 0:10:02.882123 22050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T03:01:04.187996+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T03:00:44.784626+00:00 2021-04-28T03:00:46.611183+00:00 0:00:01.826557 22049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T03:00:42.122088+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T02:00:00+00:00 PythonOperator 2021-04-28T03:00:22.497636+00:00 2021-04-28T03:00:25.505601+00:00 0:00:03.007965 22048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T03:00:20.103423+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T01:00:00+00:00 EmrJobFlowSensor 2021-04-28T02:11:27.544652+00:00 2021-04-28T02:19:29.951143+00:00 0:08:02.406491 22046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T02:11:25.071004+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T01:00:00+00:00 EmrJobFlowSensor 2021-04-28T02:11:21.104395+00:00 2021-04-28T02:23:24.250094+00:00 0:12:03.145699 22045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T02:11:18.989064+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T02:11:07.284960+00:00 2021-04-28T02:11:08.988201+00:00 0:00:01.703241 22044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T02:11:04.949938+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T02:11:01.242378+00:00 2021-04-28T02:11:03.113487+00:00 0:00:01.871109 22043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T02:10:58.893324+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T01:00:00+00:00 PythonOperator 2021-04-28T02:10:43.156581+00:00 2021-04-28T02:10:46.165562+00:00 0:00:03.008981 22042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T02:10:40.870687+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T01:00:00+00:00 PythonOperator 2021-04-28T02:10:27.665310+00:00 2021-04-28T02:10:30.915401+00:00 0:00:03.250091 22041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T02:10:24.860676+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T01:00:00+00:00 TriggerDagRunOperator 2021-04-28T02:10:19.206879+00:00 2021-04-28T02:10:19.690907+00:00 0:00:00.484028 22040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T02:10:16.853103+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T01:00:00+00:00 TriggerDagRunOperator 2021-04-28T02:10:19.177598+00:00 2021-04-28T02:10:19.757672+00:00 0:00:00.580074 22039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T02:10:16.853070+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T01:05:00+00:00 EmrJobFlowSensor 2021-04-28T02:06:02.498621+00:00 2021-04-28T02:14:05.005816+00:00 0:08:02.507195 22038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T02:06:00.323855+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T02:05:42.545565+00:00 2021-04-28T02:05:44.226250+00:00 0:00:01.680685 22037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T02:05:40.294427+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T01:05:00+00:00 PythonOperator 2021-04-28T02:05:20.695603+00:00 2021-04-28T02:05:23.685924+00:00 0:00:02.990321 22036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T02:05:18.264188+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T01:00:00+00:00 EmrJobFlowSensor 2021-04-28T02:01:04.148111+00:00 2021-04-28T02:10:06.799899+00:00 0:09:02.651788 22035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T02:01:01.902857+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T02:00:42.254761+00:00 2021-04-28T02:00:44.050260+00:00 0:00:01.795499 22034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T02:00:39.948226+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T01:00:00+00:00 PythonOperator 2021-04-28T02:00:22.783321+00:00 2021-04-28T02:00:25.780983+00:00 0:00:02.997662 22033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T02:00:19.829406+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T00:00:00+00:00 EmrJobFlowSensor 2021-04-28T01:10:09.343994+00:00 2021-04-28T01:18:11.901278+00:00 0:08:02.557284 22031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T01:10:06.776593+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T00:00:00+00:00 EmrJobFlowSensor 2021-04-28T01:10:09.229311+00:00 2021-04-28T01:20:12.095344+00:00 0:10:02.866033 22030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T01:10:06.776548+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T01:09:47.148728+00:00 2021-04-28T01:09:48.941290+00:00 0:00:01.792562 22029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T01:09:44.683727+00:00 2 default_pool