(_ context.Context, taskID string)
| 710 | } |
| 711 | |
| 712 | func (s *inMemoryManagerStore) HasOpenTaskBlocks(_ context.Context, taskID string) (bool, error) { |
| 713 | trimmedTaskID := strings.TrimSpace(taskID) |
| 714 | if _, ok := s.tasks[trimmedTaskID]; !ok { |
| 715 | return false, ErrTaskNotFound |
| 716 | } |
| 717 | now := time.Date(2026, 4, 14, 15, 0, 0, 0, time.UTC) |
| 718 | for _, block := range s.blocks[trimmedTaskID] { |
| 719 | if taskBlockOpenAt(block, now) { |
| 720 | return true, nil |
| 721 | } |
| 722 | } |
| 723 | return false, nil |
| 724 | } |
| 725 | |
| 726 | func (s *inMemoryManagerStore) CreateTaskBlock( |
| 727 | _ context.Context, |
nothing calls this directly
no test coverage detected