This is an automated email from the ASF dual-hosted git repository. lostluck pushed a commit to branch timermgr in repository https://gitbox.apache.org/repos/asf/beam.git
commit 7c618231706c405f9c46c82a9fd061725f43a6ed Author: Robert Bradshaw <[email protected]> AuthorDate: Tue Feb 14 17:04:03 2023 -0800 More verbose messaging. --- sdks/python/container/boot.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/sdks/python/container/boot.go b/sdks/python/container/boot.go index 4572f43f8a9..bb9acbacf62 100644 --- a/sdks/python/container/boot.go +++ b/sdks/python/container/boot.go @@ -268,9 +268,11 @@ func launchSDKProcess() error { // DoFns throwing exceptions. errorCount += 1 if errorCount < 4 { - log.Printf("Python (worker %v) exited: %v", workerId, err) + log.Printf("Python (worker %v) exited %v times: %v\nrestarting SDK process", + workerId, errorCount, err) } else { - log.Fatalf("Python (worker %v) exited: %v", workerId, err) + log.Fatalf("Python (worker %v) exited %v times: %v\nout of retries, failing container", + workerId, errorCount, err) } } else { log.Printf("Python (worker %v) exited.", workerId)
