diff --git a/flow/e2e/test_utils.go b/flow/e2e/test_utils.go
index c2337f21d0..1ed60196eb 100644
--- a/flow/e2e/test_utils.go
+++ b/flow/e2e/test_utils.go
@@ -64,7 +64,7 @@ func GetPgRows(pool *pgxpool.Pool, suffix string, tableName string, cols string)
 	pgQueryExecutor.SetTestEnv(true)
 
 	return pgQueryExecutor.ExecuteAndProcessQuery(
-		fmt.Sprintf("SELECT %s FROM e2e_test_%s.%s ORDER BY id", cols, suffix, tableName),
+		fmt.Sprintf(`SELECT %s FROM e2e_test_%s."%s" ORDER BY id`, cols, suffix, tableName),
 	)
 }