diff --git a/flow/e2e/test_utils.go b/flow/e2e/test_utils.go
index eb48367f12..c2371bf7c7 100644
--- a/flow/e2e/test_utils.go
+++ b/flow/e2e/test_utils.go
@@ -237,7 +237,10 @@ func CreateTableForQRep(pool *pgxpool.Pool, suffix string, tableName string) err
 	tblFieldStr := strings.Join(tblFields, ",")
 	var pgErr *pgconn.PgError
 	_, enumErr := pool.Exec(context.Background(), createMoodEnum)
-	if errors.As(enumErr, &pgErr) && pgErr.Code != pgerrcode.DuplicateObject {
+	if errors.As(enumErr, &pgErr) &&
+		pgErr.Code != pgerrcode.DuplicateObject &&
+		// S3 and GCS in parallel creating the same type
+		pgErr.Code != pgerrcode.UniqueViolation {
 		return enumErr
 	}
 	_, err := pool.Exec(context.Background(), fmt.Sprintf(`