fix: minor bugs

Author: raphael-goetz

Cargo.lock

@@ -22,7 +22,7 @@ tonic-health = "0.14.1"
 tonic = "0.14.1"
 serde_json = "1.0.149"
 serde = "1.0.228"
-
+uuid =  { version = "1.23.0", features = ["v4"] }
 [workspace.dependencies.taurus-core]
 path = "./crates/core"
 

Cargo.toml

@@ -10,4 +10,5 @@ rand = { workspace = true }
 log = { workspace = true }
 futures-lite = { workspace = true }
 async-trait = { workspace = true }
+uuid = { workspace = true }
 

crates/core/Cargo.toml

@@ -36,6 +36,7 @@ use tucana::aquila::ExecutionRequest;
 use tucana::shared::reference_value::Target;
 use tucana::shared::value::Kind;
 use tucana::shared::{NodeFunction, Struct, Value};
+use uuid::Uuid;
 
 /// Executes a flow graph by repeatedly evaluating nodes.
 ///
@@ -223,7 +224,7 @@ impl<'a> Executor<'a> {
             };
 
             let remote_result =
-                block_on(remote.execute_remote(node.runtime_function_id.clone(), request));
+                block_on(remote.execute_remote(node.definition_source.clone(), request));
             let signal = match remote_result {
                 Ok(value) => Signal::Success(value),
                 Err(err) => Signal::Failure(err),
@@ -583,9 +584,9 @@ impl<'a> Executor<'a> {
         for (param, value) in node.parameters.iter().zip(values.into_iter()) {
             fields.insert(param.runtime_parameter_id.clone(), value);
         }
-
+        let id = Uuid::new_v4();
         Ok(ExecutionRequest {
-            execution_identifier: format!("node-{}", node.database_id),
+            execution_identifier: id.to_string(),
             function_identifier: node.runtime_function_id.clone(),
             parameters: Some(Struct { fields }),
             project_id: 0,

crates/core/src/context/executor.rs

@@ -33,13 +33,14 @@ impl RemoteRuntime for RemoteNatsClient {
     ) -> Result<Value, RuntimeError> {
         let topic = format!("action.{}.{}", remote_name, request.execution_identifier);
         let payload = request.encode_to_vec();
-        let res = self.client.request(topic, payload.into()).await;
+        let res = self.client.request(topic.clone(), payload.into()).await;
+        log::info!("Publishing to topic: {}", topic);
         let message = match res {
             Ok(r) => r,
-            Err(_) => {
-                return Err(RuntimeError::simple_str(
+            Err(err) => {
+                return Err(RuntimeError::simple(
                     "RemoteRuntimeExeption",
-                    "Failed to handle NATS message",
+                    format!("Failed to handle NATS message {:?}", err),
                 ));
             }
         };

crates/manual/src/main.rs

@@ -0,0 +1,39 @@
+{
+	"name": "04_example_action",
+	"description": "This flow expects a simple http response object as the return value",
+	"inputs": [
+		{
+			"input": null,
+			"expected_result": {
+				"status_code": 200,
+				"headers": {
+					"Header": "X"
+				},
+				"payload": "Hello World"
+			}
+		}
+	],
+	"flow": {
+		"starting_node_id": "1",
+		"node_functions": [
+			{
+				"definition_source": "example",
+				"databaseId": "1",
+				"runtimeFunctionId": "fib",
+				"parameters": [
+					{
+						"databaseId": "4",
+						"runtimeParameterId": "http_response",
+						"value": {
+							"literalValue": {
+								"numberValue": {
+									"integer": 10
+								}
+							}
+						}
+					}
+				]
+			}
+		]
+	}
+}