From bbd9deb813ea7215290b2da26f9fa17b55340026 Mon Sep 17 00:00:00 2001 From: Amogh-Bharadwaj Date: Tue, 9 Jan 2024 02:29:34 +0530 Subject: [PATCH] fix qrep test --- flow/e2e/test_utils.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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(`