(
@Param('runId') runId: string,
@Query(new ZodValidationPipe(WorkflowLogsQuerySchema))
query: WorkflowLogsQueryDto,
@CurrentAuth() auth: AuthContext | null,
)
| 1143 | }, |
| 1144 | }) |
| 1145 | async logs( |
| 1146 | @Param('runId') runId: string, |
| 1147 | @Query(new ZodValidationPipe(WorkflowLogsQuerySchema)) |
| 1148 | query: WorkflowLogsQueryDto, |
| 1149 | @CurrentAuth() auth: AuthContext | null, |
| 1150 | ) { |
| 1151 | return this.logStreamService.fetch(runId, auth, { |
| 1152 | nodeRef: query.nodeRef, |
| 1153 | stream: query.stream, |
| 1154 | level: query.level, |
| 1155 | limit: query.limit, |
| 1156 | cursor: query.cursor, |
| 1157 | startTime: query.startTime, |
| 1158 | endTime: query.endTime, |
| 1159 | }); |
| 1160 | } |
| 1161 | |
| 1162 | @Get('/runs/:runId/terminal') |
| 1163 | @ApiOkResponse({ |
no test coverage detected