File tree Expand file tree Collapse file tree 1 file changed +8
-3
lines changed
src/sentry/workflow_engine Expand file tree Collapse file tree 1 file changed +8
-3
lines changed Original file line number Diff line number Diff line change 2
2
from sentry .silo .base import SiloMode
3
3
from sentry .tasks .base import instrumented_task
4
4
from sentry .taskworker import config , namespaces , retry
5
+ from sentry .utils import metrics
5
6
6
7
7
8
@instrumented_task (
@@ -31,7 +32,9 @@ def process_workflow_task(activity_id: int) -> None:
31
32
The task will get the Activity from the database, create a WorkflowEventData object,
32
33
and then process the data in `process_workflows`.
33
34
"""
34
- # TODO implement this in a follow-up PR. This update will require a lot of updates...
35
+ # TODO - @saponifi3d - implement this in a follow-up PR. This update will require WorkflowEventData
36
+ # to allow for an activity in the `event` attribute. That refactor is a bit noisy
37
+ # and will be done in a subsequent pr.
35
38
pass
36
39
37
40
@@ -43,6 +46,8 @@ def workflow_status_update_handler(activity: Activity) -> None:
43
46
Since this handler is called in process for the activity, we want
44
47
to queue a task to process workflows asynchronously.
45
48
"""
46
- # TODO implement this in a follow-up PR.
49
+ # TODO - implement in follow-up PR for now, just track a metric that we are seeing the activities.
50
+ metrics .incr (
51
+ "workflow_engine.process_workflow.activity_update" , tags = {"activity_type" : activity .type }
52
+ )
47
53
# process_workflow_task.delay(activity.id)
48
- pass
You can’t perform that action at this time.
0 commit comments