(action string)
| 3344 | } |
| 3345 | |
| 3346 | func (m *Service) requireSessionExecutor(action string) error { |
| 3347 | if m.sessions == nil { |
| 3348 | return fmt.Errorf("%w: session executor is required to %s", ErrValidation, action) |
| 3349 | } |
| 3350 | return nil |
| 3351 | } |
| 3352 | |
| 3353 | func (m *Service) collectTaskTree(ctx context.Context, rootTaskID string) ([]Task, error) { |
| 3354 | root, err := m.store.GetTask(ctx, rootTaskID) |
no outgoing calls
no test coverage detected