diff --git a/worker/pkg/benthos/utils.go b/worker/pkg/benthos/utils.go
index 703c2c4e4c..c866b3aac3 100644
--- 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 {