flowmachine.core.server.query_schemas.coalesced_location¶
Class CoalescedLocationExposed¶
CoalescedLocationExposed(preferred_location, fallback_location, subscriber_location_weights, weight_threshold: int, sampling=None)
Base class for exposed flowmachine queries. Note: this class and derived classes are not meant to be instantiated directly! Instead, they are instantiated automatically by the class FlowmachineQuerySchema. Example: FlowmachineQuerySchema().load({"query_kind": "dummy_query", "dummy_param": "foobar"})
Attributes¶
Methods¶
_flowmachine_query_obj¶
_flowmachine_query_obj
Return the underlying flowmachine query object which this class exposes.
Returns¶
Query
_unsampled_query_obj¶
_unsampled_query_obj
Return the flowmachine query object to be sampled.
Returns¶
Query
query_id¶
query_id
Class CoalescedLocationSchema¶
CoalescedLocationSchema(*, only: Union[Sequence[str], Set[str], NoneType] = None, exclude: Union[Sequence[str], Set[str]] = (), many: bool = False, context: Union[Dict, NoneType] = None, load_only: Union[Sequence[str], Set[str]] = (), dump_only: Union[Sequence[str], Set[str]] = (), partial: Union[bool, Sequence[str], Set[str]] = False, unknown: Union[str, NoneType] = None)
Schema that exposes CoalescedLocation with a FilteredReferenceLocation query as the fallback location
Attributes¶
Methods¶
validate_aggregation_units¶
validate_aggregation_units(self, data, **kwargs)
Validate that preferred_location, fallback_location and subscriber_location_weights all have the same aggregation unit
dict_class¶
dict_class
set_class¶
set_class