chore(release): v0.6.17 — detached run_workflow dispatch fix

crates/orchestrator-cli/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "orchestrator-cli"
-version = "0.6.16"
+version = "0.6.17"
 edition = "2021"
 license = "Elastic-2.0"
 default-run = "animus"

crates/orchestrator-cli/src/services/operations/ops_workflow/phases.rs

@@ -69,17 +69,23 @@ pub(crate) fn ensure_workflow_runner_plugin(project_root: &Path) -> Result<()> {
 }
 
 /// Build the `workflow/execute` request that re-attaches the workflow_runner
-/// plugin to an already-persisted workflow record. Subject fields stay empty:
-/// the persisted record is authoritative for subject, input, and vars.
+/// plugin to an already-persisted workflow record. The persisted record is
+/// authoritative for input and vars, but the subject MUST be carried in the
+/// request: the runner plugin resolves subject context from
+/// `subject_ref`/`task_id`/`requirement_id`, not from `workflow_id` alone, so
+/// an empty subject made `workflow/execute` fail to resolve subject context
+/// for every detached `workflow run` / `run_workflow` dispatch (the
+/// queue/trigger path carries the subject via `build_runner_command`, which is
+/// why only this reattach path was affected).
 pub(crate) fn workflow_execute_request_for_existing(
     workflow: &OrchestratorWorkflow,
 ) -> workflow_proto::WorkflowExecuteRequest {
     workflow_proto::WorkflowExecuteRequest {
         workflow_id: Some(workflow.id.clone()),
         subject_dispatch: None,
         subject_ref: None,
-        task_id: None,
-        requirement_id: None,
+        task_id: workflow.subject.task_id().map(str::to_string),
+        requirement_id: workflow.subject.requirement_id().map(str::to_string),
         title: None,
         description: None,
         workflow_ref: workflow.workflow_ref.clone(),
@@ -1150,6 +1156,35 @@ workflows:
         );
     }
 
+    #[tokio::test]
+    async fn reattach_request_carries_task_subject_for_plugin_resolution() {
+        let _lock = test_env_lock().lock().unwrap_or_else(|p| p.into_inner());
+        let temp = TempDir::new().expect("temp dir");
+        let _guards = isolate_plugin_discovery(&temp);
+        init_git_repo(&temp);
+        write_standard_workflow_yaml(&temp);
+        let project_root = temp.path().to_string_lossy().to_string();
+        let _config_source_seam =
+            orchestrator_config::workflow_config::config_source_client::install_yaml_config_source_base(temp.path());
+        let hub = Arc::new(FileServiceHub::new(&project_root).expect("file service hub"));
+        let task = create_test_task(&hub, "reattach subject").await;
+        let existing = hub
+            .workflows()
+            .run(WorkflowRunInput::for_task(task.id.clone(), None))
+            .await
+            .expect("workflow should start");
+
+        let request = super::workflow_execute_request_for_existing(&existing);
+
+        assert_eq!(request.workflow_id.as_deref(), Some(existing.id.as_str()));
+        assert_eq!(
+            request.task_id.as_deref(),
+            Some(task.id.as_str()),
+            "reattach request must carry the task subject so the runner plugin resolves subject context"
+        );
+        assert_eq!(request.requirement_id, None);
+    }
+
     #[tokio::test]
     async fn resume_workflow_with_runner_rejects_terminal_and_runner_owned_workflows() {
         let _lock = test_env_lock().lock().unwrap_or_else(|p| p.into_inner());