Method getRunStatus

backend/src/workflows/workflows.service.ts:1064–1157

(
    runId: string,
    temporalRunId?: string,
    auth?: AuthContext | null,
  )

  }

  async getRunStatus(
    runId: string,
    temporalRunId?: string,
    auth?: AuthContext | null,
  ): Promise<WorkflowRunStatusPayload> {
    this.logger.log(
      `Fetching status for workflow run ${runId} (temporalRunId=${temporalRunId ?? 'latest'})`,
    );
    const { organizationId, run } = await this.requireRunAccess(runId, auth);

    let temporalStatus: Awaited<ReturnType<typeof this.temporalService.describeWorkflow>>;
    let completedActions = 0;
    let failedActions = 0;
    let startedActions = 0;

    // Pre-fetch trace event counts for status inference
    if (run.totalActions && run.totalActions > 0) {
      [completedActions, failedActions, startedActions] = await Promise.all([
        this.traceRepository.countByType(runId, 'NODE_COMPLETED', organizationId),
        this.traceRepository.countByType(runId, 'NODE_FAILED', organizationId),
        this.traceRepository.countByType(runId, 'NODE_STARTED', organizationId),
      ]);
    }

    try {
      temporalStatus = await this.temporalService.describeWorkflow({
        workflowId: runId,
        runId: temporalRunId,
      });
    } catch (error) {
      // If Temporal can't find the workflow, infer status from trace events
      if (this.isNotFoundError(error)) {
        const inferredStatus = this.inferStatusFromTraceEvents({
          runId,
          totalActions: run.totalActions ?? 0,
          completedActions,
          failedActions,
          startedActions,
        });

        this.logger.log(
          `Workflow ${runId} not found in Temporal, inferred status: ${inferredStatus} ` +
            `(started=${startedActions}, completed=${completedActions}, failed=${failedActions}, total=${run.totalActions})`,
        );

        temporalStatus = {
          workflowId: runId,
          runId: temporalRunId ?? runId,
          // Cast to WorkflowExecutionStatusName - normalizeStatus handles mapping
          status: inferredStatus as unknown as typeof temporalStatus.status,
          startTime: run.createdAt.toISOString(),
          // Only set closeTime for terminal states that actually ran
          closeTime: ['COMPLETED', 'FAILED'].includes(inferredStatus)
            ? new Date().toISOString()
            : undefined,
          historyLength: 0,
          taskQueue: '',
        };