Source code for ska_sdp_config.operations.flow

"""
Flow management for SDP Configuration Database.
"""

from ..entity import Dependency, Flow
from .entity_operations import CollectiveEntityOperations




class FlowOperations(CollectiveEntityOperations[Flow, Flow.Key]):
    """Database operations related to flows management."""

    PREFIX = "/flow"
    MODEL_CLASS = Flow
    HAS_OWNER = True
    HAS_STATE = True





class DependencyOperations(
    CollectiveEntityOperations[Dependency, Dependency.Key]
):
    """Database operations on flow dependency management."""

    PREFIX = "/dependency"
    MODEL_CLASS = Dependency
    HAS_STATE = True