async def METHOD_NAME(
    node_id: NodeId, reader: WaitableCallback
) -> None:
    """Wait for response to update complete."""
    async for response, arbitration_id in reader:
        if arbitration_id.parts.originating_node_id == node_id:
            if isinstance(
                response, message_definitions.FirmwareUpdateCompleteAcknowledge
            ):
                if response.payload.error_code.value != ErrorCode.ok:
                    raise ErrorResponse(response, node_id)
                break