Increase expansion service connection timeout to 30 sec. (#36256)

shunping · web-flow · commit 17c851546905 · 2025-09-23T21:42:02.000-04:00
diff --git a/sdks/go/pkg/beam/core/runtime/xlangx/expansionx/process.go b/sdks/go/pkg/beam/core/runtime/xlangx/expansionx/process.go
@@ -94,7 +94,7 @@ func (e *ExpansionServiceRunner) pingEndpoint(timeout time.Duration) error {
 	return nil
 }
 
-const connectionTimeout = 15 * time.Second
+const connectionTimeout = 30 * time.Second
 
 // StartService starts the expansion service for a given ExpansionServiceRunner. If this is
 // called and does not return an error, the expansion service will be running in the background

Original file line number	Diff line number	Diff line change
`@@ -94,7 +94,7 @@ func (e *ExpansionServiceRunner) pingEndpoint(timeout time.Duration) error {`
`94`	`94`	`return nil`
`95`	`95`	`}`
`96`	`96`
`97`		`-const connectionTimeout = 15 * time.Second`
	`97`	`+const connectionTimeout = 30 * time.Second`
`98`	`98`
`99`	`99`	`// StartService starts the expansion service for a given ExpansionServiceRunner. If this is`
`100`	`100`	`// called and does not return an error, the expansion service will be running in the background`