fix: request disable retry

Signed-off-by: Eray Ates <eray.ates@worldline.com>
worldline-go · Aug 15, 2024 · dfd8477 · dfd8477
1 parent f03c0f9
commit dfd8477
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/pkg/flow/nodes/request.go b/pkg/flow/nodes/request.go
@@ -195,7 +195,6 @@ func (n *Request) Run(ctx context.Context, _ *sync.WaitGroup, reg *registry.Regi
 	}
 
 	rendered.addHeadersRaw = buf.String()
-	// }
 
 	var addHeaders map[string]interface{}
 	if err := yaml.Unmarshal([]byte(rendered.addHeadersRaw), &addHeaders); err != nil {
@@ -323,7 +322,7 @@ func (n *Request) Fetch(ctx context.Context, db *gorm.DB) error {
 		SkipVerify: n.skipVerify,
 		Log:        n.log,
 		Retry: request.Retry{
-			Enabled:             true,
+			Enabled:             !n.retryDisabled,
 			EnabledStatusCodes:  retryCodes,
 			DisabledStatusCodes: retryDeCodes,
 		},