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

• _validate_all

• context

• default

• missing

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]

_validate_all

_validate_all

Source: marshmallow/fields.py

context

context

Source: marshmallow/fields.py

The context dictionary for the parent :class:Schema.

default

default

Source: marshmallow/fields.py

missing

missing

Source: marshmallow/fields.py