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()