=== Failed
--
  | === FAIL: filebeat/input/filestream/internal/task TestGroup_Go/workloads_wait_for_available_worker (0.15s)
  | group_test.go:123: f2 started
  | group_test.go:110: f1 started
  | group_test.go:129: f2 done
  | group_test.go:142: f3 started
  | group_test.go:176: waiting the worker pool to finish all workloads
  | group_test.go:112: f1 done
  | group_test.go:144: f3 done
  | group_test.go:179: worker pool to finished all workloads
  | group_test.go:181:
  | Error Trace:	C:/buildkite-agent/builds/bk-agent-prod-gcp-1728676855326850128/elastic/filebeat/filebeat/input/filestream/internal/task/group_test.go:181
  | Error:      	Condition never satisfied
  | Test:       	TestGroup_Go/workloads_wait_for_available_worker
  | Messages:   	not all goroutines finished
  |  
  | === FAIL: filebeat/input/filestream/internal/task TestGroup_Go (0.57s)

PS C:\devel\beats\filebeat\input\filestream\internal\task> go test -count=1000 -run=TestGroup_Go
--- FAIL: TestGroup_Go (0.11s)
    --- FAIL: TestGroup_Go/some_workloads_return_an_error (0.00s)
        group_test.go:280:
                Error Trace:    C:/devel/beats/filebeat/input/filestream/internal/task/group_test.go:280
                Error:          "task.Group: semaphore acquire failed, was the task group closed? err: context canceled\ntask.Group: semaphore acquire failed, was the task group closed? err: context canceled\n" does not contain "a error"
                Test:           TestGroup_Go/some_workloads_return_an_error
--- FAIL: TestGroup_Go (0.11s)
    --- FAIL: TestGroup_Go/some_workloads_return_an_error (0.00s)
        group_test.go:280:
                Error Trace:    C:/devel/beats/filebeat/input/filestream/internal/task/group_test.go:280
                Error:          "task.Group: semaphore acquire failed, was the task group closed? err: context canceled\ntask.Group: semaphore acquire failed, was the task group closed? err: context canceled\n" does not contain "a error"
                Test:           TestGroup_Go/some_workloads_return_an_error
--- FAIL: TestGroup_Go (0.11s)
    --- FAIL: TestGroup_Go/some_workloads_return_an_error (0.00s)
        group_test.go:280:
                Error Trace:    C:/devel/beats/filebeat/input/filestream/internal/task/group_test.go:280
                Error:          "task.Group: semaphore acquire failed, was the task group closed? err: context canceled\ntask.Group: semaphore acquire failed, was the task group closed? err: context canceled\n" does not contain "a error"
                Test:           TestGroup_Go/some_workloads_return_an_error
FAIL
exit status 1
FAIL    github.com/elastic/beats/v7/filebeat/input/filestream/internal/task     111.404s