fix: transformation does not retry indefinitely when control plane is…

… down (#3581)
rudderlabs · Jul 5, 2023 · 1c6fc24 · 1c6fc24
1 parent 5c442c0
commit 1c6fc24
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/processor/transformer/transformer.go b/processor/transformer/transformer.go
@@ -397,7 +397,7 @@ func (trans *HandleT) doPost(ctx context.Context, rawJSON []byte, url string, ta
 				return reqErr
 			}
 			defer func() { httputil.CloseResponse(resp) }()
-			if !isJobTerminated(resp.StatusCode) {
+			if !isJobTerminated(resp.StatusCode) && resp.StatusCode != StatusCPDown {
 				return fmt.Errorf("transformer returned status code: %v", resp.StatusCode)
 			}
 			respData, reqErr = io.ReadAll(resp.Body)

diff --git a/processor/transformer/transformer_test.go b/processor/transformer/transformer_test.go
@@ -130,6 +130,10 @@ func Test_Transformer(t *testing.T) {
 }
 
 func Test_EndlessLoopIf809(t *testing.T) {
+	config.Reset()
+	defer config.Reset()
+	logger.Reset()
+	config.Set("Processor.maxRetry", 1)
 	transformer.Init()
 
 	ft := &endlessLoopTransformer{