coleam00 · gemmawood · Apr 21, 2026 · Apr 21, 2026 · Apr 21, 2026 · Apr 21, 2026
diff --git a/packages/cli/src/cli.ts b/packages/cli/src/cli.ts
@@ -204,6 +204,7 @@ async function main(): Promise<number> {
         'download-only': { type: 'boolean' },
         scope: { type: 'string' },
         force: { type: 'boolean' },
+        set: { type: 'string', multiple: true },
       },
       allowPositionals: true,
       strict: false, // Allow unknown flags to pass through
@@ -352,13 +353,34 @@ async function main(): Promise<number> {
               );
               return 1;
             }
+            // Parse --set KEY=VALUE flags into a runtime inputs map
+            const setFlags = values.set as string[] | undefined;
+            let inputs: Record<string, string> | undefined;
+            if (setFlags && setFlags.length > 0) {
+              inputs = {};
+              for (const flag of setFlags) {
+                const eqIndex = flag.indexOf('=');
+                if (eqIndex === -1) {
+                  console.error(`Error: --set flag must be in KEY=VALUE format, got: ${flag}`);
+                  return 1;
+                }
+                const key = flag.slice(0, eqIndex).trim();
+                const value = flag.slice(eqIndex + 1);
+                if (!key) {
+                  console.error(`Error: --set flag has empty key: ${flag}`);
+                  return 1;
+                }
+                inputs[key] = value;
+              }
+            }
             const options = {
               branchName,
               fromBranch,
               noWorktree,
               resume: resumeFlag,
               quiet: values.quiet as boolean | undefined,
               verbose: values.verbose as boolean | undefined,
+              inputs,
             };
             await workflowRunCommand(effectiveCwd, workflowName, userMessage, options);
             break;

diff --git a/packages/cli/src/commands/workflow.ts b/packages/cli/src/commands/workflow.ts
@@ -66,6 +66,11 @@ export interface WorkflowRunOptions {
   verbose?: boolean;
   /** Platform conversation ID (e.g. `cli-{ts}-{rand}`), NOT a DB UUID. */
   conversationId?: string;
+  /**
+   * Runtime input values for workflows that declare an `inputs:` block.
+   * Populated from `--set KEY=VALUE` CLI flags.
+   */
+  inputs?: Record<string, string>;
 }
 
 /**
@@ -655,7 +660,12 @@ export async function workflowRunCommand(
       workflow,
       userMessage,
       conversation.id,
-      codebase?.id
+      codebase?.id,
+      undefined,
+      undefined,
+      undefined,
+      undefined,
+      options.inputs
     );
   } finally {
     unsubscribe?.();

diff --git a/packages/core/src/orchestrator/orchestrator-agent.ts b/packages/core/src/orchestrator/orchestrator-agent.ts
@@ -221,7 +221,8 @@ async function dispatchOrchestratorWorkflow(
   codebase: Codebase,
   workflow: WorkflowDefinition,
   userMessage: string,
-  isolationHints?: HandleMessageContext['isolationHints']
+  isolationHints?: HandleMessageContext['isolationHints'],
+  inputs?: Record<string, string>
 ): Promise<void> {
   // Auto-attach project to conversation
   await db.updateConversation(conversation.id, {
@@ -293,7 +294,12 @@ async function dispatchOrchestratorWorkflow(
         workflow,
         userMessage,
         conversation.id,
-        codebase.id
+        codebase.id,
+        undefined,
+        undefined,
+        undefined,
+        undefined,
+        inputs
       );
     } else if (workflow.interactive) {
       // Interactive workflows run in foreground so output stays in the user's conversation
@@ -305,7 +311,12 @@ async function dispatchOrchestratorWorkflow(
         workflow,
         userMessage,
         conversation.id,
-        codebase.id
+        codebase.id,
+        undefined,
+        undefined,
+        undefined,
+        undefined,
+        inputs
       );
     } else {
       await dispatchBackgroundWorkflow(
@@ -318,6 +329,7 @@ async function dispatchOrchestratorWorkflow(
           codebaseId: codebase.id,
           availableWorkflows: [workflow],
           isolationHints,
+          inputs,
         },
         workflow
       );
@@ -331,7 +343,12 @@ async function dispatchOrchestratorWorkflow(
       workflow,
       userMessage,
       conversation.id,
-      codebase.id
+      codebase.id,
+      undefined,
+      undefined,
+      undefined,
+      undefined,
+      inputs
     );
   }
 }
@@ -530,8 +547,14 @@ export async function handleMessage(
   message: string,
   context?: HandleMessageContext
 ): Promise<void> {
-  const { issueContext, threadContext, parentConversationId, isolationHints, attachedFiles } =
-    context ?? {};
+  const {
+    issueContext,
+    threadContext,
+    parentConversationId,
+    isolationHints,
+    attachedFiles,
+    inputs,
+  } = context ?? {};
   try {
     getLog().debug({ conversationId }, 'orchestrator_message_received');
 
@@ -646,14 +669,20 @@ export async function handleMessage(
             return;
           }
           await platform.sendMessage(conversationId, `▶️ Resuming **${workflow.name}**...`);
+          const pausedResumeInputs = pausedRun.metadata?.resolved_inputs as
+            | Record<string, string>
+            | undefined;
           await dispatchOrchestratorWorkflow(
             platform,
             conversationId,
             conversation,
             codebase,
             workflow,
             pausedRun.user_message,
-            isolationHints
+            isolationHints,
+            pausedResumeInputs && Object.keys(pausedResumeInputs).length > 0
+              ? pausedResumeInputs
+              : undefined
           );
           getLog().info(
             { conversationId, workflowRunId: pausedRun.id, workflowName: pausedRun.workflow_name },
@@ -723,7 +752,8 @@ export async function handleMessage(
             conversation,
             result.workflow.definition,
             result.workflow.args ?? message,
-            isolationHints
+            isolationHints,
+            inputs
           );
         }
         return;
@@ -1392,7 +1422,8 @@ async function handleWorkflowRunCommand(
   conversation: Conversation,
   workflow: WorkflowDefinition,
   userMessage: string,
-  isolationHints?: HandleMessageContext['isolationHints']
+  isolationHints?: HandleMessageContext['isolationHints'],
+  inputs?: Record<string, string>
 ): Promise<void> {
   // Check if conversation has a project
   if (conversation.codebase_id) {
@@ -1412,7 +1443,8 @@ async function handleWorkflowRunCommand(
       codebase,
       workflow,
       userMessage,
-      isolationHints
+      isolationHints,
+      inputs
     );
     return;
   }
@@ -1489,7 +1521,8 @@ async function handleWorkflowRunCommand(
       codebase,
       resolvedWorkflow,
       userMessage,
-      isolationHints
+      isolationHints,
+      inputs
     );
     return;
   }

diff --git a/packages/core/src/orchestrator/orchestrator.ts b/packages/core/src/orchestrator/orchestrator.ts
@@ -246,6 +246,8 @@ export interface WorkflowRoutingContext {
    * Hints for isolation environment (PR review context, etc.)
    */
   readonly isolationHints?: IsolationHints;
