Skip to content

Commit

Permalink
add logs
Browse files Browse the repository at this point in the history
  • Loading branch information
tvalentyn committed Dec 18, 2024
1 parent 449d648 commit cb664db
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions sdks/python/apache_beam/runners/worker/sdk_worker.py
Original file line number Diff line number Diff line change
Expand Up @@ -245,6 +245,7 @@ def default_factory(id):
self._responses = queue.Queue(
) # type: queue.Queue[Union[beam_fn_api_pb2.InstructionResponse, Sentinel]]
_LOGGER.info('Initializing SDKHarness with unbounded number of workers.')
_LOGGER.info('@@@' + str(GRPCChannelFactory.DEFAULT_OPTIONS))

def run(self):
# type: () -> None
Expand Down

0 comments on commit cb664db

Please sign in to comment.