We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e94ad43 commit 3fb90dbCopy full SHA for 3fb90db
git_hg_sync/pulse_worker.py
@@ -55,6 +55,9 @@ def get_consumers(
55
self.task_queue,
56
auto_declare=False,
57
callbacks=[self.on_task],
58
+ # We only fetch one message at a time in case processing it fails.
59
+ # This allows us to ensure strict ordering, by re-receiving the same message
60
+ # on the next loop after having requeued it after failure.
61
prefetch_count=1,
62
)
63
logger.debug(f"Using consumer {consumer=}")
0 commit comments