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_cluster_and_add_emr_steps 2023-05-11T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T15:14:18.231183+00:00 2023-05-11T15:14:19.036288+00:00 0:00:00.805105 377272 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T15:14:15.942433+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T14:00:00+00:00 PythonOperator 2023-05-11T15:13:56.712531+00:00 2023-05-11T15:13:57.680733+00:00 0:00:00.968202 377269 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T15:13:53.975517+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T13:00:00+00:00 TriggerDagRunOperator 2023-05-11T14:16:35.271588+00:00 2023-05-11T14:16:35.720311+00:00 0:00:00.448723 377259 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T14:16:32.592529+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T13:00:00+00:00 TriggerDagRunOperator 2023-05-11T14:16:35.217486+00:00 2023-05-11T14:16:35.571058+00:00 0:00:00.353572 377258 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T14:16:32.592563+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T13:00:00+00:00 EmrJobFlowSensor 2023-05-11T14:04:03.417957+00:00 2023-05-11T14:14:05.332608+00:00 0:10:01.914651 377251 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T14:04:01.200700+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T14:03:44.140062+00:00 2023-05-11T14:03:44.947755+00:00 0:00:00.807693 377250 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T14:03:41.158568+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T13:00:00+00:00 PythonOperator 2023-05-11T14:03:22.046325+00:00 2023-05-11T14:03:23.785782+00:00 0:00:01.739457 377247 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T14:03:19.139336+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T12:00:00+00:00 TriggerDagRunOperator 2023-05-11T13:17:06.666772+00:00 2023-05-11T13:17:07.121889+00:00 0:00:00.455117 377235 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T13:17:04.416928+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T12:00:00+00:00 TriggerDagRunOperator 2023-05-11T13:17:06.608599+00:00 2023-05-11T13:17:06.941750+00:00 0:00:00.333151 377234 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T13:17:04.416959+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T12:00:00+00:00 EmrJobFlowSensor 2023-05-11T13:01:05.034413+00:00 2023-05-11T13:11:06.790774+00:00 0:10:01.756361 377230 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T13:01:02.807164+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T13:00:45.137769+00:00 2023-05-11T13:00:45.921697+00:00 0:00:00.783928 377228 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T13:00:42.798511+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T12:00:00+00:00 PythonOperator 2023-05-11T13:00:22.901790+00:00 2023-05-11T13:00:23.919973+00:00 0:00:01.018183 377226 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T13:00:20.727820+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T11:00:00+00:00 TriggerDagRunOperator 2023-05-11T12:14:27.873273+00:00 2023-05-11T12:14:28.312626+00:00 0:00:00.439353 377211 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T12:14:25.372239+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T11:00:00+00:00 TriggerDagRunOperator 2023-05-11T12:14:27.800405+00:00 2023-05-11T12:14:28.159843+00:00 0:00:00.359438 377210 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T12:14:25.372204+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T11:00:00+00:00 EmrJobFlowSensor 2023-05-11T12:00:48.892065+00:00 2023-05-11T12:11:50.893150+00:00 0:11:02.001085 377205 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T12:00:46.676299+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T12:00:26.714137+00:00 2023-05-11T12:00:27.514582+00:00 0:00:00.800445 377203 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T12:00:24.620763+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T11:00:00+00:00 PythonOperator 2023-05-11T12:00:05.224403+00:00 2023-05-11T12:00:06.224279+00:00 0:00:00.999876 377201 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T12:00:02.590170+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T10:00:00+00:00 TriggerDagRunOperator 2023-05-11T11:16:03.743844+00:00 2023-05-11T11:16:04.186554+00:00 0:00:00.442710 377189 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T11:16:00.300702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T10:00:00+00:00 TriggerDagRunOperator 2023-05-11T11:16:03.128587+00:00 2023-05-11T11:16:03.536075+00:00 0:00:00.407488 377188 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T11:16:00.300730+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T10:00:00+00:00 EmrJobFlowSensor 2023-05-11T11:05:45.374457+00:00 2023-05-11T11:15:47.556364+00:00 0:10:02.181907 377184 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T11:05:42.746129+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T11:05:25.273378+00:00 2023-05-11T11:05:26.243288+00:00 0:00:00.969910 377181 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T11:05:22.727462+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T10:00:00+00:00 PythonOperator 2023-05-11T11:05:02.951384+00:00 2023-05-11T11:05:03.994319+00:00 0:00:01.042935 377178 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T11:05:00.716405+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T09:00:00+00:00 TriggerDagRunOperator 2023-05-11T10:11:25.851490+00:00 2023-05-11T10:11:26.305724+00:00 0:00:00.454234 377163 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T10:11:23.206371+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T09:00:00+00:00 TriggerDagRunOperator 2023-05-11T10:11:25.774293+00:00 2023-05-11T10:11:26.107539+00:00 0:00:00.333246 377162 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T10:11:23.206413+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T09:00:00+00:00 EmrJobFlowSensor 2023-05-11T10:00:59.707089+00:00 2023-05-11T10:11:02.164768+00:00 0:10:02.457679 377155 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T10:00:57.183758+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T10:00:37.285406+00:00 2023-05-11T10:00:38.551098+00:00 0:00:01.265692 377153 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T10:00:35.094988+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T09:00:00+00:00 PythonOperator 2023-05-11T10:00:17.442413+00:00 2023-05-11T10:00:18.441460+00:00 0:00:00.999047 377151 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T10:00:15.077031+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T08:00:00+00:00 TriggerDagRunOperator 2023-05-11T09:13:27.672369+00:00 2023-05-11T09:13:28.113765+00:00 0:00:00.441396 377137 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T09:13:25.237625+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T08:00:00+00:00 TriggerDagRunOperator 2023-05-11T09:13:27.619442+00:00 2023-05-11T09:13:27.949710+00:00 0:00:00.330268 377136 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T09:13:25.237597+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T08:00:00+00:00 EmrJobFlowSensor 2023-05-11T09:03:04.358114+00:00 2023-05-11T09:13:06.210323+00:00 0:10:01.852209 377130 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T09:03:02.020271+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T09:02:44.062410+00:00 2023-05-11T09:02:44.910745+00:00 0:00:00.848335 377128 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T09:02:41.910546+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T08:00:00+00:00 PythonOperator 2023-05-11T09:02:23.059337+00:00 2023-05-11T09:02:24.087886+00:00 0:00:01.028549 377126 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T09:02:19.892686+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T07:00:00+00:00 TriggerDagRunOperator 2023-05-11T08:12:11.763083+00:00 2023-05-11T08:12:12.345223+00:00 0:00:00.582140 377112 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T08:12:08.002658+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T07:00:00+00:00 TriggerDagRunOperator 2023-05-11T08:12:10.857406+00:00 2023-05-11T08:12:11.216779+00:00 0:00:00.359373 377111 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T08:12:08.002687+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T07:00:00+00:00 EmrJobFlowSensor 2023-05-11T08:00:55.410285+00:00 2023-05-11T08:10:57.228579+00:00 0:10:01.818294 377103 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T08:00:53.012558+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T08:00:35.360087+00:00 2023-05-11T08:00:36.237445+00:00 0:00:00.877358 377101 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T08:00:32.994309+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T07:00:00+00:00 PythonOperator 2023-05-11T08:00:13.533367+00:00 2023-05-11T08:00:14.556462+00:00 0:00:01.023095 377099 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T08:00:10.985246+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T06:00:00+00:00 TriggerDagRunOperator 2023-05-11T07:11:32.905989+00:00 2023-05-11T07:11:33.340115+00:00 0:00:00.434126 377086 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T07:11:30.532823+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T06:00:00+00:00 TriggerDagRunOperator 2023-05-11T07:11:32.823557+00:00 2023-05-11T07:11:33.157632+00:00 0:00:00.334075 377085 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T07:11:30.532855+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T06:00:00+00:00 EmrJobFlowSensor 2023-05-11T07:01:06.252835+00:00 2023-05-11T07:11:08.088485+00:00 0:10:01.835650 377079 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T07:01:03.986786+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T07:00:44.072147+00:00 2023-05-11T07:00:44.897865+00:00 0:00:00.825718 377077 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T07:00:41.896220+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T06:00:00+00:00 PythonOperator 2023-05-11T07:00:24.697060+00:00 2023-05-11T07:00:26.576613+00:00 0:00:01.879553 377075 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T07:00:21.896761+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T05:00:00+00:00 TriggerDagRunOperator 2023-05-11T06:14:08.435632+00:00 2023-05-11T06:14:08.979381+00:00 0:00:00.543749 377061 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T06:14:05.935699+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T05:00:00+00:00 TriggerDagRunOperator 2023-05-11T06:14:08.337975+00:00 2023-05-11T06:14:08.818975+00:00 0:00:00.481000 377060 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T06:14:05.935727+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T05:00:00+00:00 EmrJobFlowSensor 2023-05-11T06:01:16.729381+00:00 2023-05-11T06:11:18.555201+00:00 0:10:01.825820 377053 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T06:01:14.404060+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T06:00:56.716953+00:00 2023-05-11T06:00:57.479017+00:00 0:00:00.762064 377051 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T06:00:54.404679+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T05:00:00+00:00 PythonOperator 2023-05-11T06:00:04.858625+00:00 2023-05-11T06:00:05.868146+00:00 0:00:01.009521 377048 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T06:00:02.293652+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T04:00:00+00:00 TriggerDagRunOperator 2023-05-11T05:25:46.756388+00:00 2023-05-11T05:25:47.083938+00:00 0:00:00.327550 377038 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T05:25:43.915519+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T04:00:00+00:00 TriggerDagRunOperator 2023-05-11T05:25:46.746376+00:00 2023-05-11T05:25:47.193115+00:00 0:00:00.446739 377037 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T05:25:43.915475+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T04:00:00+00:00 EmrJobFlowSensor 2023-05-11T05:01:11.070944+00:00 2023-05-11T05:11:12.824110+00:00 0:10:01.753166 377031 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T05:01:08.925168+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T05:00:51.169660+00:00 2023-05-11T05:00:52.146105+00:00 0:00:00.976445 377029 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T05:00:48.907692+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T04:00:00+00:00 PythonOperator 2023-05-11T05:00:29.065859+00:00 2023-05-11T05:00:30.144592+00:00 0:00:01.078733 377027 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T05:00:26.879626+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T03:00:00+00:00 TriggerDagRunOperator 2023-05-11T04:17:25.863918+00:00 2023-05-11T04:17:26.339519+00:00 0:00:00.475601 377014 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T04:17:23.326349+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T03:00:00+00:00 TriggerDagRunOperator 2023-05-11T04:17:25.819706+00:00 2023-05-11T04:17:26.166026+00:00 0:00:00.346320 377013 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T04:17:23.326312+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T03:00:00+00:00 EmrJobFlowSensor 2023-05-11T04:01:00.679191+00:00 2023-05-11T04:12:02.641239+00:00 0:11:01.962048 377005 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T04:00:58.228794+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T04:00:38.643210+00:00 2023-05-11T04:00:39.648740+00:00 0:00:01.005530 377003 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T04:00:36.109813+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T03:00:00+00:00 PythonOperator 2023-05-11T04:00:18.241939+00:00 2023-05-11T04:00:19.372515+00:00 0:00:01.130576 377001 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T04:00:16.022855+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T02:00:00+00:00 TriggerDagRunOperator 2023-05-11T03:11:55.926340+00:00 2023-05-11T03:11:56.375547+00:00 0:00:00.449207 376987 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T03:11:53.074572+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T02:00:00+00:00 TriggerDagRunOperator 2023-05-11T03:11:55.814768+00:00 2023-05-11T03:11:56.144229+00:00 0:00:00.329461 376986 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T03:11:53.074601+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T02:00:00+00:00 EmrJobFlowSensor 2023-05-11T03:00:51.728513+00:00 2023-05-11T03:10:53.510250+00:00 0:10:01.781737 376978 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T03:00:48.888748+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T03:00:29.587243+00:00 2023-05-11T03:00:30.772443+00:00 0:00:01.185200 376976 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T03:00:26.797977+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T02:00:00+00:00 PythonOperator 2023-05-11T03:00:09.090572+00:00 2023-05-11T03:00:10.176796+00:00 0:00:01.086224 376974 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T03:00:06.728132+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T01:00:00+00:00 TriggerDagRunOperator 2023-05-11T02:12:09.867260+00:00 2023-05-11T02:12:10.322520+00:00 0:00:00.455260 376961 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T02:12:07.468329+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T01:00:00+00:00 TriggerDagRunOperator 2023-05-11T02:12:09.749280+00:00 2023-05-11T02:12:10.091465+00:00 0:00:00.342185 376960 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T02:12:07.468381+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T01:00:00+00:00 EmrJobFlowSensor 2023-05-11T02:00:56.597000+00:00 2023-05-11T02:11:58.582074+00:00 0:11:01.985074 376953 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T02:00:54.366493+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T02:00:34.824836+00:00 2023-05-11T02:00:35.548042+00:00 0:00:00.723206 376951 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T02:00:32.406272+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T01:00:00+00:00 PythonOperator 2023-05-11T02:00:13.040680+00:00 2023-05-11T02:00:14.052003+00:00 0:00:01.011323 376949 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T02:00:10.387602+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T00:00:00+00:00 TriggerDagRunOperator 2023-05-11T01:11:15.415283+00:00 2023-05-11T01:11:15.930832+00:00 0:00:00.515549 376929 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T01:11:12.430548+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T00:00:00+00:00 TriggerDagRunOperator 2023-05-11T01:11:15.335829+00:00 2023-05-11T01:11:15.794441+00:00 0:00:00.458612 376928 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T01:11:12.430508+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T00:00:00+00:00 EmrJobFlowSensor 2023-05-11T01:01:01.139832+00:00 2023-05-11T01:11:03.242758+00:00 0:10:02.102926 376921 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T01:00:58.813410+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T01:00:39.223128+00:00 2023-05-11T01:00:40.043027+00:00 0:00:00.819899 376919 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T01:00:36.753793+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T00:00:00+00:00 PythonOperator 2023-05-11T01:00:17.762063+00:00 2023-05-11T01:00:18.845186+00:00 0:00:01.083123 376917 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T01:00:14.736242+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T23:00:00+00:00 TriggerDagRunOperator 2023-05-11T00:11:42.539912+00:00 2023-05-11T00:11:43.009390+00:00 0:00:00.469478 376903 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T00:11:39.890663+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T23:00:00+00:00 TriggerDagRunOperator 2023-05-11T00:11:42.309117+00:00 2023-05-11T00:11:42.676783+00:00 0:00:00.367666 376902 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T00:11:39.890618+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T23:00:00+00:00 EmrJobFlowSensor 2023-05-11T00:01:21.056702+00:00 2023-05-11T00:11:22.842704+00:00 0:10:01.786002 376896 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T00:01:18.747404+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T00:00:59.611515+00:00 2023-05-11T00:01:00.870319+00:00 0:00:01.258804 376894 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T00:00:56.729789+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T23:00:00+00:00 PythonOperator 2023-05-11T00:00:39.510627+00:00 2023-05-11T00:00:40.543038+00:00 0:00:01.032411 376891 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T00:00:36.412136+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T22:00:00+00:00 TriggerDagRunOperator 2023-05-10T23:11:11.964163+00:00 2023-05-10T23:11:12.412818+00:00 0:00:00.448655 376877 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T23:11:09.411588+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T22:00:00+00:00 TriggerDagRunOperator 2023-05-10T23:11:11.739236+00:00 2023-05-10T23:11:12.082191+00:00 0:00:00.342955 376876 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T23:11:09.411626+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T22:00:00+00:00 EmrJobFlowSensor 2023-05-10T23:00:53.810321+00:00 2023-05-10T23:10:55.605100+00:00 0:10:01.794779 376869 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T23:00:51.663283+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T23:00:34.290804+00:00 2023-05-10T23:00:35.070491+00:00 0:00:00.779687 376866 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T23:00:31.643317+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T22:00:00+00:00 PythonOperator 2023-05-10T23:00:11.746312+00:00 2023-05-10T23:00:12.754905+00:00 0:00:01.008593 376863 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T23:00:09.624213+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T21:00:00+00:00 TriggerDagRunOperator 2023-05-10T22:11:00.917756+00:00 2023-05-10T22:11:01.257113+00:00 0:00:00.339357 376847 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T22:10:58.185030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T21:00:00+00:00 TriggerDagRunOperator 2023-05-10T22:11:00.819769+00:00 2023-05-10T22:11:01.280702+00:00 0:00:00.460933 376846 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T22:10:58.185001+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T21:00:00+00:00 EmrJobFlowSensor 2023-05-10T22:00:47.626851+00:00 2023-05-10T22:10:49.436540+00:00 0:10:01.809689 376839 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T22:00:45.496793+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T22:00:26.169046+00:00 2023-05-10T22:00:27.011854+00:00 0:00:00.842808 376837 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T22:00:23.410836+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T21:00:00+00:00 PythonOperator 2023-05-10T22:00:05.640908+00:00 2023-05-10T22:00:06.678559+00:00 0:00:01.037651 376835 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T22:00:03.393268+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T20:00:00+00:00 TriggerDagRunOperator 2023-05-10T21:11:16.043641+00:00 2023-05-10T21:11:16.491311+00:00 0:00:00.447670 376821 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T21:11:13.089224+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T20:00:00+00:00 TriggerDagRunOperator 2023-05-10T21:11:15.803254+00:00 2023-05-10T21:11:16.152749+00:00 0:00:00.349495 376820 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T21:11:13.089268+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T20:00:00+00:00 EmrJobFlowSensor 2023-05-10T21:01:05.423922+00:00 2023-05-10T21:11:07.356335+00:00 0:10:01.932413 376814 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T21:01:02.582227+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T21:00:44.781183+00:00 2023-05-10T21:00:45.772411+00:00 0:00:00.991228 376812 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T21:00:42.433577+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T20:00:00+00:00 PythonOperator 2023-05-10T21:00:22.673705+00:00 2023-05-10T21:00:23.641231+00:00 0:00:00.967526 376810 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T21:00:20.444760+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T19:00:00+00:00 TriggerDagRunOperator 2023-05-10T20:11:06.088008+00:00 2023-05-10T20:11:06.551396+00:00 0:00:00.463388 376795 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T20:11:03.586259+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T19:00:00+00:00 TriggerDagRunOperator 2023-05-10T20:11:06.067096+00:00 2023-05-10T20:11:06.408760+00:00 0:00:00.341664 376794 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T20:11:03.586288+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T19:00:00+00:00 EmrJobFlowSensor 2023-05-10T20:00:54.560711+00:00 2023-05-10T20:10:56.355606+00:00 0:10:01.794895 376788 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T20:00:51.747858+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-10T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-10T20:00:33.875291+00:00 2023-05-10T20:00:34.715574+00:00 0:00:00.840283 376786 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-10T20:00:31.726935+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-10T19:00:00+00:00 PythonOperator 2023-05-10T20:00:12.355857+00:00 2023-05-10T20:00:13.539713+00:00 0:00:01.183856 376784 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-10T20:00:09.706710+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-10T18:00:00+00:00 TriggerDagRunOperator 2023-05-10T19:11:34.219846+00:00 2023-05-10T19:11:34.764278+00:00 0:00:00.544432 376766 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T19:11:31.712473+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-10T18:00:00+00:00 TriggerDagRunOperator 2023-05-10T19:11:34.085339+00:00 2023-05-10T19:11:34.423068+00:00 0:00:00.337729 376765 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-10T19:11:31.712445+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-10T18:00:00+00:00 EmrJobFlowSensor 2023-05-10T19:01:09.982829+00:00 2023-05-10T19:11:11.946005+00:00 0:10:01.963176 376758 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-10T19:01:07.629324+00:00 2 default_pool