Fix RPC issue in frontend

This commit is contained in:
doctorpangloss 2024-02-15 21:54:13 -08:00
parent cd54bf3b3d
commit a62f2c00ed

View File

@ -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)