From cd54bf3b3d216a9013d4074e2acf79975ef0a93f Mon Sep 17 00:00:00 2001 From: doctorpangloss <@hiddenswitch.com> Date: Thu, 15 Feb 2024 20:28:11 -0800 Subject: [PATCH] Tweak worker RPC creation --- comfy/distributed/distributed_prompt_worker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/comfy/distributed/distributed_prompt_worker.py b/comfy/distributed/distributed_prompt_worker.py index e37043353..9b6e091d5 100644 --- a/comfy/distributed/distributed_prompt_worker.py +++ b/comfy/distributed/distributed_prompt_worker.py @@ -64,7 +64,7 @@ class DistributedPromptWorker: logging.error(f"failed to connect to self._connection_uri={self._connection_uri}", connection_error) raise connection_error 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._embedded_comfy_client is None: