feat: adjustments from code review

Author: raphael-goetz

crates/taurus-provider/src/providers/remote/nats_remote_runtime.rs

@@ -34,12 +34,12 @@ impl RemoteRuntime for NATSRemoteRuntime {
             Ok(r) => r,
             Err(err) => {
                 log::error!(
-                    "RemoteRuntimeExeption: failed to handle NATS message: {}",
+                    "RemoteRuntimeException: failed to handle NATS message: {}",
                     err
                 );
                 return Err(RuntimeError::new(
                     "T-PROV-000001",
-                    "RemoteRuntimeExeption",
+                    "RemoteRuntimeException",
                     "Failed to receive any response messages from a remote runtime.",
                 ));
             }
@@ -50,22 +50,22 @@ impl RemoteRuntime for NATSRemoteRuntime {
             Ok(r) => match r.node_result {
                 Some(res) => Ok(res),
                 None => {
-                    log::error!("RemoteRuntimeExeption: recieved execution result without an body");
-                    return Err(RuntimeError::new(
+                    log::error!("RemoteRuntimeException: received execution result without a body");
+                    Err(RuntimeError::new(
                         "T-PROV-000003",
-                        "RemoteRuntimeExeption",
-                        "Recieved empty action execution response",
-                    ));
+                        "RemoteRuntimeException",
+                        "Received empty action execution response",
+                    ))
                 }
             },
             Err(err) => {
                 log::error!(
-                    "RemoteRuntimeExeption: failed to decode NATS message: {}",
+                    "RemoteRuntimeException: failed to decode NATS message: {}",
                     err
                 );
                 return Err(RuntimeError::new(
                     "T-PROV-000002",
-                    "RemoteRuntimeExeption",
+                    "RemoteRuntimeException",
                     "Failed to read Remote Response",
                 ));
             }

crates/taurus/src/app/worker.rs

@@ -37,15 +37,15 @@ pub fn spawn_worker(
         };
 
         let mut test_execution_subscription = match client
-            .queue_subscribe(String::from("test_executions.*"), "taurus".into())
+            .queue_subscribe(String::from("test_execution.*"), "taurus".into())
             .await
         {
             Ok(subscription) => {
-                log::info!("Subscribed to 'test_executions.*'");
+                log::info!("Subscribed to 'test_execution.*'");
                 subscription
             }
             Err(err) => {
-                log::error!("Failed to subscribe to 'test_executions.*': {:?}", err);
+                log::error!("Failed to subscribe to 'test_execution.*': {:?}", err);
                 return;
             }
         };
@@ -85,7 +85,7 @@ pub fn spawn_worker(
                         }
                         None => {
                             test_execution_closed = true;
-                            log::warn!("Subscription 'test_executions.*' ended");
+                            log::warn!("Subscription 'test_execution.*' ended");
                         }
                     }
                 }
