This is an automated email from the ASF dual-hosted git repository.
amoghdesai pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 5248f0e81dc Remove go test parallelism to fix ci (#51388)
5248f0e81dc is described below
commit 5248f0e81dc21267fbefe42da4fb511a6fdfa032
Author: Amogh Desai <[email protected]>
AuthorDate: Wed Jun 4 12:48:18 2025 +0530
Remove go test parallelism to fix ci (#51388)
---
go-sdk/worker/runner_test.go | 3 ---
1 file changed, 3 deletions(-)
diff --git a/go-sdk/worker/runner_test.go b/go-sdk/worker/runner_test.go
index b2fa4382b0e..e70eea13401 100644
--- a/go-sdk/worker/runner_test.go
+++ b/go-sdk/worker/runner_test.go
@@ -86,7 +86,6 @@ func (s *WorkerSuite) SetupSuite() {
}
func (s *WorkerSuite) TestWithServer() {
- s.T().Parallel()
s.worker.(*worker).heartbeatInterval = 100 * time.Millisecond
iface, err := s.worker.WithServer("http://example.com";)
@@ -151,7 +150,6 @@ func (s *WorkerSuite) BodyJSONMatches(expected []byte)
httpmock.Matcher {
// TestTaskNotRegisteredErrors checks that when a task cannot be found we
report "success" on the Workload but
// report the task as failed to the Execution API server
func (s *WorkerSuite) TestTaskNotRegisteredErrors() {
- s.T().Parallel()
id := uuid.New().String()
testWorkload := newTestWorkLoad(id, id[:8])
s.ExpectTaskState(id, api.TerminalTIStateFailed)
@@ -188,7 +186,6 @@ func (s *WorkerSuite)
TestTaskReturnErrorReportsFailedState() {
}
func (s *WorkerSuite) TestTaskHeartbeatsWhileRunning() {
- s.T().Parallel()
id := uuid.New().String()
testWorkload := newTestWorkLoad(id, id[:8])
s.worker.RegisterTaskWithName(testWorkload.TI.DagId,
testWorkload.TI.TaskId, func() error {
