Skip to content

Commit 386b9c2

Browse files
gmrclaude
andcommitted
Move schema_uri_format to top-level consumer config
It's a framework concern, not an application setting, so it belongs alongside sentry_dsn, queue, qos_prefetch etc. rather than inside the config: sub-section. Config change: # Before config: schema_uri_format: file:///etc/schemas/{0}.avsc # After schema_uri_format: file:///etc/schemas/{0}.avsc Added schema_uri_format: str | None to ConsumerConfig. Consumer reads it via self._process.consumer_config.schema_uri_format. Co-Authored-By: Claude Sonnet 4.6 (1M context) <noreply@anthropic.com>
1 parent ee073fa commit 386b9c2

2 files changed

Lines changed: 6 additions & 1 deletion

File tree

rejected/config.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,7 @@ class ConsumerConfig(pydantic.BaseModel):
5959
qos_prefetch: int = 1
6060
max_errors: int = 5
6161
error_exchange: str | None = None
62+
schema_uri_format: str | None = None
6263
sentry_dsn: str | None = None
6364
drop_exchange: str | None = None
6465
drop_invalid_messages: bool | None = None

rejected/consumer.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1590,7 +1590,11 @@ def _load_avro_schema(self, message_type: str) -> dict:
15901590
and this method has not been overridden
15911591
15921592
"""
1593-
uri_format = self.settings.get('schema_uri_format')
1593+
uri_format = (
1594+
self._process.consumer_config.schema_uri_format
1595+
if self._process
1596+
else None
1597+
)
15941598
if not uri_format:
15951599
raise NotImplementedError(
15961600
'Set schema_uri_format in consumer config or override '

0 commit comments

Comments
 (0)