Skip to content

flowmachine.core.server.query_schemas.subscriber_subset

Class NoneOrQuery

NoneOrQuery()
Source: flowmachine/core/server/query_schemas/subscriber_subset.py

Validator which fails if value is not the id of a real query, or is not None`.

Class SubscriberSubset

SubscriberSubset(required=False, allow_none=True, validate=None, **kwargs)
Source: flowmachine/core/server/query_schemas/subscriber_subset.py

Represents a subscriber subset. This can either be a string representing a query_id or None, meaning "all subscribers".

Attributes

Methods

deserialize

deserialize(self, value: Any, attr: str = None, data: Mapping[str, Any] = None, **kwargs) -> Union[NoneType, flowmachine.core.table.Table]
Source: flowmachine/core/server/query_schemas/subscriber_subset.py

Deserialize value. :param value: The value to deserialize. :param attr: The attribute/key in data to deserialize. :param data: The raw input data passed to Schema.load. :param kwargs: Field-specific keyword arguments. :raise ValidationError: If an invalid value is passed or if a required value is missing.

Returns
  • typing.Union[NoneType, flowmachine.core.table.Table]

context

context
Source: marshmallow/fields.py

The context dictionary for the parent :class:Schema.

root

root
Source: marshmallow/fields.py

Reference to the Schema that this field belongs to even if it is buried in a container field (e.g. List). Return None for unbound fields.