adds transaction error to critical errs (#3255)

nucleuscloud · Feb 12, 2025 · a641806 · a641806
1 parent 0578034
commit a641806
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/worker/pkg/benthos/utils.go b/worker/pkg/benthos/utils.go
@@ -41,6 +41,7 @@ func IsCriticalError(errMsg string) bool {
 		"does not exist",
 		"syntax error at or near",
 		"ON CONFLICT DO UPDATE requires inference specification or constraint name",
+		"transaction has already been committed or rolled back",
 	}
 
 	for _, errStr := range criticalErrors {