feat: Remove unnecessary workflow state reset calls; streamline workflow execution logic for improved clarity

Author: yaonyan

packages/core/src/executors/sampling/workflow-sampling-executor.ts

@@ -86,10 +86,6 @@ export class WorkflowSamplingExecutor extends BaseSamplingExecutor {
 
     const toolCallData = parsedData as Record<string, unknown>;
 
-    if (toolCallData.userRequest) {
-      workflowState.reset();
-    }
-
     if (toolCallData.action === "complete") {
       const reasoning = (toolCallData.reasoning as string) || "Task completed";
       return this.createCompletionResult(reasoning);

packages/core/src/executors/workflow/workflow-tool-registrar.ts

@@ -86,7 +86,6 @@ export function registerAgenticWorkflowTool(
       try {
         // Use appropriate executor based on mode
         if (sampling) {
-          workflowState.reset();
           return await workflowSamplingExecutor.executeWorkflowSampling(
             args as Record<string, unknown>,
             argsDef as Record<string, unknown>,

packages/core/src/factories/args-def-factory.ts

@@ -101,27 +101,14 @@ Workflow step definitions - provide ONLY on initial call.
     },
 
     forCurrentState: function (state: WorkflowState): JSONSchema {
-      if (!state.isWorkflowInitialized()) {
-        if (predefinedSteps) {
-          return this.common({
-            init: this.init(),
-          });
-        }
-        return this.common({
-          steps: this.steps(),
-          init: this.init(),
-        });
-      }
-
       const currentStep = state.getCurrentStep();
-      if (!currentStep) {
-        throw new Error(
-          `Invalid workflow state: no current step, ${
-            JSON.stringify(
-              state.getDebugInfo(),
-            )
-          }`,
-        );
+      if (!state.isWorkflowInitialized() || !currentStep) {
+        state.reset();
+        const initSchema: Record<string, JSONSchema> = { init: this.init() };
+        if (!predefinedSteps) {
+          initSchema.steps = this.steps();
+        }
+        return this.common(initSchema);
       }
 
       const stepDependencies = {