Method createRunner

src/node/services/workflows/WorkflowService.ts:867–891

(runId: string)

  }

  private async createRunner(runId: string): Promise<WorkflowRunner> {
    // The run record always exists by the time a runner is created (create/resume/retry
    // paths persist it first), so resolve the display name for task labeling here.
    const workflowName =
      this.taskAdapterFactory != null
        ? (await this.runStore.getRun(runId)).workflow.name
        : undefined;
    return new WorkflowRunner({
      runStore: this.runStore,
      runtimeFactory: this.runtimeFactory,
      taskAdapter: this.taskAdapterFactory?.(runId, workflowName) ?? this.requireTaskAdapter(),
      nestedWorkflowAdapter: {
        createRun: async (input) => {
          const run = await this.createNestedWorkflowRun(input);
          return { runId: run.id, name: run.workflow.name };
        },
        run: async (childRunId, options) => {
          const childRunner = await this.createRunner(childRunId);
          return await childRunner.run(childRunId, options);
        },
      },
      runnerId: generateWorkflowRunnerOwnerId(this.runnerId, runId),
      ...(this.clock != null ? { clock: this.clock } : {}),
    });
  }

  private async requireRunForWorkspace(input: {
    workspaceId: string;