Task Instances

Reset Filters
  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 create_emr_steps 2021-04-12T05:00:00+00:00 PythonOperator 2021-04-12T06:00:16.400456+00:00 2021-04-12T06:00:19.106973+00:00 0:00:02.706517 16260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T06:00:14.081162+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T04:00:00+00:00 TriggerDagRunOperator 2021-04-12T05:11:07.699189+00:00 2021-04-12T05:11:08.268647+00:00 0:00:00.569458 16253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T05:11:05.391475+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T04:00:00+00:00 TriggerDagRunOperator 2021-04-12T05:11:07.631499+00:00 2021-04-12T05:11:08.102382+00:00 0:00:00.470883 16252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T05:11:05.391444+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T04:00:00+00:00 EmrJobFlowSensor 2021-04-12T05:00:50.824929+00:00 2021-04-12T05:10:53.706300+00:00 0:10:02.881371 16247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T05:00:48.625904+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T05:00:31.286383+00:00 2021-04-12T05:00:33.102904+00:00 0:00:01.816521 16246 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T05:00:28.753672+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T04:00:00+00:00 PythonOperator 2021-04-12T05:00:08.751782+00:00 2021-04-12T05:00:11.500707+00:00 0:00:02.748925 16245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T05:00:06.535969+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T03:00:00+00:00 TriggerDagRunOperator 2021-04-12T04:11:26.273431+00:00 2021-04-12T04:11:26.861185+00:00 0:00:00.587754 16238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T04:11:23.677021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T03:00:00+00:00 TriggerDagRunOperator 2021-04-12T04:11:26.110339+00:00 2021-04-12T04:11:26.550617+00:00 0:00:00.440278 16237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T04:11:23.677057+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T03:00:00+00:00 EmrJobFlowSensor 2021-04-12T04:01:05.328866+00:00 2021-04-12T04:11:08.095948+00:00 0:10:02.767082 16232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T04:01:03.040461+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T04:00:41.791404+00:00 2021-04-12T04:00:43.518074+00:00 0:00:01.726670 16231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T04:00:39.005236+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T03:00:00+00:00 PythonOperator 2021-04-12T04:00:21.159254+00:00 2021-04-12T04:00:23.953687+00:00 0:00:02.794433 16230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T04:00:18.990777+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T02:00:00+00:00 TriggerDagRunOperator 2021-04-12T03:10:18.521337+00:00 2021-04-12T03:10:19.043496+00:00 0:00:00.522159 16223 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T03:10:15.893970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T02:00:00+00:00 TriggerDagRunOperator 2021-04-12T03:10:18.305204+00:00 2021-04-12T03:10:18.714437+00:00 0:00:00.409233 16222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T03:10:15.894019+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T02:00:00+00:00 EmrJobFlowSensor 2021-04-12T03:00:52.230170+00:00 2021-04-12T03:09:55.136202+00:00 0:09:02.906032 16217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T03:00:49.938361+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T03:00:30.378617+00:00 2021-04-12T03:00:32.102989+00:00 0:00:01.724372 16216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T03:00:28.041204+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T02:00:00+00:00 PythonOperator 2021-04-12T03:00:10.177768+00:00 2021-04-12T03:00:13.015208+00:00 0:00:02.837440 16215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T03:00:07.903288+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T01:00:00+00:00 TriggerDagRunOperator 2021-04-12T02:11:17.712256+00:00 2021-04-12T02:11:18.305123+00:00 0:00:00.592867 16208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T02:11:15.200184+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T01:00:00+00:00 TriggerDagRunOperator 2021-04-12T02:11:17.284065+00:00 2021-04-12T02:11:17.708417+00:00 0:00:00.424352 16207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T02:11:15.200212+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T01:00:00+00:00 EmrJobFlowSensor 2021-04-12T02:02:10.402649+00:00 2021-04-12T02:11:13.133111+00:00 0:09:02.730462 16203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T02:02:08.037581+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T02:01:50.776039+00:00 2021-04-12T02:01:52.505304+00:00 0:00:01.729265 16202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T02:01:48.017044+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T01:00:00+00:00 PythonOperator 2021-04-12T02:01:28.470223+00:00 2021-04-12T02:01:31.515230+00:00 0:00:03.045007 16201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T02:01:25.998480+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T00:00:00+00:00 TriggerDagRunOperator 2021-04-12T01:11:18.575349+00:00 2021-04-12T01:11:19.005061+00:00 0:00:00.429712 16193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T01:11:15.836739+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T00:00:00+00:00 TriggerDagRunOperator 2021-04-12T01:11:18.288265+00:00 2021-04-12T01:11:18.940293+00:00 0:00:00.652028 16192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T01:11:15.836712+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T00:00:00+00:00 EmrJobFlowSensor 2021-04-12T01:01:05.144114+00:00 2021-04-12T01:11:07.937866+00:00 0:10:02.793752 16188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T01:01:02.791125+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T01:00:43.032380+00:00 2021-04-12T01:00:44.731325+00:00 0:00:01.698945 16187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T01:00:40.765276+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T00:00:00+00:00 PythonOperator 2021-04-12T01:00:23.250466+00:00 2021-04-12T01:00:26.411969+00:00 0:00:03.161503 16186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T01:00:20.748724+00:00 2 default_pool
