83afd0a83b743f962a6d3f7f46cf63816f4faff6,src/sos/workflow_executor.py,Base_Executor,run_as_master,#Base_Executor#Any#Any#,965

Before Change

                        continue

                    // echck if there is any message from the socket
                    if not proc.socket.poll(0):
                        continue

                    // receieve something from the pipe
                    res = proc.socket.recv_pyobj()
                    runnable = proc.step
                    // if this is NOT a result, rather some request for task, step, workflow etc
                    if isinstance(res, list):

After Change

                    // echck if there is any message from the socket
                    if not proc.socket.poll(0):
                        if proc.is_alive():
                            continue
                        else:
                            raise RuntimeError("Worker seems to have died.")
                    else:
                        proc.mark_alive()

                    // receieve something from the pipe

Instances