Skip to content
This repository was archived by the owner on Feb 22, 2022. It is now read-only.

Commit 31f87d0

Browse files
committed
change explanation for sndtimeo of 0 for tasks_q
1 parent 5f92a2d commit 31f87d0

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

funcx_forwarder/forwarder.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -243,9 +243,9 @@ def initialize_endpoint_queues(self):
243243
''' Initialize the three queues over which the forwarder communicates with endpoints
244244
TaskQueue in mode='server' binds to all interfaces by default
245245
'''
246-
# SNDTIMEO for the tasks_q should be 0 because if the endpoint is unreachable
247-
# due to a network issue this will cause send calls to raise, rather than
248-
# blocking and waiting
246+
# SNDTIMEO for the tasks_q should be 0 because we do not want to allow
247+
# send blocking in the main forwarder loop (an exception will occur instead
248+
# if the send can't happen immediately)
249249
self.tasks_q = TaskQueue('127.0.0.1',
250250
port=self.tasks_port,
251251
SNDTIMEO=0,

0 commit comments

Comments
 (0)