search

taskiq-python / taskiq-redis

Broker and result backend for taskiq
MIT License
40 stars 18 forks source link

fix #65: avoid worker crash in case connection is broken #64

Closed khizunov closed 1 month ago

khizunov commented 4 months ago

The issue is that if the connection is disrupted (due to a Redis restart or temporary connectivity issues), the Taskiq worker crashes, interrupting all ongoing handlers. For example, any long-running tasks will be interrupted and will not complete their work.

khizunov commented 4 months ago

Can you please describe when this feature is required, because taskiq worker automatically restarts if anything goes wrong?

Sure, I was going to open an issue.

The issue is that if the connection is disrupted (due to a Redis restart or temporary connectivity issues), the Taskiq worker crashes, interrupting all ongoing handlers. For example, any long-running tasks will be interrupted and will not complete their work.

khizunov commented 4 months ago

@s3rius

khizunov commented 2 months ago

@s3rius did you have a chance to look at it?

s3rius commented 2 months ago

Please rebase onto main branch and we will merge it.