|
1 | 1 | from sentry.taskworker.registry import taskregistry
|
2 | 2 |
|
3 | 3 | # Namespaces for taskworker tasks
|
4 |
| -alerts_tasks = taskregistry.create_namespace("alerts", app_feature="shared") |
| 4 | +alerts_tasks = taskregistry.create_namespace( |
| 5 | + "alerts", |
| 6 | + app_feature="shared", |
| 7 | +) |
5 | 8 |
|
6 | 9 | attachments_tasks = taskregistry.create_namespace(
|
7 | 10 | "attachments",
|
8 | 11 | app_feature="attachments",
|
9 | 12 | )
|
10 | 13 |
|
11 |
| -auth_tasks = taskregistry.create_namespace("auth", app_feature="shared") |
| 14 | +auth_tasks = taskregistry.create_namespace( |
| 15 | + "auth", |
| 16 | + app_feature="shared", |
| 17 | +) |
12 | 18 |
|
13 | 19 | auth_control_tasks = taskregistry.create_namespace(
|
14 | 20 | "auth.control",
|
15 | 21 | app_feature="shared",
|
16 | 22 | )
|
17 | 23 |
|
18 |
| -buffer_tasks = taskregistry.create_namespace("buffer", app_feature="errors") |
| 24 | +buffer_tasks = taskregistry.create_namespace( |
| 25 | + "buffer", |
| 26 | + app_feature="errors", |
| 27 | +) |
19 | 28 |
|
20 |
| -crons_tasks = taskregistry.create_namespace("crons", app_feature="crons") |
| 29 | +crons_tasks = taskregistry.create_namespace( |
| 30 | + "crons", |
| 31 | + app_feature="crons", |
| 32 | +) |
21 | 33 |
|
22 | 34 | deletion_tasks = taskregistry.create_namespace(
|
23 | 35 | "deletions",
|
|
32 | 44 | app_feature="shared",
|
33 | 45 | )
|
34 | 46 |
|
35 |
| -demomode_tasks = taskregistry.create_namespace("demomode", app_feature="shared") |
| 47 | +demomode_tasks = taskregistry.create_namespace( |
| 48 | + "demomode", |
| 49 | + app_feature="shared", |
| 50 | +) |
36 | 51 |
|
37 | 52 | ai_agent_monitoring_tasks = taskregistry.create_namespace(
|
38 |
| - "ai_agent_monitoring", app_feature="ai_agent_monitoring" |
| 53 | + "ai_agent_monitoring", |
| 54 | + app_feature="ai_agent_monitoring", |
39 | 55 | )
|
40 | 56 |
|
41 |
| -digests_tasks = taskregistry.create_namespace("digests", app_feature="shared") |
| 57 | +digests_tasks = taskregistry.create_namespace( |
| 58 | + "digests", |
| 59 | + app_feature="shared", |
| 60 | +) |
42 | 61 |
|
43 | 62 | export_tasks = taskregistry.create_namespace(
|
44 | 63 | name="export",
|
|
67 | 86 | )
|
68 | 87 |
|
69 | 88 | ingest_attachments_tasks = taskregistry.create_namespace(
|
70 |
| - "ingest.attachments", app_feature="attachments" |
| 89 | + "ingest.attachments", |
| 90 | + app_feature="attachments", |
71 | 91 | )
|
72 | 92 |
|
73 |
| -ingest_errors_tasks = taskregistry.create_namespace("ingest.errors", app_feature="errors") |
| 93 | +ingest_errors_tasks = taskregistry.create_namespace( |
| 94 | + "ingest.errors", |
| 95 | + app_feature="errors", |
| 96 | +) |
74 | 97 |
|
75 | 98 | ingest_errors_postprocess_tasks = taskregistry.create_namespace(
|
76 |
| - "ingest.errors.postprocess", app_feature="errors" |
| 99 | + "ingest.errors.postprocess", |
| 100 | + app_feature="errors", |
77 | 101 | )
|
78 | 102 |
|
79 |
| -issues_tasks = taskregistry.create_namespace("issues", app_feature="issueplatform") |
| 103 | +issues_tasks = taskregistry.create_namespace( |
| 104 | + "issues", |
| 105 | + app_feature="issueplatform", |
| 106 | +) |
80 | 107 |
|
81 |
| -integrations_tasks = taskregistry.create_namespace("integrations", app_feature="integrations") |
| 108 | +integrations_tasks = taskregistry.create_namespace( |
| 109 | + "integrations", |
| 110 | + app_feature="integrations", |
| 111 | +) |
82 | 112 |
|
83 | 113 | integrations_control_tasks = taskregistry.create_namespace(
|
84 | 114 | "integrations.control",
|
85 | 115 | app_feature="integrations",
|
86 | 116 | )
|
87 | 117 |
|
88 |
| -notifications_tasks = taskregistry.create_namespace("notifications", app_feature="shared") |
| 118 | +notifications_tasks = taskregistry.create_namespace( |
| 119 | + "notifications", |
| 120 | + app_feature="shared", |
| 121 | +) |
89 | 122 |
|
90 | 123 | notifications_control_tasks = taskregistry.create_namespace(
|
91 | 124 | "notifications.control",
|
92 | 125 | app_feature="shared",
|
93 | 126 | )
|
94 | 127 |
|
95 |
| -options_tasks = taskregistry.create_namespace("options", app_feature="shared") |
| 128 | +options_tasks = taskregistry.create_namespace( |
| 129 | + "options", |
| 130 | + app_feature="shared", |
| 131 | +) |
96 | 132 |
|
97 | 133 | options_control_tasks = taskregistry.create_namespace(
|
98 | 134 | "options.control",
|
99 | 135 | app_feature="shared",
|
100 | 136 | )
|
101 | 137 |
|
102 |
| -performance_tasks = taskregistry.create_namespace("performance", app_feature="transactions") |
| 138 | +performance_tasks = taskregistry.create_namespace( |
| 139 | + "performance", |
| 140 | + app_feature="transactions", |
| 141 | +) |
103 | 142 |
|
104 |
| -profiling_tasks = taskregistry.create_namespace("profiling", app_feature="profiles") |
| 143 | +profiling_tasks = taskregistry.create_namespace( |
| 144 | + "profiling", |
| 145 | + app_feature="profiles", |
| 146 | +) |
105 | 147 |
|
106 |
| -relay_tasks = taskregistry.create_namespace("relay", app_feature="shared") |
| 148 | +relay_tasks = taskregistry.create_namespace( |
| 149 | + "relay", |
| 150 | + app_feature="shared", |
| 151 | +) |
107 | 152 |
|
108 |
| -relocation_tasks = taskregistry.create_namespace("relocation", app_feature="infra") |
| 153 | +relocation_tasks = taskregistry.create_namespace( |
| 154 | + "relocation", |
| 155 | + app_feature="infra", |
| 156 | +) |
109 | 157 |
|
110 |
| -relocation_control_tasks = taskregistry.create_namespace("relocation.control", app_feature="infra") |
| 158 | +relocation_control_tasks = taskregistry.create_namespace( |
| 159 | + "relocation.control", |
| 160 | + app_feature="infra", |
| 161 | +) |
111 | 162 |
|
112 |
| -release_health_tasks = taskregistry.create_namespace("releasehealth", app_feature="sessions") |
| 163 | +release_health_tasks = taskregistry.create_namespace( |
| 164 | + "releasehealth", |
| 165 | + app_feature="sessions", |
| 166 | +) |
113 | 167 |
|
114 |
| -replays_tasks = taskregistry.create_namespace("replays", app_feature="replays") |
| 168 | +replays_tasks = taskregistry.create_namespace( |
| 169 | + "replays", |
| 170 | + app_feature="replays", |
| 171 | +) |
115 | 172 |
|
116 |
| -reports_tasks = taskregistry.create_namespace("reports", app_feature="shared") |
| 173 | +reports_tasks = taskregistry.create_namespace( |
| 174 | + "reports", |
| 175 | + app_feature="shared", |
| 176 | +) |
117 | 177 |
|
118 |
| -sdk_tasks = taskregistry.create_namespace("sdk", app_feature="shared") |
| 178 | +sdk_tasks = taskregistry.create_namespace( |
| 179 | + "sdk", |
| 180 | + app_feature="shared", |
| 181 | +) |
119 | 182 |
|
120 |
| -sdk_control_tasks = taskregistry.create_namespace("sdk.control", app_feature="shared") |
| 183 | +sdk_control_tasks = taskregistry.create_namespace( |
| 184 | + "sdk.control", |
| 185 | + app_feature="shared", |
| 186 | +) |
121 | 187 |
|
122 |
| -seer_tasks = taskregistry.create_namespace("seer", app_feature="errors") |
| 188 | +seer_tasks = taskregistry.create_namespace( |
| 189 | + "seer", |
| 190 | + app_feature="errors", |
| 191 | +) |
123 | 192 |
|
124 |
| -selfhosted_tasks = taskregistry.create_namespace("selfhosted", app_feature="shared") |
| 193 | +selfhosted_tasks = taskregistry.create_namespace( |
| 194 | + "selfhosted", |
| 195 | + app_feature="shared", |
| 196 | +) |
125 | 197 |
|
126 |
| -sentryapp_tasks = taskregistry.create_namespace("sentryapp", app_feature="integrations") |
| 198 | +sentryapp_tasks = taskregistry.create_namespace( |
| 199 | + "sentryapp", |
| 200 | + app_feature="integrations", |
| 201 | +) |
127 | 202 |
|
128 | 203 | sentryapp_control_tasks = taskregistry.create_namespace(
|
129 |
| - "sentryapp.control", app_feature="integrations" |
| 204 | + "sentryapp.control", |
| 205 | + app_feature="integrations", |
130 | 206 | )
|
131 | 207 |
|
132 |
| -symbolication_tasks = taskregistry.create_namespace("symbolication", app_feature="errors") |
| 208 | +symbolication_tasks = taskregistry.create_namespace( |
| 209 | + "symbolication", |
| 210 | + app_feature="errors", |
| 211 | +) |
133 | 212 |
|
134 | 213 | telemetry_experience_tasks = taskregistry.create_namespace(
|
135 |
| - "telemetry-experience", app_feature="transactions" |
| 214 | + "telemetry-experience", |
| 215 | + app_feature="transactions", |
136 | 216 | )
|
137 | 217 |
|
138 |
| -tempest_tasks = taskregistry.create_namespace("tempest", app_feature="errors") |
| 218 | +tempest_tasks = taskregistry.create_namespace( |
| 219 | + "tempest", |
| 220 | + app_feature="errors", |
| 221 | +) |
139 | 222 |
|
140 |
| -uptime_tasks = taskregistry.create_namespace("uptime", app_feature="crons") |
| 223 | +uptime_tasks = taskregistry.create_namespace( |
| 224 | + "uptime", |
| 225 | + app_feature="crons", |
| 226 | +) |
141 | 227 |
|
142 | 228 | workflow_engine_tasks = taskregistry.create_namespace(
|
143 |
| - "workflow_engine", app_feature="workflow_engine" |
| 229 | + "workflow_engine", |
| 230 | + app_feature="workflow_engine", |
144 | 231 | )
|
145 | 232 |
|
146 | 233 |
|
|
0 commit comments