2fd487bb253f2a634e25925f2d1b3e357c0c7b1d,sos/sos_executor.py,SoS_Worker,run_workflow,#SoS_Worker#Any#Any#Any#Any#Any#Any#Any#,127

Before Change

        pipe.send(
            {"__workflow_id__": workflow_id
            })
        

    def run_step(self, section, context, shared, run_mode, sig_mode, verbosity, pipe):

After Change

            pipe.send(res)
        else:
            res["__workflow_id__"] =  workflow_id
            pipe.send(res)
        

    def run_step(self, section, context, shared, run_mode, sig_mode, verbosity, pipe):
        self.reset_dict()

Instances