Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Karton already supports debug mode, but sometimes you need to works with already "unwealthy" tasks that crashed.
Restarting them is not an option - you cannot predict which consumer will get this task, while you need to feed this task to exact consumer you run under debugger / with extra prints / etc. The goal is to debug crashed task without interrupting the processing.
This PR introduces new method,
Consumer.loop_crached_tasks
that gradually makes debugging process more easy by working only with crashed tasks. It has several restrictions:karton.tasks
instead ofkarton.queue
list in redis.CRASHED
metrics on further crashes.STARTED
.