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 trigger_dagrun_campaign-history-job_v002 2023-04-02T23:00:00+00:00 TriggerDagRunOperator 2023-04-03T00:30:36.346364+00:00 2023-04-03T00:30:36.814894+00:00 0:00:00.468530 363179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T00:30:33.910153+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T23:00:00+00:00 EmrJobFlowSensor 2023-04-03T00:05:22.055265+00:00 2023-04-03T00:15:24.054504+00:00 0:10:01.999239 363174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T00:05:17.351836+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T00:05:00.792514+00:00 2023-04-03T00:05:01.781941+00:00 0:00:00.989427 363171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T00:04:57.346607+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T23:00:00+00:00 PythonOperator 2023-04-03T00:04:37.438617+00:00 2023-04-03T00:04:41.504811+00:00 0:00:04.066194 363169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T00:04:35.317000+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T22:00:00+00:00 TriggerDagRunOperator 2023-04-02T23:15:38.573467+00:00 2023-04-02T23:15:39.039422+00:00 0:00:00.465955 363160 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T23:15:35.765267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T22:00:00+00:00 TriggerDagRunOperator 2023-04-02T23:15:38.368757+00:00 2023-04-02T23:15:38.839295+00:00 0:00:00.470538 363159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T23:15:35.765297+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T22:00:00+00:00 EmrJobFlowSensor 2023-04-02T23:00:49.962878+00:00 2023-04-02T23:10:51.768249+00:00 0:10:01.805371 363148 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T23:00:47.710993+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T22:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T23:00:29.823842+00:00 2023-04-02T23:00:30.681666+00:00 0:00:00.857824 363146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T23:00:27.686351+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T22:00:00+00:00 PythonOperator 2023-04-02T23:00:08.311009+00:00 2023-04-02T23:00:11.685280+00:00 0:00:03.374271 363143 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T23:00:05.665401+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T21:00:00+00:00 TriggerDagRunOperator 2023-04-02T22:11:25.360544+00:00 2023-04-02T22:11:26.121860+00:00 0:00:00.761316 363134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T22:11:22.711028+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T21:00:00+00:00 TriggerDagRunOperator 2023-04-02T22:11:25.169827+00:00 2023-04-02T22:11:25.797900+00:00 0:00:00.628073 363133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T22:11:22.711056+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T21:00:00+00:00 EmrJobFlowSensor 2023-04-02T22:00:50.763597+00:00 2023-04-02T22:10:52.600715+00:00 0:10:01.837118 363125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T22:00:48.488414+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T21:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T22:00:28.691918+00:00 2023-04-02T22:00:29.493625+00:00 0:00:00.801707 363123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T22:00:26.496395+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T21:00:00+00:00 PythonOperator 2023-04-02T22:00:06.867544+00:00 2023-04-02T22:00:10.305023+00:00 0:00:03.437479 363121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T22:00:04.454245+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T20:00:00+00:00 TriggerDagRunOperator 2023-04-02T21:11:14.646812+00:00 2023-04-02T21:11:15.163853+00:00 0:00:00.517041 363111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T21:11:12.207334+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T20:00:00+00:00 TriggerDagRunOperator 2023-04-02T21:11:14.399920+00:00 2023-04-02T21:11:14.835327+00:00 0:00:00.435407 363110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T21:11:12.207299+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T20:00:00+00:00 EmrJobFlowSensor 2023-04-02T21:01:00.999287+00:00 2023-04-02T21:11:02.879581+00:00 0:10:01.880294 363103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T21:00:58.447137+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T20:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T21:00:40.773995+00:00 2023-04-02T21:00:41.723869+00:00 0:00:00.949874 363101 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T21:00:38.431835+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T20:00:00+00:00 PythonOperator 2023-04-02T21:00:19.026047+00:00 2023-04-02T21:00:25.538889+00:00 0:00:06.512842 363099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T21:00:16.409884+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T19:00:00+00:00 TriggerDagRunOperator 2023-04-02T20:11:21.693727+00:00 2023-04-02T20:11:22.156370+00:00 0:00:00.462643 363088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T20:11:19.034442+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T19:00:00+00:00 TriggerDagRunOperator 2023-04-02T20:11:21.513425+00:00 2023-04-02T20:11:22.006604+00:00 0:00:00.493179 363087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T20:11:19.034411+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T19:00:00+00:00 EmrJobFlowSensor 2023-04-02T20:00:57.821316+00:00 2023-04-02T20:10:59.524838+00:00 0:10:01.703522 363081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T20:00:55.622494+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T19:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T20:00:35.733137+00:00 2023-04-02T20:00:36.540029+00:00 0:00:00.806892 363079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T20:00:33.591748+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T19:00:00+00:00 PythonOperator 2023-04-02T20:00:16.136361+00:00 2023-04-02T20:00:19.555638+00:00 0:00:03.419277 363077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T20:00:13.607858+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T18:00:00+00:00 TriggerDagRunOperator 2023-04-02T19:11:19.339696+00:00 2023-04-02T19:11:19.828942+00:00 0:00:00.489246 363065 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T19:11:16.930781+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T18:00:00+00:00 TriggerDagRunOperator 2023-04-02T19:11:19.112025+00:00 2023-04-02T19:11:19.556811+00:00 0:00:00.444786 363064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T19:11:16.930746+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T18:00:00+00:00 EmrJobFlowSensor 2023-04-02T19:01:01.083833+00:00 2023-04-02T19:11:02.982045+00:00 0:10:01.898212 363058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T19:00:58.527940+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T18:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T19:00:41.517726+00:00 2023-04-02T19:00:43.196848+00:00 0:00:01.679122 363056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T19:00:38.510898+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T18:00:00+00:00 PythonOperator 2023-04-02T19:00:18.877765+00:00 2023-04-02T19:00:22.168382+00:00 0:00:03.290617 363054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T19:00:16.471155+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T17:00:00+00:00 TriggerDagRunOperator 2023-04-02T18:12:00.750893+00:00 2023-04-02T18:12:01.265870+00:00 0:00:00.514977 363044 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T18:11:58.390818+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T17:00:00+00:00 TriggerDagRunOperator 2023-04-02T18:12:00.723729+00:00 2023-04-02T18:12:01.193383+00:00 0:00:00.469654 363043 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T18:11:58.390846+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T17:00:00+00:00 EmrJobFlowSensor 2023-04-02T18:01:07.021933+00:00 2023-04-02T18:11:08.741965+00:00 0:10:01.720032 363035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T18:01:04.696193+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T17:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T18:00:45.162619+00:00 2023-04-02T18:00:46.350096+00:00 0:00:01.187477 363033 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T18:00:42.701817+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T17:00:00+00:00 PythonOperator 2023-04-02T18:00:22.920732+00:00 2023-04-02T18:00:26.960550+00:00 0:00:04.039818 363031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T18:00:20.561824+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T16:00:00+00:00 TriggerDagRunOperator 2023-04-02T17:28:50.422456+00:00 2023-04-02T17:28:51.024807+00:00 0:00:00.602351 363024 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T17:28:47.649200+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T16:00:00+00:00 TriggerDagRunOperator 2023-04-02T17:28:50.205184+00:00 2023-04-02T17:28:50.765746+00:00 0:00:00.560562 363023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T17:28:47.649171+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T16:00:00+00:00 EmrJobFlowSensor 2023-04-02T17:11:39.895017+00:00 2023-04-02T17:21:41.792963+00:00 0:10:01.897946 363020 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T17:11:37.571323+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T16:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T17:11:17.728758+00:00 2023-04-02T17:11:18.545134+00:00 0:00:00.816376 363017 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T17:11:15.552404+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T16:00:00+00:00 PythonOperator 2023-04-02T17:10:57.932863+00:00 2023-04-02T17:11:01.989471+00:00 0:00:04.056608 363014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T17:10:55.546090+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T15:00:00+00:00 TriggerDagRunOperator 2023-04-02T16:11:42.115049+00:00 2023-04-02T16:11:42.587548+00:00 0:00:00.472499 363002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T16:11:39.750584+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T15:00:00+00:00 TriggerDagRunOperator 2023-04-02T16:11:41.905269+00:00 2023-04-02T16:11:42.359392+00:00 0:00:00.454123 363001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T16:11:39.750553+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T15:00:00+00:00 EmrJobFlowSensor 2023-04-02T16:00:49.999452+00:00 2023-04-02T16:10:51.759754+00:00 0:10:01.760302 362996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T16:00:47.489264+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T15:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T16:00:27.871277+00:00 2023-04-02T16:00:28.695619+00:00 0:00:00.824342 362994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T16:00:25.524175+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T15:00:00+00:00 PythonOperator 2023-04-02T16:00:08.229591+00:00 2023-04-02T16:00:12.397879+00:00 0:00:04.168288 362992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T16:00:05.513962+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T14:00:00+00:00 TriggerDagRunOperator 2023-04-02T15:47:42.888563+00:00 2023-04-02T15:47:43.336661+00:00 0:00:00.448098 362987 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T15:47:40.271472+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T14:00:00+00:00 TriggerDagRunOperator 2023-04-02T15:47:42.690243+00:00 2023-04-02T15:47:43.149328+00:00 0:00:00.459085 362986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T15:47:40.271446+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T14:00:00+00:00 EmrJobFlowSensor 2023-04-02T15:37:32.981095+00:00 2023-04-02T15:47:34.838808+00:00 0:10:01.857713 362982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T15:37:30.642409+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T14:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T15:37:10.756120+00:00 2023-04-02T15:37:11.689417+00:00 0:00:00.933297 362979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T15:37:08.607744+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T14:00:00+00:00 PythonOperator 2023-04-02T15:36:48.853220+00:00 2023-04-02T15:36:52.107048+00:00 0:00:03.253828 362976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T15:36:46.588661+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T13:00:00+00:00 TriggerDagRunOperator 2023-04-02T14:26:53.360293+00:00 2023-04-02T14:26:53.865071+00:00 0:00:00.504778 362969 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T14:26:50.509786+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T13:00:00+00:00 TriggerDagRunOperator 2023-04-02T14:26:53.199974+00:00 2023-04-02T14:26:53.640278+00:00 0:00:00.440304 362968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T14:26:50.509742+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T13:00:00+00:00 EmrJobFlowSensor 2023-04-02T14:16:45.547094+00:00 2023-04-02T14:26:47.464629+00:00 0:10:01.917535 362963 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T14:16:43.201106+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T13:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T14:16:23.900867+00:00 2023-04-02T14:16:24.797265+00:00 0:00:00.896398 362959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T14:16:21.183938+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T13:00:00+00:00 PythonOperator 2023-04-02T14:00:19.239188+00:00 2023-04-02T14:00:23.690132+00:00 0:00:04.450944 362957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T14:00:17.090428+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T12:00:00+00:00 TriggerDagRunOperator 2023-04-02T13:48:20.540982+00:00 2023-04-02T13:48:21.112666+00:00 0:00:00.571684 362951 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T13:48:17.562132+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T12:00:00+00:00 TriggerDagRunOperator 2023-04-02T13:48:20.189984+00:00 2023-04-02T13:48:20.667248+00:00 0:00:00.477264 362950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T13:48:17.562175+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T12:00:00+00:00 EmrJobFlowSensor 2023-04-02T13:04:30.700761+00:00 2023-04-02T13:14:32.593780+00:00 0:10:01.893019 362943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T13:04:28.284814+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T12:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T13:04:10.631130+00:00 2023-04-02T13:04:11.667822+00:00 0:00:01.036692 362941 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T13:04:08.266942+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T12:00:00+00:00 PythonOperator 2023-04-02T13:03:49.026384+00:00 2023-04-02T13:03:55.499283+00:00 0:00:06.472899 362939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T13:03:46.246434+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T11:00:00+00:00 TriggerDagRunOperator 2023-04-02T12:28:09.924029+00:00 2023-04-02T12:28:10.410195+00:00 0:00:00.486166 362931 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T12:28:06.835590+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T11:00:00+00:00 TriggerDagRunOperator 2023-04-02T12:28:09.613490+00:00 2023-04-02T12:28:10.112518+00:00 0:00:00.499028 362930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T12:28:06.835562+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T11:00:00+00:00 EmrJobFlowSensor 2023-04-02T12:15:23.332960+00:00 2023-04-02T12:25:25.575780+00:00 0:10:02.242820 362925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T12:15:21.146369+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T11:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T12:15:01.427343+00:00 2023-04-02T12:15:02.852813+00:00 0:00:01.425470 362922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T12:14:59.123619+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T11:00:00+00:00 PythonOperator 2023-04-02T12:14:41.910688+00:00 2023-04-02T12:14:45.506293+00:00 0:00:03.595605 362920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T12:14:39.107831+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T10:00:00+00:00 TriggerDagRunOperator 2023-04-02T11:11:20.662773+00:00 2023-04-02T11:11:21.169090+00:00 0:00:00.506317 362911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T11:11:18.141088+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T10:00:00+00:00 TriggerDagRunOperator 2023-04-02T11:11:20.639261+00:00 2023-04-02T11:11:21.190125+00:00 0:00:00.550864 362910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T11:11:18.141060+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T10:00:00+00:00 EmrJobFlowSensor 2023-04-02T11:01:06.582699+00:00 2023-04-02T11:11:08.365227+00:00 0:10:01.782528 362903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T11:01:04.352002+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T10:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T11:00:46.533656+00:00 2023-04-02T11:00:47.351923+00:00 0:00:00.818267 362901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T11:00:44.334546+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T10:00:00+00:00 PythonOperator 2023-04-02T11:00:24.660086+00:00 2023-04-02T11:00:29.171830+00:00 0:00:04.511744 362899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T11:00:22.396682+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T09:00:00+00:00 TriggerDagRunOperator 2023-04-02T10:11:18.010922+00:00 2023-04-02T10:11:18.482578+00:00 0:00:00.471656 362889 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T10:11:15.408135+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T09:00:00+00:00 TriggerDagRunOperator 2023-04-02T10:11:17.780526+00:00 2023-04-02T10:11:18.229550+00:00 0:00:00.449024 362888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T10:11:15.408170+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T09:00:00+00:00 EmrJobFlowSensor 2023-04-02T10:00:56.740452+00:00 2023-04-02T10:10:58.455190+00:00 0:10:01.714738 362881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T10:00:54.532811+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T09:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T10:00:36.975200+00:00 2023-04-02T10:00:37.885752+00:00 0:00:00.910552 362879 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T10:00:34.514060+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T09:00:00+00:00 PythonOperator 2023-04-02T10:00:14.893039+00:00 2023-04-02T10:00:18.240787+00:00 0:00:03.347748 362877 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T10:00:12.434054+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T08:00:00+00:00 TriggerDagRunOperator 2023-04-02T09:11:32.122663+00:00 2023-04-02T09:11:32.619261+00:00 0:00:00.496598 362870 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T09:11:29.602252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T08:00:00+00:00 TriggerDagRunOperator 2023-04-02T09:11:31.959860+00:00 2023-04-02T09:11:32.403579+00:00 0:00:00.443719 362869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T09:11:29.602223+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T08:00:00+00:00 EmrJobFlowSensor 2023-04-02T09:01:08.975232+00:00 2023-04-02T09:11:10.626373+00:00 0:10:01.651141 362863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T09:01:06.668308+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T08:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T09:00:45.821971+00:00 2023-04-02T09:00:46.732061+00:00 0:00:00.910090 362861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T09:00:42.717182+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T08:00:00+00:00 PythonOperator 2023-04-02T09:00:23.342714+00:00 2023-04-02T09:00:27.393866+00:00 0:00:04.051152 362859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T09:00:20.626677+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T07:00:00+00:00 TriggerDagRunOperator 2023-04-02T08:11:15.269837+00:00 2023-04-02T08:11:15.747140+00:00 0:00:00.477303 362849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T08:11:12.742215+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T07:00:00+00:00 TriggerDagRunOperator 2023-04-02T08:11:14.960931+00:00 2023-04-02T08:11:15.486789+00:00 0:00:00.525858 362848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T08:11:12.742188+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T07:00:00+00:00 EmrJobFlowSensor 2023-04-02T08:00:58.650206+00:00 2023-04-02T08:11:00.470639+00:00 0:10:01.820433 362842 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T08:00:56.396534+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T07:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T08:00:36.593252+00:00 2023-04-02T08:00:37.413845+00:00 0:00:00.820593 362840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T08:00:34.383649+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T07:00:00+00:00 PythonOperator 2023-04-02T08:00:14.507221+00:00 2023-04-02T08:00:18.588920+00:00 0:00:04.081699 362838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T08:00:12.364308+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T06:00:00+00:00 TriggerDagRunOperator 2023-04-02T07:13:33.065641+00:00 2023-04-02T07:13:33.516792+00:00 0:00:00.451151 362830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T07:13:30.202410+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T06:00:00+00:00 TriggerDagRunOperator 2023-04-02T07:13:32.794983+00:00 2023-04-02T07:13:33.248917+00:00 0:00:00.453934 362829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T07:13:30.202367+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T06:00:00+00:00 EmrJobFlowSensor 2023-04-02T07:03:09.821762+00:00 2023-04-02T07:13:11.611904+00:00 0:10:01.790142 362823 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T07:03:07.444472+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T06:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T07:02:50.719162+00:00 2023-04-02T07:02:51.766397+00:00 0:00:01.047235 362821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T07:02:47.431040+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T06:00:00+00:00 PythonOperator 2023-04-02T07:02:28.116689+00:00 2023-04-02T07:02:32.144464+00:00 0:00:04.027775 362819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T07:02:25.385268+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T05:00:00+00:00 TriggerDagRunOperator 2023-04-02T06:41:41.651557+00:00 2023-04-02T06:41:42.176242+00:00 0:00:00.524685 362813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T06:41:38.816605+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T05:00:00+00:00 TriggerDagRunOperator 2023-04-02T06:41:41.498629+00:00 2023-04-02T06:41:41.951048+00:00 0:00:00.452419 362812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T06:41:38.816646+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T05:00:00+00:00 EmrJobFlowSensor 2023-04-02T06:31:34.117147+00:00 2023-04-02T06:41:35.782903+00:00 0:10:01.665756 362809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T06:31:31.926943+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T05:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T06:31:14.252837+00:00 2023-04-02T06:31:15.167240+00:00 0:00:00.914403 362806 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T06:31:11.908750+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T05:00:00+00:00 PythonOperator 2023-04-02T06:30:53.431794+00:00 2023-04-02T06:30:56.591240+00:00 0:00:03.159446 362803 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T06:30:49.859621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T04:00:00+00:00 TriggerDagRunOperator 2023-04-02T05:33:53.481785+00:00 2023-04-02T05:33:53.954356+00:00 0:00:00.472571 362795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T05:33:50.665652+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-02T04:00:00+00:00 TriggerDagRunOperator 2023-04-02T05:33:53.346680+00:00 2023-04-02T05:33:53.897492+00:00 0:00:00.550812 362794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T05:33:50.665679+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-02T04:00:00+00:00 EmrJobFlowSensor 2023-04-02T05:07:17.139878+00:00 2023-04-02T05:17:18.932826+00:00 0:10:01.792948 362791 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-02T05:07:14.539508+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-02T04:00:00+00:00 EmrCreateJobFlowOperator 2023-04-02T05:06:56.702949+00:00 2023-04-02T05:06:57.580471+00:00 0:00:00.877522 362787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-02T05:06:54.477503+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-02T04:00:00+00:00 PythonOperator 2023-04-02T05:06:35.037850+00:00 2023-04-02T05:06:39.172375+00:00 0:00:04.134525 362785 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-02T05:06:32.456453+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T03:00:00+00:00 TriggerDagRunOperator 2023-04-02T04:21:29.180273+00:00 2023-04-02T04:21:29.706550+00:00 0:00:00.526277 362774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-02T04:21:26.311044+00:00 2 default_pool