prompt-graph-exec 0.1.28

Execution of Chidori, interprets a given graph of prompts and nodes, provides grpc api to the runtime
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

use prompt_graph_core::proto::{ChangeValue, item, NodeWillExecuteOnBranch, Path};
use crate::db_operations::custom_node_execution::get_custom_node_execution;

use crate::executor::NodeExecutionContext;

#[tracing::instrument]
pub async fn execute_node_custom(ctx: &NodeExecutionContext<'_>) -> anyhow::Result<Vec<ChangeValue>> {
    let &NodeExecutionContext {
        node_will_execute_on_branch,
        item: item::Item::NodeCustom(_n),
        namespaces,
        tree,
        ..
    } = ctx else {
        panic!("execute_node_custom: expected NodeExecutionContext with Custom item");
    };

    let NodeWillExecuteOnBranch { branch, counter, ..} = node_will_execute_on_branch;

    loop {
        if let Some(change) = get_custom_node_execution(&tree, *branch, *counter) {
            let mut result_filled_values = vec![];
            for filled_value in change.filled_values {
                for output_table in namespaces.iter() {
                    let mut address = vec![output_table.clone()];
                    address.extend(filled_value.path.as_ref().unwrap().address.clone());
                    result_filled_values.push(
                    ChangeValue {
                        path: Some(Path {
                            address,
                        }),
                        value: filled_value.value.clone(),
                        branch: 0,
                    });
                }

            }
            return Ok(result_filled_values);
        }
    }
}