Method commit

backend/src/workflows/workflows.service.ts:707–732

(id: string, auth?: AuthContext | null)

  }

  async commit(id: string, auth?: AuthContext | null): Promise<WorkflowDefinition> {
    const organizationId = await this.requireWorkflowAdmin(id, auth);
    const workflow = await this.repository.findById(id, { organizationId });
    if (!workflow) {
      throw new NotFoundException(`Workflow ${id} not found`);
    }

    const version = await this.versionRepository.findLatestByWorkflowId(id, {
      organizationId,
    });
    if (!version) {
      throw new NotFoundException(`No versions recorded for workflow ${id}`);
    }

    this.logger.log(`Compiling workflow ${workflow.id} version ${version.version}`);
    const graph = WorkflowGraphSchema.parse(version.graph);
    const definition = compileWorkflowGraph(graph);
    await this.repository.saveCompiledDefinition(id, definition, { organizationId });
    await this.versionRepository.setCompiledDefinition(version.id, definition, {
      organizationId,
    });
    this.logger.log(
      `Compiled workflow ${workflow.id} version ${version.version} with ${definition.actions.length} action(s); entrypoint=${definition.entrypoint.ref}`,
    );
    return definition;
  }

  async run(
    id: string,