+  /** Runtime input values for workflows declared with an `inputs:` block. */
+  readonly inputs?: Record<string, string>;
 }
 
 /**
@@ -374,7 +376,8 @@ export async function dispatchBackgroundWorkflow(
           ctx.issueContext,
           isolationContext,
           ctx.conversationDbId,
-          preCreatedRun
+          preCreatedRun,
+          ctx.inputs
         );
         // Surface workflow output to parent conversation as a result card
         if ('paused' in result) {

diff --git a/packages/core/src/types/index.ts b/packages/core/src/types/index.ts
@@ -51,6 +51,8 @@ export interface HandleMessageContext {
   readonly parentConversationId?: string;
   readonly isolationHints?: IsolationHints;
   readonly attachedFiles?: AttachedFile[];
+  /** Runtime input values for workflows declared with an `inputs:` block. */
+  readonly inputs?: Record<string, string>;
 }
 
 export interface Codebase {

diff --git a/packages/server/src/routes/api.ts b/packages/server/src/routes/api.ts
@@ -1709,7 +1709,7 @@ export function registerApiRoutes(
       return apiError(c, 400, 'Invalid workflow name');
     }
     try {
-      const { conversationId, message } = getValidatedBody(c, runWorkflowBodySchema);
+      const { conversationId, message, inputs } = getValidatedBody(c, runWorkflowBodySchema);
       // Persist user message and register DB ID (same as message endpoint)
       let conv: Awaited<ReturnType<typeof conversationDb.findConversationByPlatformId>> = null;
       try {
@@ -1737,7 +1737,11 @@ export function registerApiRoutes(
       }
 
       const fullMessage = `/workflow run ${workflowName} ${message}`;
-      const result = await dispatchToOrchestrator(conversationId, fullMessage);
+      const result = await dispatchToOrchestrator(
+        conversationId,
+        fullMessage,
+        inputs ? { inputs } : undefined
+      );
       return c.json(result);
     } catch (error) {
       getLog().error({ err: error }, 'run_workflow_failed');

diff --git a/packages/server/src/routes/schemas/workflow.schemas.ts b/packages/server/src/routes/schemas/workflow.schemas.ts
@@ -205,6 +205,12 @@ export const runWorkflowBodySchema = z
   .object({
     conversationId: z.string(),
     message: z.string(),
+    /**
+     * Runtime input values for workflows that declare an `inputs:` block.
+     * Keys must match input names declared in the workflow YAML; values are strings.
+     * Unrecognised keys are passed through and ignored by workflows that don't declare them.
+     */
+    inputs: z.record(z.string()).optional(),
   })
   .openapi('RunWorkflowBody');