Skip to content

Commit cee7e25

Browse files
Shutdown SharedMemoryManager in 'run()'
1 parent 7b6a720 commit cee7e25

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

scheduler/Scheduler.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -258,6 +258,8 @@ async def run(self) -> Union[List[Tuple], List[Any]]:
258258
self._sanitise_output()
259259
self.finished = True
260260

261+
self._shutdown()
262+
261263
return self.output
262264

263265
def run_blocking(self) -> Union[List[Tuple], List[Any]]:

0 commit comments

Comments
 (0)