@@ -159,7 +159,7 @@ async fn process_test_execution_message(
     runtime_usage_service: Option<&TaurusRuntimeUsageService>,
 ) {
     let requested_execution_id =
-        match parse_execution_id_from_subject(&message.subject, "test_executions") {
+        match parse_execution_id_from_subject(&message.subject, "test_execution") {
             Some(res) => res,
             None => {
                 log::error!("Failed to extract execution uuid from {}", &message.subject);
@@ -480,7 +480,7 @@ mod tests {
         execution_id: ExecutionId,
         payload: Vec<u8>,
     ) -> Result<ExecutionResult, String> {
-        let subject = format!("test_executions.{execution_id}");
+        let subject = format!("test_execution.{execution_id}");
 
         for attempt in 1..=10 {
             match tokio::time::timeout(

docs/errors.md

@@ -10,6 +10,7 @@ This document is the canonical catalog for runtime error codes emitted by Taurus
 
 - `T-STD-XXXXX`: Errors originating inside standard function implementations under `runtime/functions/*`.
 - `T-CORE-XXXXXX`: Errors originating from core runtime infrastructure.
+- `T-TAURUS-XXXXXX`: Errors originating from the Taurus runtime app layer.
 - `T-PROV-XXXXXX`: Errors originating from provider integrations (transport adapters, remote runtime connectors).
 
 ## Code Table
@@ -23,10 +24,13 @@ This document is the canonical catalog for runtime error codes emitted by Taurus
 | `T-CORE-000003` | Engine | Flow requires remote execution but no remote runtime adapter was configured. | Node execution target is remote while `RemoteRuntime` is `None`. | `runtime/engine/executor.rs` |
 | `T-CORE-000004` | Engine | Reference lookup failed in the execution value store. | Missing prior node result, missing flow input path, or unresolved input reference. | `runtime/engine/executor.rs` |
 | `T-CORE-000005` | Engine | Remote request cannot be assembled because parameter metadata and resolved values diverge. | Parameter count mismatch during remote request materialization. | `runtime/engine/executor.rs` |
+| `T-CORE-000006` | Engine | Remote node execution returned a node result without a success/error outcome. | Provider returned a `NodeExecutionResult` with no `result` field. | `runtime/engine/executor.rs` |
 | `T-CORE-000101` | Compiler | Flow compilation failed because a node id appears more than once. | Duplicate `database_id` in input nodes. | `runtime/engine/compiler.rs` |
 | `T-CORE-000102` | Compiler | Flow compilation failed because the declared start node is absent. | `start_node_id` not found in node list. | `runtime/engine/compiler.rs` |
 | `T-CORE-000103` | Compiler | Flow compilation failed because a `next` edge points to a missing node. | `next_node_id` references unknown node id. | `runtime/engine/compiler.rs` |
 | `T-CORE-000104` | Compiler | Flow compilation failed because a parameter is structurally incomplete. | Parameter has no value payload in IR. | `runtime/engine/compiler.rs` |
+| `T-CORE-000105` | Compiler | Flow compilation failed because a sub-flow parameter is missing its execution reference. | `sub_flow.execution_reference` is absent. | `runtime/engine/compiler.rs` |
+| `T-CORE-000106` | Compiler | Flow compilation failed because a sub-flow parameter uses an unsupported execution reference. | `sub_flow.execution_reference` is not a starting node id. | `runtime/engine/compiler.rs` |
 | `T-CORE-000201` | Handler | Handler argument arity contract was violated before function execution began. | `args!`/`no_args!` macro expected different argument count. | `handler/macros.rs` |
 | `T-CORE-000202` | Handler | Handler argument type conversion failed during typed extraction. | `TryFromArgument` expected type does not match provided argument. | `handler/argument.rs` |
 | `T-CORE-000301` | App Error Mapping | Application configuration failure mapped into runtime error format. | Invalid/missing runtime config surfaced as `Error::Configuration`. | `types/errors/error.rs` |
@@ -35,6 +39,7 @@ This document is the canonical catalog for runtime error codes emitted by Taurus
 | `T-CORE-000304` | App Error Mapping | Serialization/deserialization failure mapped into runtime error format. | Encoding/decoding/parsing failure surfaced as `Error::Serialization`. | `types/errors/error.rs` |
 | `T-CORE-000399` | App Error Mapping | Internal application failure mapped into runtime error format. | Catch-all non-domain internal failure surfaced as `Error::Internal`. | `types/errors/error.rs` |
 | `T-CORE-999999` | Runtime Error Fallback | Default fallback runtime error code when no explicit mapping is provided. | `RuntimeError::default()` used as defensive fallback. | `types/errors/runtime_error.rs` |
+| `T-TAURUS-000001` | Taurus App | Test execution request payload could not be decoded as an execution flow. | Malformed or schema-incompatible payload published to the test execution NATS subject. | `taurus/src/app/worker.rs` |
 | `T-PROV-000001` | Provider Remote Runtime | Remote request to NATS did not yield a valid response message. | NATS request failed or timed out while waiting for remote runtime answer. | `taurus-provider/providers/remote/nats_remote_runtime.rs` |
 | `T-PROV-000002` | Provider Remote Runtime | Remote runtime response could not be decoded into expected protobuf structure. | Received payload is malformed, truncated, or schema-incompatible for `ExecutionResult`. | `taurus-provider/providers/remote/nats_remote_runtime.rs` |
 | `T-PROV-000003` | Provider Remote Runtime | Remote runtime response decoded, but contained no concrete result field. | `ExecutionResult` exists but `result` is `None` (protocol contract violation). | `taurus-provider/providers/remote/nats_remote_runtime.rs` |