Merge pull request #20 from erhant/main

chore: Workflow as reference
andthattoo · Nov 1, 2024 · 72b090f · 72b090f
2 parents a0b5efb + 0d29d14
commit 72b090f
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/examples/execute_workflow.rs b/examples/execute_workflow.rs
@@ -11,7 +11,7 @@ async fn main() {
     let workflow = Workflow::new_from_json("./workflows/search.json").unwrap();
     let mut memory = ProgramMemory::new();
     let input = Entry::try_value_or_str("How would does reiki work?");
-    let return_value = exe.execute(Some(&input), workflow, &mut memory).await;
+    let return_value = exe.execute(Some(&input), &workflow, &mut memory).await;
     match return_value {
         Ok(value) => println!("{}", value),
         Err(err) => eprintln!("Error: {:?}", err),

diff --git a/src/program/executor.rs b/src/program/executor.rs
@@ -80,7 +80,7 @@ impl Executor {
     pub async fn execute(
         &self,
         input: Option<&Entry>,
-        workflow: Workflow,
+        workflow: &Workflow,
         memory: &mut ProgramMemory,
     ) -> Result<String, ExecutionError> {
         let config = workflow.get_config();

diff --git a/tests/run.rs b/tests/run.rs
@@ -33,7 +33,7 @@ macro_rules! workflow_test {
             let workflow = Workflow::new_from_json($workflow).unwrap();
             let mut memory = ProgramMemory::new();
             let input = Entry::try_value_or_str($input);
-            if let Err(e) = exe.execute(Some(&input), workflow, &mut memory).await {
+            if let Err(e) = exe.execute(Some(&input), &workflow, &mut memory).await {
                 log::error!("Execution failed: {}", e);
             };
         }
@@ -44,7 +44,7 @@ macro_rules! workflow_test {
             let exe = setup_test($model).await;
             let workflow = Workflow::new_from_json($workflow).unwrap();
             let mut memory = ProgramMemory::new();
-            if let Err(e) = exe.execute(None, workflow, &mut memory).await {
+            if let Err(e) = exe.execute(None, &workflow, &mut memory).await {
                 log::error!("Execution failed: {}", e);
             };
         }