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-08T21:00:00+00:00 PythonOperator 2021-04-08T22:00:23.817906+00:00 2021-04-08T22:00:26.638237+00:00 0:00:02.820331 15061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T22:00:21.003863+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T20:00:00+00:00 TriggerDagRunOperator 2021-04-08T21:11:03.869524+00:00 2021-04-08T21:11:04.413205+00:00 0:00:00.543681 15053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T21:11:01.510754+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T20:00:00+00:00 TriggerDagRunOperator 2021-04-08T21:11:03.691553+00:00 2021-04-08T21:11:04.155429+00:00 0:00:00.463876 15052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T21:11:01.510717+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T20:00:00+00:00 EmrJobFlowSensor 2021-04-08T21:00:48.890561+00:00 2021-04-08T21:10:51.829047+00:00 0:10:02.938486 15048 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T21:00:46.510476+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T21:00:26.940330+00:00 2021-04-08T21:00:28.839687+00:00 0:00:01.899357 15047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T21:00:24.433091+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T20:00:00+00:00 PythonOperator 2021-04-08T21:00:05.146768+00:00 2021-04-08T21:00:08.055582+00:00 0:00:02.908814 15046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T21:00:02.426179+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T19:00:00+00:00 TriggerDagRunOperator 2021-04-08T20:10:23.817782+00:00 2021-04-08T20:10:24.480121+00:00 0:00:00.662339 15038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T20:10:21.252854+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T19:00:00+00:00 TriggerDagRunOperator 2021-04-08T20:10:23.682369+00:00 2021-04-08T20:10:24.269471+00:00 0:00:00.587102 15037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T20:10:21.252823+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T19:00:00+00:00 EmrJobFlowSensor 2021-04-08T20:00:56.302565+00:00 2021-04-08T20:09:59.043447+00:00 0:09:02.740882 15033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T20:00:54.121402+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T20:00:34.467576+00:00 2021-04-08T20:00:36.370249+00:00 0:00:01.902673 15032 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T20:00:32.083650+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T19:00:00+00:00 PythonOperator 2021-04-08T20:00:12.309512+00:00 2021-04-08T20:00:15.068804+00:00 0:00:02.759292 15031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T20:00:10.024343+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T18:00:00+00:00 TriggerDagRunOperator 2021-04-08T19:09:08.409654+00:00 2021-04-08T19:09:08.901200+00:00 0:00:00.491546 15023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T19:09:05.843306+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T18:00:00+00:00 TriggerDagRunOperator 2021-04-08T19:09:08.120125+00:00 2021-04-08T19:09:08.671897+00:00 0:00:00.551772 15022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T19:09:05.843338+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T18:00:00+00:00 EmrJobFlowSensor 2021-04-08T19:00:55.273406+00:00 2021-04-08T19:08:57.684991+00:00 0:08:02.411585 15018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T19:00:53.102241+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T19:00:35.240886+00:00 2021-04-08T19:00:36.953161+00:00 0:00:01.712275 15017 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T19:00:33.084873+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T18:00:00+00:00 PythonOperator 2021-04-08T19:00:11.710050+00:00 2021-04-08T19:00:14.458367+00:00 0:00:02.748317 15016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T19:00:09.074647+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T17:00:00+00:00 TriggerDagRunOperator 2021-04-08T18:10:20.340514+00:00 2021-04-08T18:10:20.909886+00:00 0:00:00.569372 15008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T18:10:17.847625+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T17:00:00+00:00 TriggerDagRunOperator 2021-04-08T18:10:20.197331+00:00 2021-04-08T18:10:20.646413+00:00 0:00:00.449082 15007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T18:10:17.847661+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T17:00:00+00:00 EmrJobFlowSensor 2021-04-08T18:00:55.158755+00:00 2021-04-08T18:09:57.764573+00:00 0:09:02.605818 15003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T18:00:52.790752+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T18:00:35.259976+00:00 2021-04-08T18:00:37.144305+00:00 0:00:01.884329 15002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T18:00:32.770793+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T17:00:00+00:00 PythonOperator 2021-04-08T18:00:13.047039+00:00 2021-04-08T18:00:15.925923+00:00 0:00:02.878884 15001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T18:00:10.690980+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T16:00:00+00:00 TriggerDagRunOperator 2021-04-08T17:11:28.179677+00:00 2021-04-08T17:11:28.789058+00:00 0:00:00.609381 14993 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T17:11:25.456325+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T16:00:00+00:00 TriggerDagRunOperator 2021-04-08T17:11:27.994013+00:00 2021-04-08T17:11:28.409249+00:00 0:00:00.415236 14992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T17:11:25.456285+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T16:00:00+00:00 EmrJobFlowSensor 2021-04-08T17:01:06.620045+00:00 2021-04-08T17:11:09.510874+00:00 0:10:02.890829 14988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T17:01:04.349203+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T17:00:46.581304+00:00 2021-04-08T17:00:48.402438+00:00 0:00:01.821134 14987 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T17:00:44.245087+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T16:00:00+00:00 PythonOperator 2021-04-08T17:00:24.545225+00:00 2021-04-08T17:00:27.258743+00:00 0:00:02.713518 14986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T17:00:22.227640+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T15:00:00+00:00 TriggerDagRunOperator 2021-04-08T16:12:18.354042+00:00 2021-04-08T16:12:18.881381+00:00 0:00:00.527339 14979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T16:12:15.363733+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T15:00:00+00:00 TriggerDagRunOperator 2021-04-08T16:12:18.150590+00:00 2021-04-08T16:12:18.647034+00:00 0:00:00.496444 14978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T16:12:15.363696+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T15:00:00+00:00 EmrJobFlowSensor 2021-04-08T16:01:04.020358+00:00 2021-04-08T16:11:06.817368+00:00 0:10:02.797010 14973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T16:01:01.854485+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T16:00:42.183640+00:00 2021-04-08T16:00:43.998679+00:00 0:00:01.815039 14972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T16:00:39.880816+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T15:00:00+00:00 PythonOperator 2021-04-08T16:00:20.211057+00:00 2021-04-08T16:00:22.986362+00:00 0:00:02.775305 14971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T16:00:17.867677+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T14:00:00+00:00 TriggerDagRunOperator 2021-04-08T15:11:15.720664+00:00 2021-04-08T15:11:16.265585+00:00 0:00:00.544921 14964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T15:11:12.749368+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T14:00:00+00:00 TriggerDagRunOperator 2021-04-08T15:11:15.682374+00:00 2021-04-08T15:11:16.083488+00:00 0:00:00.401114 14963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T15:11:12.749411+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T14:00:00+00:00 EmrJobFlowSensor 2021-04-08T15:01:06.318607+00:00 2021-04-08T15:11:09.187705+00:00 0:10:02.869098 14958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T15:01:04.143651+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T15:00:38.531829+00:00 2021-04-08T15:00:40.258174+00:00 0:00:01.726345 14957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T15:00:36.174302+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T14:00:00+00:00 PythonOperator 2021-04-08T15:00:18.405622+00:00 2021-04-08T15:00:21.182009+00:00 0:00:02.776387 14956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T15:00:16.144221+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T13:00:00+00:00 TriggerDagRunOperator 2021-04-08T14:18:28.961170+00:00 2021-04-08T14:18:29.475522+00:00 0:00:00.514352 14949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T14:18:26.218409+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T13:00:00+00:00 TriggerDagRunOperator 2021-04-08T14:18:28.642508+00:00 2021-04-08T14:18:29.077629+00:00 0:00:00.435121 14948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T14:18:26.218442+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T13:00:00+00:00 EmrJobFlowSensor 2021-04-08T14:08:19.293712+00:00 2021-04-08T14:18:22.234580+00:00 0:10:02.940868 14946 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T14:08:16.819495+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T14:07:56.910115+00:00 2021-04-08T14:07:58.600475+00:00 0:00:01.690360 14944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T14:07:54.797455+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T13:00:00+00:00 PythonOperator 2021-04-08T14:07:37.201440+00:00 2021-04-08T14:07:39.946466+00:00 0:00:02.745026 14942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T14:07:34.774974+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T12:00:00+00:00 TriggerDagRunOperator 2021-04-08T13:11:02.558617+00:00 2021-04-08T13:11:03.014645+00:00 0:00:00.456028 14934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T13:11:00.169699+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T12:00:00+00:00 TriggerDagRunOperator 2021-04-08T13:11:02.578331+00:00 2021-04-08T13:11:03.157130+00:00 0:00:00.578799 14933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T13:11:00.169647+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T12:00:00+00:00 EmrJobFlowSensor 2021-04-08T13:00:53.786838+00:00 2021-04-08T13:10:56.633126+00:00 0:10:02.846288 14929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T13:00:51.350109+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T13:00:33.422331+00:00 2021-04-08T13:00:35.194811+00:00 0:00:01.772480 14928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T13:00:31.260198+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T12:00:00+00:00 PythonOperator 2021-04-08T13:00:11.515333+00:00 2021-04-08T13:00:14.230576+00:00 0:00:02.715243 14927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T13:00:09.231677+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T11:00:00+00:00 TriggerDagRunOperator 2021-04-08T12:11:21.347208+00:00 2021-04-08T12:11:21.770026+00:00 0:00:00.422818 14919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T12:11:19.081855+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T11:00:00+00:00 TriggerDagRunOperator 2021-04-08T12:11:21.308393+00:00 2021-04-08T12:11:21.890288+00:00 0:00:00.581895 14918 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T12:11:19.081889+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T11:00:00+00:00 EmrJobFlowSensor 2021-04-08T12:00:56.229623+00:00 2021-04-08T12:10:59.218211+00:00 0:10:02.988588 14914 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T12:00:54.042973+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T12:00:36.300949+00:00 2021-04-08T12:00:38.051553+00:00 0:00:01.750604 14913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T12:00:34.019225+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T11:00:00+00:00 PythonOperator 2021-04-08T12:00:12.828398+00:00 2021-04-08T12:00:15.681294+00:00 0:00:02.852896 14912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T12:00:10.055944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T10:00:00+00:00 TriggerDagRunOperator 2021-04-08T11:11:11.939332+00:00 2021-04-08T11:11:12.346651+00:00 0:00:00.407319 14904 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T11:11:09.541092+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T10:00:00+00:00 TriggerDagRunOperator 2021-04-08T11:11:11.878617+00:00 2021-04-08T11:11:12.431123+00:00 0:00:00.552506 14903 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T11:11:09.541146+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T10:00:00+00:00 EmrJobFlowSensor 2021-04-08T11:00:46.418777+00:00 2021-04-08T11:10:49.324217+00:00 0:10:02.905440 14899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T11:00:44.160692+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T11:00:26.326841+00:00 2021-04-08T11:00:28.183202+00:00 0:00:01.856361 14898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T11:00:24.060927+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T10:00:00+00:00 PythonOperator 2021-04-08T11:00:04.898195+00:00 2021-04-08T11:00:07.628822+00:00 0:00:02.730627 14897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T11:00:02.038991+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T09:00:00+00:00 TriggerDagRunOperator 2021-04-08T10:12:20.159105+00:00 2021-04-08T10:12:20.704261+00:00 0:00:00.545156 14889 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T10:12:17.696508+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T09:00:00+00:00 TriggerDagRunOperator 2021-04-08T10:12:20.041757+00:00 2021-04-08T10:12:20.610431+00:00 0:00:00.568674 14888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T10:12:17.696540+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T09:00:00+00:00 EmrJobFlowSensor 2021-04-08T10:01:06.606849+00:00 2021-04-08T10:12:09.620545+00:00 0:11:03.013696 14884 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T10:01:04.450525+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T10:00:46.484457+00:00 2021-04-08T10:00:48.289968+00:00 0:00:01.805511 14883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T10:00:44.348341+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T09:00:00+00:00 PythonOperator 2021-04-08T10:00:25.186508+00:00 2021-04-08T10:00:28.032683+00:00 0:00:02.846175 14882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T10:00:22.330862+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T08:00:00+00:00 TriggerDagRunOperator 2021-04-08T09:11:23.171563+00:00 2021-04-08T09:11:23.898363+00:00 0:00:00.726800 14874 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T09:11:20.534666+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T08:00:00+00:00 TriggerDagRunOperator 2021-04-08T09:11:22.851328+00:00 2021-04-08T09:11:23.272225+00:00 0:00:00.420897 14873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T09:11:20.534693+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T08:00:00+00:00 EmrJobFlowSensor 2021-04-08T09:00:57.640184+00:00 2021-04-08T09:11:00.487703+00:00 0:10:02.847519 14869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T09:00:55.391104+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T09:00:35.839839+00:00 2021-04-08T09:00:37.542318+00:00 0:00:01.702479 14868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T09:00:33.383933+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T08:00:00+00:00 PythonOperator 2021-04-08T09:00:16.162686+00:00 2021-04-08T09:00:19.030737+00:00 0:00:02.868051 14867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T09:00:13.363952+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T07:00:00+00:00 TriggerDagRunOperator 2021-04-08T08:11:10.539893+00:00 2021-04-08T08:11:11.098472+00:00 0:00:00.558579 14859 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T08:11:08.192641+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T07:00:00+00:00 TriggerDagRunOperator 2021-04-08T08:11:10.513173+00:00 2021-04-08T08:11:10.924099+00:00 0:00:00.410926 14858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T08:11:08.192674+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T07:00:00+00:00 EmrJobFlowSensor 2021-04-08T08:00:49.699891+00:00 2021-04-08T08:10:52.650156+00:00 0:10:02.950265 14854 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T08:00:47.257211+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T08:00:29.464003+00:00 2021-04-08T08:00:31.166649+00:00 0:00:01.702646 14853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T08:00:27.114545+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T07:00:00+00:00 PythonOperator 2021-04-08T08:00:07.657977+00:00 2021-04-08T08:00:10.578107+00:00 0:00:02.920130 14852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T08:00:05.087675+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T06:00:00+00:00 TriggerDagRunOperator 2021-04-08T07:12:35.121543+00:00 2021-04-08T07:12:35.657370+00:00 0:00:00.535827 14844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T07:12:32.806656+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T06:00:00+00:00 TriggerDagRunOperator 2021-04-08T07:12:34.995032+00:00 2021-04-08T07:12:35.444453+00:00 0:00:00.449421 14843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T07:12:32.806688+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T06:00:00+00:00 EmrJobFlowSensor 2021-04-08T07:01:09.928140+00:00 2021-04-08T07:12:12.992092+00:00 0:11:03.063952 14839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T07:01:07.538751+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T07:00:35.817836+00:00 2021-04-08T07:00:37.662403+00:00 0:00:01.844567 14838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T07:00:33.504026+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T06:00:00+00:00 PythonOperator 2021-04-08T07:00:11.934258+00:00 2021-04-08T07:00:14.637584+00:00 0:00:02.703326 14837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T07:00:09.494139+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T05:00:00+00:00 TriggerDagRunOperator 2021-04-08T06:11:13.150696+00:00 2021-04-08T06:11:13.700076+00:00 0:00:00.549380 14829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T06:11:10.793868+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T05:00:00+00:00 TriggerDagRunOperator 2021-04-08T06:11:13.015966+00:00 2021-04-08T06:11:13.433772+00:00 0:00:00.417806 14828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T06:11:10.793832+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T05:00:00+00:00 EmrJobFlowSensor 2021-04-08T06:00:48.290229+00:00 2021-04-08T06:10:51.181650+00:00 0:10:02.891421 14824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T06:00:45.809004+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T06:00:26.055870+00:00 2021-04-08T06:00:27.810385+00:00 0:00:01.754515 14823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T06:00:23.796157+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T05:00:00+00:00 PythonOperator 2021-04-08T06:00:06.282762+00:00 2021-04-08T06:00:09.154444+00:00 0:00:02.871682 14822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T06:00:03.781449+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T04:00:00+00:00 TriggerDagRunOperator 2021-04-08T05:11:27.817554+00:00 2021-04-08T05:11:28.325893+00:00 0:00:00.508339 14814 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T05:11:25.496549+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T04:00:00+00:00 TriggerDagRunOperator 2021-04-08T05:11:27.704929+00:00 2021-04-08T05:11:28.112722+00:00 0:00:00.407793 14813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T05:11:25.496515+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T04:00:00+00:00 EmrJobFlowSensor 2021-04-08T05:01:00.815826+00:00 2021-04-08T05:11:03.671270+00:00 0:10:02.855444 14809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T05:00:58.357519+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T05:00:38.493089+00:00 2021-04-08T05:00:40.329257+00:00 0:00:01.836168 14808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T05:00:36.188715+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T04:00:00+00:00 PythonOperator 2021-04-08T05:00:18.424753+00:00 2021-04-08T05:00:21.203064+00:00 0:00:02.778311 14807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T05:00:16.134308+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T03:00:00+00:00 TriggerDagRunOperator 2021-04-08T04:11:07.864552+00:00 2021-04-08T04:11:08.437433+00:00 0:00:00.572881 14799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T04:11:05.244456+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T03:00:00+00:00 TriggerDagRunOperator 2021-04-08T04:11:07.642314+00:00 2021-04-08T04:11:08.077316+00:00 0:00:00.435002 14798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T04:11:05.244491+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T03:00:00+00:00 EmrJobFlowSensor 2021-04-08T04:01:00.497029+00:00 2021-04-08T04:11:03.463424+00:00 0:10:02.966395 14794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T04:00:57.959781+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T04:00:40.016073+00:00 2021-04-08T04:00:41.678181+00:00 0:00:01.662108 14793 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T04:00:37.787627+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T03:00:00+00:00 PythonOperator 2021-04-08T04:00:18.062303+00:00 2021-04-08T04:00:21.033309+00:00 0:00:02.971006 14792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T04:00:15.733956+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T02:00:00+00:00 TriggerDagRunOperator 2021-04-08T03:11:06.920133+00:00 2021-04-08T03:11:07.553640+00:00 0:00:00.633507 14784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T03:11:04.617324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T02:00:00+00:00 TriggerDagRunOperator 2021-04-08T03:11:06.914122+00:00 2021-04-08T03:11:07.510105+00:00 0:00:00.595983 14783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T03:11:04.617297+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T02:00:00+00:00 EmrJobFlowSensor 2021-04-08T03:00:53.792222+00:00 2021-04-08T03:10:56.657733+00:00 0:10:02.865511 14779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T03:00:51.637096+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T03:00:34.117385+00:00 2021-04-08T03:00:35.949184+00:00 0:00:01.831799 14778 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T03:00:31.621208+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T02:00:00+00:00 PythonOperator 2021-04-08T03:00:12.137015+00:00 2021-04-08T03:00:14.873458+00:00 0:00:02.736443 14777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T03:00:09.597448+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T01:00:00+00:00 TriggerDagRunOperator 2021-04-08T02:09:15.296341+00:00 2021-04-08T02:09:15.810495+00:00 0:00:00.514154 14769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T02:09:12.995185+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T01:00:00+00:00 TriggerDagRunOperator 2021-04-08T02:09:15.310634+00:00 2021-04-08T02:09:15.979902+00:00 0:00:00.669268 14768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T02:09:12.995213+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T01:00:00+00:00 EmrJobFlowSensor 2021-04-08T02:01:00.609006+00:00 2021-04-08T02:09:03.282936+00:00 0:08:02.673930 14764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T02:00:58.051359+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T02:00:30.212117+00:00 2021-04-08T02:00:31.913048+00:00 0:00:01.700931 14763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T02:00:27.966757+00:00 2 default_pool