83afd0a83b743f962a6d3f7f46cf63816f4faff6,src/sos/workflow_executor.py,ExecutionManager,terminate,#ExecutionManager#Any#,164

Before Change

                close_socket(proc.socket)
            time.sleep(0.1)
            for proc in self.procs + self.pool:
                if proc.worker and proc.worker.is_alive():
                    proc.worker.terminate()
                    proc.worker.join()
        else:
            for proc in self.procs + self.pool:
                // proc can be fake if from a nested workflow
                if proc.worker:

After Change

    def terminate(self, brutal: bool = False) -> None:
        self.cleanup()
        if self.executor_ping_socket is not None:
            close_socket(self.executor_ping_socket, "ping socket", now=True)

        if not brutal:
            for proc in self.procs + self.pool:
                proc.socket.send_pyobj(None)
                close_socket(proc.socket, now=True)

Instances