We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5792c43 commit f93bd12Copy full SHA for f93bd12
megatron/core/inference/engines/dynamic_engine.py
@@ -303,7 +303,7 @@ async def start_listening_to_data_parallel_coordinator(
303
304
# Todo [Siddharth]: can we move this code to another file?
305
self.zmq_context = zmq.Context()
306
- self.zmq_sockets = [] # keep track of all sockets created by this engine
+ self.zmq_sockets = [] # keep track of all sockets created by this engine.
307
ip_address_of_dp_coordinator = os.getenv('MASTER_ADDR', '127.0.0.1')
308
identity = f'tp-coord-{parallel_state.get_data_parallel_rank()}'
309
if (
0 commit comments