#NEWLINE# def add_connection( self , address ) : #NEWLINE# #INDENT# 'Connect to the worker at ``address``. Worker invocations will be round robin load balanced between all connected workers.' #NEWLINE# with self . __connection_lock : #NEWLINE# #INDENT# self . active_connections . add ( self ) #NEWLINE# self . __update_addresses ( )