Function taskBlockOpenAt

internal/task/manager_test.go:945–950

(block TaskBlock, now time.Time)

}

func taskBlockOpenAt(block TaskBlock, now time.Time) bool {
	if !block.ClearedAt.IsZero() {
		return false
	}
	return block.ExpiresAt.IsZero() || block.ExpiresAt.After(now)
}

func (s *inMemoryManagerStore) CreateDependency(_ context.Context, dependency Dependency) error {
	if _, ok := s.tasks[dependency.TaskID]; !ok {