Cleanly shutdown workers if session should be interrupted
As discussed in #66
This commit is contained in:
@@ -535,6 +535,7 @@ class DSession:
|
||||
while not self.session_finished:
|
||||
self.loop_once()
|
||||
if self.shouldstop:
|
||||
self.triggershutdown()
|
||||
raise Interrupted(str(self.shouldstop))
|
||||
return True
|
||||
|
||||
|
||||
Reference in New Issue
Block a user