Stream errors (#173)

* catch stream error 3

CHANGELOG.md

@@ -4,7 +4,12 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [0.8.5] - 2021-10-22
+### Added
+* Retry logging on stream INTERNAL_ERROR errors
+
 ## [0.8.4] - 2021-10-21
+### Added
 * Add `X-Accel-Buffering=no` header to service response calls for log streaming.
 
 ## [0.8.3] - 2021-10-05

cli/internal/api/api.go

@@ -81,10 +81,11 @@ func (c *Client) GetLogs(ctx context.Context, workflowName string) (responses.Ge
 func (c *Client) StreamLogs(ctx context.Context, w io.Writer, workflowName string) error {
 	var loggingCursorByte int64
 	// When we receive a stream error we continue and retry processing up to 5 times keeping track of the byte we were logging.
-	for i := 0; i < 5; i++ {
+	for i := 0; i < 10; i++ {
 		err := c.streamLogsToWriterAtCursor(ctx, w, workflowName, &loggingCursorByte)
 		if err != nil {
-			if strings.Contains(err.Error(), "stream error: stream ID 1; INTERNAL_ERROR") {
+			// if connection idle timeout occurs retry
+			if strings.Contains(err.Error(), "stream error: stream ID 1; INTERNAL_ERROR") || strings.Contains(err.Error(), "stream error: stream ID 3; INTERNAL_ERROR") {
 				time.Sleep(time.Second * 10)
 				continue
 			}