Add worker_id attribute

apache · Dec 27, 2024 · ed45658 · ed45658
1 parent 9c85c73
commit ed45658
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/sdks/python/apache_beam/runners/worker/sdk_worker.py b/sdks/python/apache_beam/runners/worker/sdk_worker.py
@@ -900,6 +900,7 @@ def __init__(self, state_cache, worker_id, credentials=None):
     self._throwing_state_handler = ThrowingStateHandler()
     self._credentials = credentials
     self._state_cache = state_cache
+    self._worker_id = worker_id
 
   def create_state_handler(self, api_service_descriptor):
     # type: (endpoints_pb2.ApiServiceDescriptor) -> CachingStateHandler