Skip to content

Commit 07a4efb

Browse files
authored
Remove unused timeout parameter from ZMQ router (#3799)
This was used as part of the exit behaviour for UDP part of the monitoring router, from before PR #3796 router split. # Changed Behaviour none ## Type of change - Code maintenance/cleanup
1 parent 5e5c607 commit 07a4efb

File tree

1 file changed

+0
-4
lines changed

1 file changed

+0
-4
lines changed

parsl/monitoring/radios/zmq_router.py

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@ def __init__(self,
2828

2929
run_dir: str = ".",
3030
logging_level: int = logging.INFO,
31-
atexit_timeout: int = 3, # in seconds
3231
resource_msgs: mpq.Queue,
3332
exit_event: Event,
3433
):
@@ -45,8 +44,6 @@ def __init__(self,
4544
Parsl log directory paths. Logs and temp files go here. Default: '.'
4645
logging_level : int
4746
Logging level as defined in the logging module. Default: logging.INFO
48-
atexit_timeout : float, optional
49-
The amount of time in seconds to terminate the hub without receiving any messages, after the last dfk workflow message is received.
5047
resource_msgs : multiprocessing.Queue
5148
A multiprocessing queue to receive messages to be routed onwards to the database process
5249
exit_event : Event
@@ -59,7 +56,6 @@ def __init__(self,
5956
self.logger.debug("Monitoring router starting")
6057

6158
self.hub_address = hub_address
62-
self.atexit_timeout = atexit_timeout
6359

6460
self.loop_freq = 10.0 # milliseconds
6561

0 commit comments

Comments
 (0)