File tree Expand file tree Collapse file tree 1 file changed +0
-9
lines changed
src/sentry/workflow_engine/processors Expand file tree Collapse file tree 1 file changed +0
-9
lines changed Original file line number Diff line number Diff line change 1
1
from dataclasses import asdict , dataclass , replace
2
2
from datetime import datetime
3
- from datetime import timezone as tz
4
3
from enum import StrEnum
5
4
from typing import DefaultDict
6
5
@@ -130,18 +129,10 @@ def enqueue_workflows(
130
129
key = WORKFLOW_ENGINE_BUFFER_LIST_KEY , value = list (items_by_project_id .keys ())
131
130
)
132
131
133
- buffer_project_ids = buffer .backend .get_sorted_set (
134
- WORKFLOW_ENGINE_BUFFER_LIST_KEY , min = 0 , max = datetime .now (tz = tz .utc ).timestamp ()
135
- )
136
- log_str = ", " .join (
137
- f"{ project_id } : { timestamp } " for project_id , timestamp in buffer_project_ids
138
- )
139
-
140
132
logger .debug (
141
133
"workflow_engine.workflows.enqueued" ,
142
134
extra = {
143
135
"project_to_workflow" : project_to_workflow ,
144
- "buffer_project_ids" : log_str ,
145
136
},
146
137
)
147
138
You can’t perform that action at this time.
0 commit comments