Skip to content

flowmachine.core.server.query_schemas.coalesced_location

Class CoalescedLocationExposed

CoalescedLocationExposed(preferred_location, fallback_location, subscriber_location_weights, weight_threshold: int, sampling=None)
Source: flowmachine/core/server/query_schemas/coalesced_location.py

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
Source: flowmachine/core/server/query_schemas/base_query_with_sampling.py

Return the underlying flowmachine query object which this class exposes.

Returns
  • Query

_unsampled_query_obj

_unsampled_query_obj
Source: flowmachine/core/server/query_schemas/coalesced_location.py

Return the flowmachine query object to be sampled.

Returns
  • Query

query_id

query_id
Source: flowmachine/core/server/query_schemas/base_exposed_query.py

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)
Source: flowmachine/core/server/query_schemas/coalesced_location.py

Schema that exposes CoalescedLocation with a FilteredReferenceLocation query as the fallback location

Attributes

Methods

validate_aggregation_units

validate_aggregation_units(self, data, **kwargs)
Source: flowmachine/core/server/query_schemas/coalesced_location.py

Validate that preferred_location, fallback_location and subscriber_location_weights all have the same aggregation unit

dict_class

dict_class
Source: marshmallow/schema.py

set_class

set_class
Source: marshmallow/schema.py