success 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 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-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 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 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 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 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 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-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 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-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 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-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 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 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T16:00:00+00:00 TriggerDagRunOperator 2021-04-11T17:10:20.391272+00:00 2021-04-11T17:10:20.927413+00:00 0:00:00.536141 16073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T17:10:18.017897+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T16:00:00+00:00 TriggerDagRunOperator 2021-04-11T17:10:20.260404+00:00 2021-04-11T17:10:20.669691+00:00 0:00:00.409287 16072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T17:10:18.017870+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T16:00:00+00:00 EmrJobFlowSensor 2021-04-11T17:01:09.240876+00:00 2021-04-11T17:10:11.891300+00:00 0:09:02.650424 16068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T17:01:06.988111+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T17:00:45.202017+00:00 2021-04-11T17:00:46.919137+00:00 0:00:01.717120 16067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T17:00:42.888753+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T16:00:00+00:00 PythonOperator 2021-04-11T17:00:25.307314+00:00 2021-04-11T17:00:28.000069+00:00 0:00:02.692755 16066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T17:00:22.830877+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T15:00:00+00:00 TriggerDagRunOperator 2021-04-11T16:11:22.320610+00:00 2021-04-11T16:11:22.914122+00:00 0:00:00.593512 16058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T16:11:19.873411+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T15:00:00+00:00 TriggerDagRunOperator 2021-04-11T16:11:22.228933+00:00 2021-04-11T16:11:22.656454+00:00 0:00:00.427521 16057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T16:11:19.873379+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T15:00:00+00:00 EmrJobFlowSensor 2021-04-11T16:01:08.107286+00:00 2021-04-11T16:11:10.955308+00:00 0:10:02.848022 16053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T16:01:05.067362+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T16:00:45.395002+00:00 2021-04-11T16:00:47.226181+00:00 0:00:01.831179 16052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T16:00:43.046566+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T15:00:00+00:00 PythonOperator 2021-04-11T16:00:23.744721+00:00 2021-04-11T16:00:26.638285+00:00 0:00:02.893564 16051 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T16:00:20.930706+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T14:00:00+00:00 TriggerDagRunOperator 2021-04-11T15:10:04.095080+00:00 2021-04-11T15:10:04.679509+00:00 0:00:00.584429 16043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T15:10:01.650375+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T14:00:00+00:00 TriggerDagRunOperator 2021-04-11T15:10:03.848506+00:00 2021-04-11T15:10:04.273373+00:00 0:00:00.424867 16042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T15:10:01.650404+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T14:00:00+00:00 EmrJobFlowSensor 2021-04-11T15:00:55.156389+00:00 2021-04-11T15:09:58.157313+00:00 0:09:03.000924 16038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T15:00:52.748129+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T15:00:32.907338+00:00 2021-04-11T15:00:34.576999+00:00 0:00:01.669661 16037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T15:00:30.726258+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T14:00:00+00:00 PythonOperator 2021-04-11T15:00:11.340192+00:00 2021-04-11T15:00:14.092447+00:00 0:00:02.752255 16036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T15:00:08.706166+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T13:00:00+00:00 TriggerDagRunOperator 2021-04-11T14:11:10.457145+00:00 2021-04-11T14:11:10.974969+00:00 0:00:00.517824 16028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T14:11:07.660834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T13:00:00+00:00 TriggerDagRunOperator 2021-04-11T14:11:09.982631+00:00 2021-04-11T14:11:10.525937+00:00 0:00:00.543306 16027 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T14:11:07.660796+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T13:00:00+00:00 EmrJobFlowSensor 2021-04-11T14:01:01.131075+00:00 2021-04-11T14:11:04.070736+00:00 0:10:02.939661 16023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T14:00:58.844400+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T14:00:39.299998+00:00 2021-04-11T14:00:41.112682+00:00 0:00:01.812684 16022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T14:00:36.769807+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T13:00:00+00:00 PythonOperator 2021-04-11T14:00:17.025625+00:00 2021-04-11T14:00:20.141864+00:00 0:00:03.116239 16021 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T14:00:14.684223+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T12:00:00+00:00 TriggerDagRunOperator 2021-04-11T13:10:12.481459+00:00 2021-04-11T13:10:13.058126+00:00 0:00:00.576667 16013 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T13:10:09.365283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T12:00:00+00:00 TriggerDagRunOperator 2021-04-11T13:10:12.448023+00:00 2021-04-11T13:10:12.918131+00:00 0:00:00.470108 16012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T13:10:09.365232+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T12:00:00+00:00 EmrJobFlowSensor 2021-04-11T13:00:58.503638+00:00 2021-04-11T13:10:01.403434+00:00 0:09:02.899796 16008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T13:00:56.304505+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T13:00:36.518003+00:00 2021-04-11T13:00:38.253690+00:00 0:00:01.735687 16007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T13:00:34.283134+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T12:00:00+00:00 PythonOperator 2021-04-11T13:00:16.796178+00:00 2021-04-11T13:00:19.536885+00:00 0:00:02.740707 16006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T13:00:14.232103+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T11:00:00+00:00 TriggerDagRunOperator 2021-04-11T12:10:34.429665+00:00 2021-04-11T12:10:34.879080+00:00 0:00:00.449415 15998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T12:10:31.664045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T11:00:00+00:00 TriggerDagRunOperator 2021-04-11T12:10:34.277231+00:00 2021-04-11T12:10:34.847052+00:00 0:00:00.569821 15997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T12:10:31.664075+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T11:00:00+00:00 EmrJobFlowSensor 2021-04-11T12:01:12.799798+00:00 2021-04-11T12:10:15.459931+00:00 0:09:02.660133 15993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T12:01:10.616993+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T12:00:42.867765+00:00 2021-04-11T12:00:44.668526+00:00 0:00:01.800761 15992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T12:00:40.591062+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T11:00:00+00:00 PythonOperator 2021-04-11T12:00:12.915972+00:00 2021-04-11T12:00:15.629005+00:00 0:00:02.713033 15991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T12:00:10.523795+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T10:00:00+00:00 TriggerDagRunOperator 2021-04-11T11:17:22.278684+00:00 2021-04-11T11:17:22.877366+00:00 0:00:00.598682 15983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T11:17:20.025984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T10:00:00+00:00 TriggerDagRunOperator 2021-04-11T11:17:22.195435+00:00 2021-04-11T11:17:22.683169+00:00 0:00:00.487734 15982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T11:17:20.025953+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T10:00:00+00:00 EmrJobFlowSensor 2021-04-11T11:01:04.554297+00:00 2021-04-11T11:17:08.573043+00:00 0:16:04.018746 15978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T11:01:02.097528+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T11:00:40.573090+00:00 2021-04-11T11:00:42.384576+00:00 0:00:01.811486 15977 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T11:00:38.152813+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T10:00:00+00:00 PythonOperator 2021-04-11T11:00:18.276790+00:00 2021-04-11T11:00:21.022651+00:00 0:00:02.745861 15976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T11:00:15.991974+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T09:00:00+00:00 TriggerDagRunOperator 2021-04-11T10:10:32.382485+00:00 2021-04-11T10:10:32.954589+00:00 0:00:00.572104 15968 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T10:10:29.893148+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T09:00:00+00:00 TriggerDagRunOperator 2021-04-11T10:10:32.269450+00:00 2021-04-11T10:10:32.677331+00:00 0:00:00.407881 15967 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T10:10:29.893195+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T09:00:00+00:00 EmrJobFlowSensor 2021-04-11T10:01:13.332532+00:00 2021-04-11T10:10:15.993887+00:00 0:09:02.661355 15963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T10:01:10.984715+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T10:00:51.209726+00:00 2021-04-11T10:00:52.928543+00:00 0:00:01.718817 15962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T10:00:48.961335+00:00 2 default_pool