Fix bedrock: (#331)

- Fix missing await
- Fix missing error response
This commit is contained in:
cybermaggedon 2025-03-27 15:17:08 +00:00 committed by GitHub
parent 8efc3b281d
commit 57663742e6
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

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