(
@Param('runId') runId: string,
@Query(new ZodValidationPipe(TemporalRunQuerySchema)) query: TemporalRunQueryDto,
@CurrentAuth() auth: AuthContext | null,
)
| 665 | description: 'Current Temporal execution status', |
| 666 | }) |
| 667 | async status( |
| 668 | @Param('runId') runId: string, |
| 669 | @Query(new ZodValidationPipe(TemporalRunQuerySchema)) query: TemporalRunQueryDto, |
| 670 | @CurrentAuth() auth: AuthContext | null, |
| 671 | ) { |
| 672 | const result = await this.workflowsService.getRunStatus(runId, query.temporalRunId, auth); |
| 673 | if (TERMINAL_COMPLETION_STATUSES.has(result.status)) { |
| 674 | this.terminalArchiveService.archiveRun(auth, runId).catch((error) => { |
| 675 | console.warn(`Failed to archive terminal after status fetch for run ${runId}`, error); |
| 676 | }); |
| 677 | } |
| 678 | return result; |
| 679 | } |
| 680 | |
| 681 | @Get('/runs/:runId/result') |
| 682 | @ApiOkResponse({ |
no test coverage detected