Signed-off-by: Robert Shaw <robshaw@redhat.com>
This commit is contained in:
Robert Shaw 2025-07-20 03:45:48 +00:00
parent 4438796b48
commit 2a68433a82

View File

@ -709,12 +709,8 @@ class AsyncMPClient(MPClient):
assert output_socket is not None
async def process_outputs_socket():
i = 0
try:
while True:
if i % 100 == 0:
logger.info(f"{i=}")
i += 1
frames = await output_socket.recv_multipart(copy=False)
resources.validate_alive(frames)
outputs: EngineCoreOutputs = decoder.decode(frames)