diff --git a/fedn/network/combiner/hooks/grpc_wrappers.py b/fedn/network/combiner/hooks/grpc_wrappers.py index 0aff6b371..b288ff8cb 100644 --- a/fedn/network/combiner/hooks/grpc_wrappers.py +++ b/fedn/network/combiner/hooks/grpc_wrappers.py @@ -26,6 +26,7 @@ def wrapper(self, request, context): try: yield from fn(self, request, context) except Exception as e: + self.client_updates = {} self._retire_and_log(func_name, e) # Option B for streaming: signal an RPC error the client understands context.set_code(grpc.StatusCode.FAILED_PRECONDITION)