From 381cceefe1b8f7bd5a2cafa671c7156d89676bbf Mon Sep 17 00:00:00 2001 From: Staci Mullins <63313398+stacimc@users.noreply.github.com> Date: Tue, 29 Oct 2024 09:26:03 -0700 Subject: [PATCH] Remove logic to change port to 8002 for prod data refresh. We'll instead change the port in prod to match local (#5111) --- catalog/dags/data_refresh/distributed_reindex.py | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/catalog/dags/data_refresh/distributed_reindex.py b/catalog/dags/data_refresh/distributed_reindex.py index a9fab139567..5accf63ceb5 100644 --- a/catalog/dags/data_refresh/distributed_reindex.py +++ b/catalog/dags/data_refresh/distributed_reindex.py @@ -261,15 +261,9 @@ def create_connection( """ worker_conn_id = f"indexer_worker_{instance_id or media_type}" - # TODO: Locally we use 8003 to avoid collision with the legacy indexer worker that's - # part of the ingestion server. When the ingestion server and legacy data refresh are - # removed, we should modify the local environment to use 8002 here as well and - # avoid having to do this check. - port = "8003" if environment != PRODUCTION else "8002" - # Create the Connection logger.info(f"Creating connection with id {worker_conn_id}") - worker_conn = Connection(conn_id=worker_conn_id, uri=f"http://{server}:{port}/") + worker_conn = Connection(conn_id=worker_conn_id, uri=f"http://{server}:8003/") session = settings.Session() session.add(worker_conn) session.commit()