Merge branch 'release/v0.21'

This commit is contained in:
Cyber MacGeddon 2025-03-31 22:14:58 +01:00
commit 96e8efcf1e

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