flowmachine.core.query_info_lookup

Class QueryInfoLookup

QueryInfoLookup(redis_client: redis.client.Redis)

Source: flowmachine/core/query_info_lookup.py

Implements a lookup from the query_id to query parameters and vice versa (backed by redis).

Methods

get_query_id

get_query_id(self, query_params: dict) -> str

Source: flowmachine/core/query_info_lookup.py

get_query_kind

get_query_kind(self, query_id: str) -> str

Source: flowmachine/core/query_info_lookup.py

get_query_params

get_query_params(self, query_id: str) -> dict

Source: flowmachine/core/query_info_lookup.py

query_is_known

query_is_known(self, query_id: str) -> bool

Source: flowmachine/core/query_info_lookup.py

register_query

register_query(self, query_id: str, query_params: dict) -> None

Source: flowmachine/core/query_info_lookup.py

Class QueryInfoLookupError

Source: flowmachine/core/query_info_lookup.py

Exception indicating an error with the query info lookup.

Class UnkownQueryIdError

Source: flowmachine/core/query_info_lookup.py

Exception indicating an error with the query info lookup.