Skip to content

Commit fcaf6b6

Browse files
authored
feat(taskworker) Add email + cutover topics (#92312)
Refs getsentry/getsentry#17554
1 parent 4fcbc63 commit fcaf6b6

File tree

2 files changed

+6
-0
lines changed

2 files changed

+6
-0
lines changed

src/sentry/conf/server.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3155,6 +3155,9 @@ def custom_parameter_sort(parameter: dict) -> tuple[str, int]:
31553155
"taskworker-billing-dlq": "default",
31563156
"taskworker-control": "default",
31573157
"taskworker-control-dlq": "default",
3158+
"taskworker-cutover": "default",
3159+
"taskworker-email": "default",
3160+
"taskworker-email-dlq": "default",
31583161
"taskworker-ingest": "default",
31593162
"taskworker-ingest-dlq": "default",
31603163
"taskworker-ingest-errors": "default",

src/sentry/conf/types/kafka_definition.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -76,6 +76,9 @@ class Topic(Enum):
7676
TASKWORKER_BILLING_DLQ = "taskworker-billing-dlq"
7777
TASKWORKER_CONTROL = "taskworker-control"
7878
TASKWORKER_CONTROL_DLQ = "taskworker-control-dlq"
79+
TASKWORKER_CUTOVER = "taskworker-cutover"
80+
TASKWORKER_EMAIL = "taskworker-email"
81+
TASKWORKER_EMAIL_DLQ = "taskworker-email-dlq"
7982
TASKWORKER_INGEST = "taskworker-ingest"
8083
TASKWORKER_INGEST_DLQ = "taskworker-ingest-dlq"
8184
TASKWORKER_INGEST_ERRORS = "taskworker-ingest-errors"

0 commit comments

Comments
 (0)