Struct querent_synapse::querent::query::query_engine::QueryEngineManager

pub struct QueryEngineManager {
    pub workflows: Mutex<HashMap<String, QueryEngine>>,
    pub runtime: &'static PyRuntime,
}

Fields

workflows: Mutex<HashMap<String, QueryEngine>>

Mutex-protected map of engines for query, keyed by their unique identifier.

runtime: &'static PyRuntime

Reference to the Python runtime.

Implementations

impl QueryEngineManager

pub fn new() -> Result<Self, String>

Creates a new WorkflowManager instance.

pub fn add_workflow(&self, workflow: QueryEngine) -> Result<(), String>

Adds a workflow to the manager.

pub fn get_workflows(&self) -> Vec<QueryEngine>

Retrieves a list of all workflows managed by this manager.

pub async fn start_workflows(&self) -> Result<(), QuerentError>

Starts workflows by executing their Python code asynchronously.

Trait Implementations

impl Drop for QueryEngineManager

fn drop(&mut self)

Drops the WorkflowManager instance, cleaning up resources.