(ctx context.Context, sessionID string)
| 1310 | } |
| 1311 | |
| 1312 | func (m *Service) stopUnboundStartedTaskSession(ctx context.Context, sessionID string) error { |
| 1313 | trimmedSessionID := strings.TrimSpace(sessionID) |
| 1314 | if trimmedSessionID == "" || m.sessions == nil { |
| 1315 | return nil |
| 1316 | } |
| 1317 | requestErr := m.sessions.RequestTaskStop(ctx, trimmedSessionID, StopReasonFailed) |
| 1318 | forceErr := m.sessions.ForceTaskStop(ctx, trimmedSessionID, StopReasonFailed) |
| 1319 | if requestErr != nil { |
| 1320 | requestErr = fmt.Errorf("task: request stop for unbound session %q: %w", trimmedSessionID, requestErr) |
| 1321 | } |
| 1322 | if forceErr != nil { |
| 1323 | forceErr = fmt.Errorf("task: force stop unbound session %q: %w", trimmedSessionID, forceErr) |
| 1324 | } |
| 1325 | return errorsJoin(requestErr, forceErr) |
| 1326 | } |
| 1327 | |
| 1328 | func (m *Service) failRunAfterSessionStartError( |
| 1329 | ctx context.Context, |
no test coverage detected