Fix bedrock:

- Fix missing await
- Fix missing error response
This commit is contained in:
Cyber MacGeddon 2025-03-27 15:15:58 +00:00
parent 8efc3b281d
commit 4df9d1c32d

View file

@ -302,7 +302,7 @@ class Processor(ConsumerProducer):
model=str(self.model),
)
self.send(r, properties={"id": id})
await self.send(r, properties={"id": id})
print("Done.", flush=True)
@ -333,6 +333,8 @@ class Processor(ConsumerProducer):
model=None,
)
await self.send(r, properties={"id": id})
self.consumer.acknowledge(msg)
@staticmethod