Morry98 / fastapi-task-manager

97%

push

github

Fix/redis flushall issue (#13)

* 🐛 **Consumer group loss after `FLUSHALL`**: `FLUSHALL` at runtime
deletes all stream consumer groups. The Coordinator recreates streams
via `XADD`, but `xreadgroup` kept throwing `NOGROUP` on every iteration.
Catch `NOGROUP` in `_try_read_stream` and call `setup_consumer_groups()`
to recover; the Reconciler republishes any tasks queued before the group
was restored.

* 🐛 **False "Task failed" after flush**: When a task finishes while the
consumer group is gone, `xack` throws `NOGROUP`. The generic handler in
`_execute_and_ack` was catching this, logging "Task failed", and
applying backoff on a task that actually succeeded. Catch `NOGROUP` in
`_ack_message` and log a warning instead — the message is already gone
from the PEL.

6 of 15 new or added lines in 1 file covered. (40.0%)

3358 of 3456 relevant lines covered (97.16%)

4.83 hits per line