Skip to content

Commit de00695

Browse files
authored
fix(aci): Retry failures in delayed_workflow (#94470)
When there's a failure, we'd like to retry. We already exit cleanly in known terminal cases. There's a risk of runaway retries from not being specific in what we're targeting, but there's a limit to how many times we retry, and all known unhandled exceptions so far we've wanted retry for. Retry is a reasonably safe default for us.
1 parent 6ed61fa commit de00695

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/sentry/workflow_engine/processors/delayed_workflow.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@
2828
delayed_processing_registry,
2929
)
3030
from sentry.silo.base import SiloMode
31-
from sentry.tasks.base import instrumented_task
31+
from sentry.tasks.base import instrumented_task, retry
3232
from sentry.tasks.post_process import should_retry_fetch
3333
from sentry.taskworker.config import TaskworkerConfig
3434
from sentry.taskworker.namespaces import issues_tasks
@@ -675,6 +675,7 @@ def repr_keys[T, V](d: dict[T, V]) -> dict[str, V]:
675675
),
676676
),
677677
)
678+
@retry
678679
@log_context.root()
679680
def process_delayed_workflows(
680681
project_id: int, batch_key: str | None = None, *args: Any, **kwargs: Any

0 commit comments

Comments
 (0)