We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a6bd21a commit e999995Copy full SHA for e999995
1 file changed
sdks/python/container/boot.go
@@ -268,9 +268,11 @@ func launchSDKProcess() error {
268
// DoFns throwing exceptions.
269
errorCount += 1
270
if errorCount < 4 {
271
- log.Printf("Python (worker %v) exited: %v", workerId, err)
+ log.Printf("Python (worker %v) exited %v times: %v\nrestarting SDK process",
272
+ workerId, errorCount, err)
273
} else {
- log.Fatalf("Python (worker %v) exited: %v", workerId, err)
274
+ log.Fatalf("Python (worker %v) exited %v times: %v\nout of retries, failing container",
275
276
}
277
278
log.Printf("Python (worker %v) exited.", workerId)
0 commit comments