b98f36bb59333812f16eabb417258b41dedfec2c,src/syft/core/nodes/abstract/worker.py,Worker,recv_msg,#Worker#Any#,45

Before Change

    def recv_msg(self, msg: SyftMessage) -> SyftMessage:

        try:
            return self.msg_router[type(msg)].process(worker=self, msg=msg)
        except KeyError as e:
            if type(msg) not in self.msg_router:
                raise KeyError(
                    f"The worker {self.id} of type {type(self)} cannot process messages of type "

After Change

    def recv_msg(self, msg: SyftMessage) -> SyftMessage:

        try:
            processed = self.msg_router[type(msg)].process(worker=self, msg=msg)
        except KeyError as e:
            if type(msg) not in self.msg_router:
                raise KeyError(
                    f"The worker {self.id} of type {type(self)} cannot process messages of type "

Instances