Skip to content

Commit

Permalink
Lint
Browse files Browse the repository at this point in the history
  • Loading branch information
damccorm committed Apr 11, 2023
1 parent 41942f4 commit 1a6fc7c
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion sdks/python/apache_beam/utils/multi_process_shared.py
Original file line number Diff line number Diff line change
Expand Up @@ -203,7 +203,8 @@ def _get_manager(self):
address = fin.read()
logging.info('Connecting to remote proxy at %s', address)
host, port = address.split(':')
# We need to be able to authenticate with both the manager and the process.
# We need to be able to authenticate with both the manager and
# the process.
manager = _SingletonRegistrar(
address=(host, int(port)), authkey=AUTH_KEY)
multiprocessing.current_process().authkey = AUTH_KEY
Expand Down

0 comments on commit 1a6fc7c

Please sign in to comment.