Skip to content

Commit 309a41f

Browse files
authored
🔧 chore(aci): retry action and activity tasks (#95355)
1 parent 56b1d54 commit 309a41f

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

src/sentry/workflow_engine/tasks/actions.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
from sentry.eventstream.base import GroupState
55
from sentry.models.activity import Activity
66
from sentry.silo.base import SiloMode
7-
from sentry.tasks.base import instrumented_task
7+
from sentry.tasks.base import instrumented_task, retry
88
from sentry.taskworker import config, namespaces
99
from sentry.taskworker.retry import Retry
1010
from sentry.utils import metrics
@@ -61,6 +61,7 @@ def build_trigger_action_task_params(action, detector, event_data: WorkflowEvent
6161
),
6262
),
6363
)
64+
@retry
6465
def trigger_action(
6566
action_id: int,
6667
detector_id: int,

src/sentry/workflow_engine/tasks/workflows.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@
4141
),
4242
),
4343
)
44+
@retry
4445
def process_workflow_activity(activity_id: int, group_id: int, detector_id: int) -> None:
4546
"""
4647
Process a workflow task identified by the given activity, group, and detector.

0 commit comments

Comments
 (0)