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 create_cluster_and_add_emr_steps 2021-04-11T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T00:11:48.513245+00:00 2021-04-12T00:11:50.495189+00:00 0:00:01.981944 16181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T00:11:46.323302+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T23:00:00+00:00 PythonOperator 2021-04-12T00:11:28.742185+00:00 2021-04-12T00:11:31.762427+00:00 0:00:03.020242 16180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T00:11:26.309370+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T23:00:00+00:00 PythonOperator 2021-04-12T00:11:26.747405+00:00 2021-04-12T00:11:29.479675+00:00 0:00:02.732270 16179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T00:11:24.364459+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T23:00:00+00:00 TriggerDagRunOperator 2021-04-12T00:11:08.911000+00:00 2021-04-12T00:11:09.429366+00:00 0:00:00.518366 16178 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T00:11:06.296617+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T23:00:00+00:00 TriggerDagRunOperator 2021-04-12T00:11:08.596519+00:00 2021-04-12T00:11:09.026696+00:00 0:00:00.430177 16177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T00:11:06.296565+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T23:05:00+00:00 EmrJobFlowSensor 2021-04-12T00:06:08.385186+00:00 2021-04-12T00:14:11.004238+00:00 0:08:02.619052 16176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T00:06:05.989709+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T00:05:30.593795+00:00 2021-04-12T00:05:32.358857+00:00 0:00:01.765062 16175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T00:05:28.058235+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T23:05:00+00:00 PythonOperator 2021-04-12T00:05:10.289740+00:00 2021-04-12T00:05:13.090308+00:00 0:00:02.800568 16174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T00:05:07.911812+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T23:00:00+00:00 EmrJobFlowSensor 2021-04-12T00:00:53.991107+00:00 2021-04-12T00:10:56.860582+00:00 0:10:02.869475 16173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T00:00:51.673586+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T00:00:28.055358+00:00 2021-04-12T00:00:29.884069+00:00 0:00:01.828711 16172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T00:00:25.645485+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T23:00:00+00:00 PythonOperator 2021-04-12T00:00:08.066161+00:00 2021-04-12T00:00:10.805244+00:00 0:00:02.739083 16171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T00:00:05.555081+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T22:00:00+00:00 EmrJobFlowSensor 2021-04-11T23:11:32.010268+00:00 2021-04-11T23:19:34.429254+00:00 0:08:02.418986 16169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T23:11:29.845225+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T22:00:00+00:00 EmrJobFlowSensor 2021-04-11T23:11:28.123613+00:00 2021-04-11T23:21:30.925006+00:00 0:10:02.801393 16168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T23:11:25.749987+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T23:11:10.347564+00:00 2021-04-11T23:11:12.042542+00:00 0:00:01.694978 16167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T23:11:07.735486+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T23:11:06.018659+00:00 2021-04-11T23:11:07.911955+00:00 0:00:01.893296 16166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T23:11:03.741382+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T22:00:00+00:00 PythonOperator 2021-04-11T23:10:40.016575+00:00 2021-04-11T23:10:43.035965+00:00 0:00:03.019390 16165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T23:10:37.711280+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T22:00:00+00:00 PythonOperator 2021-04-11T23:10:38.037605+00:00 2021-04-11T23:10:40.799351+00:00 0:00:02.761746 16164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T23:10:35.727649+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T22:00:00+00:00 TriggerDagRunOperator 2021-04-11T23:10:20.041515+00:00 2021-04-11T23:10:20.563403+00:00 0:00:00.521888 16163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T23:10:17.700812+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T22:00:00+00:00 TriggerDagRunOperator 2021-04-11T23:10:19.897942+00:00 2021-04-11T23:10:20.288932+00:00 0:00:00.390990 16162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T23:10:17.700778+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T22:05:00+00:00 EmrJobFlowSensor 2021-04-11T23:06:07.432396+00:00 2021-04-11T23:14:09.857173+00:00 0:08:02.424777 16161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T23:06:05.299364+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T23:05:45.651064+00:00 2021-04-11T23:05:47.382843+00:00 0:00:01.731779 16160 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T23:05:43.266108+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T22:05:00+00:00 PythonOperator 2021-04-11T23:05:23.396895+00:00 2021-04-11T23:05:26.263946+00:00 0:00:02.867051 16159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T23:05:21.249383+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T22:00:00+00:00 EmrJobFlowSensor 2021-04-11T23:00:55.053718+00:00 2021-04-11T23:09:57.785711+00:00 0:09:02.731993 16158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T23:00:52.702103+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T23:00:34.866605+00:00 2021-04-11T23:00:36.529579+00:00 0:00:01.662974 16157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T23:00:32.685004+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T22:00:00+00:00 PythonOperator 2021-04-11T23:00:13.015671+00:00 2021-04-11T23:00:15.779036+00:00 0:00:02.763365 16156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T23:00:10.607968+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T21:00:00+00:00 EmrJobFlowSensor 2021-04-11T22:14:21.678264+00:00 2021-04-11T22:24:24.491724+00:00 0:10:02.813460 16154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T22:14:19.503282+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T21:00:00+00:00 EmrJobFlowSensor 2021-04-11T22:14:15.878743+00:00 2021-04-11T22:23:18.726129+00:00 0:09:02.847386 16153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T22:14:13.556423+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T22:14:02.102112+00:00 2021-04-11T22:14:03.833499+00:00 0:00:01.731387 16152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T22:13:59.566457+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T22:13:55.822956+00:00 2021-04-11T22:13:57.609582+00:00 0:00:01.786626 16151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T22:13:53.437394+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T21:00:00+00:00 PythonOperator 2021-04-11T22:13:40.604694+00:00 2021-04-11T22:13:43.681403+00:00 0:00:03.076709 16150 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T22:13:37.424507+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T21:00:00+00:00 PythonOperator 2021-04-11T22:13:34.155182+00:00 2021-04-11T22:13:36.976033+00:00 0:00:02.820851 16149 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T22:13:31.418003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T21:00:00+00:00 TriggerDagRunOperator 2021-04-11T22:13:20.006324+00:00 2021-04-11T22:13:20.547549+00:00 0:00:00.541225 16148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T22:13:17.411443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T21:00:00+00:00 TriggerDagRunOperator 2021-04-11T22:13:19.688707+00:00 2021-04-11T22:13:20.122509+00:00 0:00:00.433802 16147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T22:13:17.411478+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T21:05:00+00:00 EmrJobFlowSensor 2021-04-11T22:05:54.872931+00:00 2021-04-11T22:13:57.939090+00:00 0:08:03.066159 16146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T22:05:52.602766+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T22:05:32.959350+00:00 2021-04-11T22:05:34.598751+00:00 0:00:01.639401 16145 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T22:05:30.654589+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T21:05:00+00:00 PythonOperator 2021-04-11T22:05:10.684824+00:00 2021-04-11T22:05:13.479416+00:00 0:00:02.794592 16144 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T22:05:08.522888+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T21:00:00+00:00 EmrJobFlowSensor 2021-04-11T22:00:54.501629+00:00 2021-04-11T22:12:57.593157+00:00 0:12:03.091528 16143 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T22:00:52.204707+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T22:00:34.511301+00:00 2021-04-11T22:00:36.232996+00:00 0:00:01.721695 16142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T22:00:32.184584+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T21:00:00+00:00 PythonOperator 2021-04-11T22:00:12.862849+00:00 2021-04-11T22:00:15.577912+00:00 0:00:02.715063 16141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T22:00:10.129879+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T20:00:00+00:00 EmrJobFlowSensor 2021-04-11T21:11:07.768395+00:00 2021-04-11T21:21:10.742377+00:00 0:10:02.973982 16139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T21:11:05.503787+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T20:00:00+00:00 EmrJobFlowSensor 2021-04-11T21:11:03.686580+00:00 2021-04-11T21:19:06.112076+00:00 0:08:02.425496 16138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T21:11:01.494288+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T21:10:45.801622+00:00 2021-04-11T21:10:47.505637+00:00 0:00:01.704015 16137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T21:10:43.434067+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T21:10:41.875226+00:00 2021-04-11T21:10:43.531997+00:00 0:00:01.656771 16136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T21:10:39.432920+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T20:00:00+00:00 PythonOperator 2021-04-11T21:10:26.007129+00:00 2021-04-11T21:10:29.026895+00:00 0:00:03.019766 16135 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T21:10:23.419768+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T20:00:00+00:00 PythonOperator 2021-04-11T21:10:19.747312+00:00 2021-04-11T21:10:22.709083+00:00 0:00:02.961771 16134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T21:10:17.414404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T20:00:00+00:00 TriggerDagRunOperator 2021-04-11T21:10:13.750977+00:00 2021-04-11T21:10:14.284342+00:00 0:00:00.533365 16133 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T21:10:11.409374+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T20:00:00+00:00 TriggerDagRunOperator 2021-04-11T21:10:13.601023+00:00 2021-04-11T21:10:14.088824+00:00 0:00:00.487801 16132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T21:10:11.409408+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T20:05:00+00:00 EmrJobFlowSensor 2021-04-11T21:06:01.266960+00:00 2021-04-11T21:14:03.825021+00:00 0:08:02.558061 16131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T21:05:59.053295+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T21:05:39.048350+00:00 2021-04-11T21:05:40.663130+00:00 0:00:01.614780 16130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T21:05:36.895097+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T20:05:00+00:00 PythonOperator 2021-04-11T21:05:16.975035+00:00 2021-04-11T21:05:19.617443+00:00 0:00:02.642408 16129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T21:05:14.876170+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T20:00:00+00:00 EmrJobFlowSensor 2021-04-11T21:00:54.543635+00:00 2021-04-11T21:09:57.070813+00:00 0:09:02.527178 16128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T21:00:52.307521+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T21:00:32.758167+00:00 2021-04-11T21:00:34.496809+00:00 0:00:01.738642 16127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T21:00:30.353179+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T20:00:00+00:00 PythonOperator 2021-04-11T21:00:10.629200+00:00 2021-04-11T21:00:13.329692+00:00 0:00:02.700492 16126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T21:00:08.260221+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T19:00:00+00:00 EmrJobFlowSensor 2021-04-11T20:12:12.989239+00:00 2021-04-11T20:21:15.607325+00:00 0:09:02.618086 16124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T20:12:10.746220+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T19:00:00+00:00 EmrJobFlowSensor 2021-04-11T20:11:59.228415+00:00 2021-04-11T20:22:02.103501+00:00 0:10:02.875086 16123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T20:11:56.680095+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T20:11:50.918487+00:00 2021-04-11T20:11:52.715252+00:00 0:00:01.796765 16122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T20:11:48.642220+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T20:11:39.144305+00:00 2021-04-11T20:11:40.839126+00:00 0:00:01.694821 16121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T20:11:36.757672+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T19:00:00+00:00 PythonOperator 2021-04-11T20:11:30.916665+00:00 2021-04-11T20:11:33.747213+00:00 0:00:02.830548 16120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T20:11:28.661401+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T19:00:00+00:00 PythonOperator 2021-04-11T20:11:17.147286+00:00 2021-04-11T20:11:20.478213+00:00 0:00:03.330927 16119 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T20:11:14.595764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T19:00:00+00:00 TriggerDagRunOperator 2021-04-11T20:11:04.908861+00:00 2021-04-11T20:11:05.411113+00:00 0:00:00.502252 16118 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T20:11:02.588863+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T19:00:00+00:00 TriggerDagRunOperator 2021-04-11T20:11:04.732599+00:00 2021-04-11T20:11:05.144058+00:00 0:00:00.411459 16117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T20:11:02.588896+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T19:05:00+00:00 EmrJobFlowSensor 2021-04-11T20:05:48.148358+00:00 2021-04-11T20:13:50.569278+00:00 0:08:02.420920 16116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T20:05:45.993600+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T20:05:26.320255+00:00 2021-04-11T20:05:27.951355+00:00 0:00:01.631100 16115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T20:05:23.969732+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T19:05:00+00:00 PythonOperator 2021-04-11T20:05:06.196505+00:00 2021-04-11T20:05:08.992697+00:00 0:00:02.796192 16114 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T20:05:03.944980+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T19:00:00+00:00 EmrJobFlowSensor 2021-04-11T20:00:49.867578+00:00 2021-04-11T20:10:52.770312+00:00 0:10:02.902734 16113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T20:00:47.606700+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T20:00:29.921124+00:00 2021-04-11T20:00:31.679724+00:00 0:00:01.758600 16112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T20:00:27.591950+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T19:00:00+00:00 PythonOperator 2021-04-11T20:00:08.189919+00:00 2021-04-11T20:00:10.899652+00:00 0:00:02.709733 16111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T20:00:05.564901+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T18:00:00+00:00 EmrJobFlowSensor 2021-04-11T19:21:10.621424+00:00 2021-04-11T19:31:13.293733+00:00 0:10:02.672309 16109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T19:21:07.848894+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T18:00:00+00:00 EmrJobFlowSensor 2021-04-11T19:21:07.997234+00:00 2021-04-11T19:31:11.151667+00:00 0:10:03.154433 16108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T19:21:05.777383+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T19:20:50.509541+00:00 2021-04-11T19:20:52.345793+00:00 0:00:01.836252 16107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T19:20:47.762232+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T19:20:48.236815+00:00 2021-04-11T19:20:50.315830+00:00 0:00:02.079015 16106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T19:20:45.766791+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T18:00:00+00:00 PythonOperator 2021-04-11T19:20:29.167957+00:00 2021-04-11T19:20:31.879669+00:00 0:00:02.711712 16105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T19:20:25.675162+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T18:00:00+00:00 PythonOperator 2021-04-11T19:20:26.802007+00:00 2021-04-11T19:20:30.291157+00:00 0:00:03.489150 16104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T19:20:23.665987+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T18:00:00+00:00 TriggerDagRunOperator 2021-04-11T19:20:20.011255+00:00 2021-04-11T19:20:20.526970+00:00 0:00:00.515715 16103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T19:20:17.589573+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T18:00:00+00:00 TriggerDagRunOperator 2021-04-11T19:20:19.851491+00:00 2021-04-11T19:20:20.261430+00:00 0:00:00.409939 16102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T19:20:17.589601+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T18:05:00+00:00 EmrJobFlowSensor 2021-04-11T19:05:54.716981+00:00 2021-04-11T19:13:57.207908+00:00 0:08:02.490927 16101 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T19:05:52.271829+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T19:05:34.486626+00:00 2021-04-11T19:05:36.216128+00:00 0:00:01.729502 16100 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T19:05:32.187360+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T18:05:00+00:00 PythonOperator 2021-04-11T19:05:12.263273+00:00 2021-04-11T19:05:15.702044+00:00 0:00:03.438771 16099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T19:05:10.137111+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T18:00:00+00:00 EmrJobFlowSensor 2021-04-11T19:01:06.084310+00:00 2021-04-11T19:20:10.052611+00:00 0:19:03.968301 16098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T19:01:03.840873+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T19:00:45.881780+00:00 2021-04-11T19:00:47.543931+00:00 0:00:01.662151 16097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T19:00:43.713828+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T18:00:00+00:00 PythonOperator 2021-04-11T19:00:24.620193+00:00 2021-04-11T19:00:27.563136+00:00 0:00:02.942943 16096 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T19:00:21.751293+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T17:00:00+00:00 EmrJobFlowSensor 2021-04-11T18:10:35.460924+00:00 2021-04-11T18:19:38.082373+00:00 0:09:02.621449 16094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T18:10:33.266474+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T17:00:00+00:00 EmrJobFlowSensor 2021-04-11T18:10:33.671731+00:00 2021-04-11T18:20:36.402042+00:00 0:10:02.730311 16093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T18:10:31.349679+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T18:10:15.649625+00:00 2021-04-11T18:10:17.461137+00:00 0:00:01.811512 16092 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T18:10:13.195416+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T18:10:11.502222+00:00 2021-04-11T18:10:13.207559+00:00 0:00:01.705337 16091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T18:10:09.273213+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T17:00:00+00:00 PythonOperator 2021-04-11T18:09:53.761661+00:00 2021-04-11T18:09:56.556734+00:00 0:00:02.795073 16090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T18:09:51.146176+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T17:00:00+00:00 PythonOperator 2021-04-11T18:09:51.338639+00:00 2021-04-11T18:09:54.652475+00:00 0:00:03.313836 16089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T18:09:49.153272+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T17:00:00+00:00 TriggerDagRunOperator 2021-04-11T18:09:35.691585+00:00 2021-04-11T18:09:36.207051+00:00 0:00:00.515466 16088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T18:09:33.169341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T17:00:00+00:00 TriggerDagRunOperator 2021-04-11T18:09:35.558341+00:00 2021-04-11T18:09:35.957059+00:00 0:00:00.398718 16087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T18:09:33.169302+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T17:05:00+00:00 EmrJobFlowSensor 2021-04-11T18:05:47.186781+00:00 2021-04-11T18:14:49.853272+00:00 0:09:02.666491 16086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T18:05:44.852801+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T18:05:25.094070+00:00 2021-04-11T18:05:26.749780+00:00 0:00:01.655710 16085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T18:05:22.730594+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T17:05:00+00:00 PythonOperator 2021-04-11T18:05:04.851137+00:00 2021-04-11T18:05:07.516707+00:00 0:00:02.665570 16084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T18:05:02.712370+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T17:00:00+00:00 EmrJobFlowSensor 2021-04-11T18:01:20.666914+00:00 2021-04-11T18:09:23.275602+00:00 0:08:02.608688 16083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T18:01:18.417846+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T18:00:44.621916+00:00 2021-04-11T18:00:46.297419+00:00 0:00:01.675503 16082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T18:00:42.410706+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T17:00:00+00:00 PythonOperator 2021-04-11T18:00:25.109351+00:00 2021-04-11T18:00:28.033426+00:00 0:00:02.924075 16081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T18:00:22.344073+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T16:00:00+00:00 EmrJobFlowSensor 2021-04-11T17:11:24.662666+00:00 2021-04-11T17:21:27.516388+00:00 0:10:02.853722 16079 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T17:11:22.175141+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T16:00:00+00:00 EmrJobFlowSensor 2021-04-11T17:11:12.856374+00:00 2021-04-11T17:20:16.243600+00:00 0:09:03.387226 16078 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T17:11:10.109870+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T17:11:02.523041+00:00 2021-04-11T17:11:04.337095+00:00 0:00:01.814054 16077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T17:11:00.160590+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T17:10:50.336002+00:00 2021-04-11T17:10:52.016473+00:00 0:00:01.680471 16076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T17:10:48.083414+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T16:00:00+00:00 PythonOperator 2021-04-11T17:10:40.295228+00:00 2021-04-11T17:10:43.358963+00:00 0:00:03.063735 16075 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T17:10:38.037098+00:00 2 default_pool