From a62f2c00edf14da258021475232a0ea8845f9af0 Mon Sep 17 00:00:00 2001 From: doctorpangloss <@hiddenswitch.com> Date: Thu, 15 Feb 2024 21:54:13 -0800 Subject: [PATCH] Fix RPC issue in frontend --- comfy/distributed/distributed_prompt_queue.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/comfy/distributed/distributed_prompt_queue.py b/comfy/distributed/distributed_prompt_queue.py index 91613db00..ad9a19fde 100644 --- a/comfy/distributed/distributed_prompt_queue.py +++ b/comfy/distributed/distributed_prompt_queue.py @@ -273,7 +273,7 @@ class DistributedPromptQueue(AbstractPromptQueue): return self._connection = await connect_robust(self._connection_uri, loop=self._loop) self._channel = await self._connection.channel() - self._rpc = await JsonRPC.create(channel=self._channel) + self._rpc = await JsonRPC.create(channel=self._channel, auto_delete=True, durable=False, exclusive=True) self._rpc.host_exceptions = True if self._is_caller: self._caller_progress_handlers = ProgressHandlers(self._rpc, self._caller_server, self._queue_name)