Skip to content

Commit 6988343

Browse files
committed
Close stdin used to send config to Interchange
This was introduced in PR #3463 and at the time I incorrectly assumed that interchange exit would close both ends of the pipe. That is untrue. For example: pytest parsl/tests/test_htex/ --config local ends with 341 fds open before this PR, and 327 file descriptors open after this PR.
1 parent 2b7e7f9 commit 6988343

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

parsl/executors/high_throughput/executor.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -551,6 +551,7 @@ def _start_local_interchange_process(self) -> None:
551551
logger.debug("Popened interchange process. Writing config object")
552552
stdin.write(config_pickle)
553553
stdin.flush()
554+
stdin.close()
554555
logger.debug("Sent config object. Requesting worker ports")
555556
try:
556557
(self.worker_task_port, self.worker_result_port) = self.command_client.run("WORKER_PORTS", timeout_s=120)

0 commit comments

Comments
 (0)