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: 'types.StrSequenceOrSet | None' = None, exclude: 'types.StrSequenceOrSet' = (), many: 'bool | None' = None, context: 'dict | None' = None, load_only: 'types.StrSequenceOrSet' = (), dump_only: 'types.StrSequenceOrSet' = (), partial: 'bool | types.StrSequenceOrSet | None' = None, unknown: 'str | None' = 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