nv_ingest.schemas.message_brokers package#
Submodules#
nv_ingest.schemas.message_brokers.request_schema module#
- class nv_ingest.schemas.message_brokers.request_schema.PopRequestSchema(
- *,
- command: str,
- queue_name: Annotated[str, MinLen(min_length=1)],
- timeout: float | None = 100,
Bases:
BaseModel- command: str#
- model_config: ClassVar[ConfigDict] = {'extra': 'forbid'}#
Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].
- queue_name: str#
- timeout: float | None#
- class nv_ingest.schemas.message_brokers.request_schema.PushRequestSchema(
- *,
- command: str,
- queue_name: Annotated[str, MinLen(min_length=1)],
- message: Annotated[str, MinLen(min_length=1)],
- timeout: float | None = 100,
Bases:
BaseModel- command: str#
- message: str#
- model_config: ClassVar[ConfigDict] = {'extra': 'forbid'}#
Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].
- queue_name: str#
- timeout: float | None#
- class nv_ingest.schemas.message_brokers.request_schema.SizeRequestSchema(
- *,
- command: str,
- queue_name: Annotated[str, MinLen(min_length=1)],
Bases:
BaseModel- command: str#
- model_config: ClassVar[ConfigDict] = {'extra': 'forbid'}#
Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].
- queue_name: str#
nv_ingest.schemas.message_brokers.response_schema module#
- class nv_ingest.schemas.message_brokers.response_schema.ResponseSchema(
- *,
- response_code: int,
- response_reason: str | None = 'OK',
- response: str | dict | None = None,
- trace_id: str | None = None,
- transaction_id: str | None = None,
Bases:
BaseModel- model_config: ClassVar[ConfigDict] = {}#
Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].
- response: str | dict | None#
- response_code: int#
- response_reason: str | None#
- trace_id: str | None#
- transaction_id: str | None#