Revert defaulting worker id

apache · Dec 23, 2024 · 3636a3c · 3636a3c
1 parent 33df29b
commit 3636a3c
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/sdks/python/apache_beam/runners/worker/worker_id_interceptor.py b/sdks/python/apache_beam/runners/worker/worker_id_interceptor.py
@@ -39,9 +39,6 @@ class WorkerIdInterceptor(grpc.UnaryUnaryClientInterceptor,
   # the corresponding container changes.
   # Unique worker Id for this worker.
   _worker_id = os.environ.get('WORKER_ID')
-  if not _worker_id:
-    import uuid
-    _worker_id = str(uuid.uuid4())
 
   def __init__(self, worker_id: Optional[str] = None) -> None:
     if worker_id: