test(bigquerystorage): increase await timeout for createReadSession to 1 minute (#14125)

## Description
Increases the `await()` timeout to 1 minute in `ITBigQueryStorageTest`
(v1beta1, v1beta2) and adds the 1-minute retry logic to the production
v1 test helper (`Helper.processRowsAtSnapshot`) when creating read
sessions.

### Context
In CI environments, table metadata propagation from
`bigquery.googleapis.com` to `bigquerystorage.googleapis.com` can take
longer than 10 seconds, causing `ConditionTimeoutException` or
`NotFoundException` test flakes (e.g., in
`sponge/b1dc622b-9c70-41cb-953e-74c2dfbb3f31`).

Setting a 1-minute retry ceiling:
- Provides sufficient buffer for metadata propagation across busy CI
runners.
- Ensures consistency across v1, v1beta1, and v1beta2 test suites.
- Matches the 1-minute timeout used elsewhere in the test suite (e.g.
`job.waitFor(...,
RetryOption.totalTimeoutDuration(Duration.ofMinutes(1)))`).
- Adds zero extra latency to successful runs, as `await()` returns
immediately upon session creation.

Author: lqiu96

java-bigquerystorage/google-cloud-bigquerystorage-it/src/test/java/com/google/cloud/bigquery/storage/v1/it/util/Helper.java

@@ -16,10 +16,12 @@
 
 package com.google.cloud.bigquery.storage.v1.it.util;
 
+import static org.awaitility.Awaitility.await;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.fail;
 
 import com.google.api.core.ApiFutureCallback;
+import com.google.api.gax.rpc.NotFoundException;
 import com.google.api.gax.rpc.ServerStream;
 import com.google.auth.oauth2.ServiceAccountCredentials;
 import com.google.cloud.bigquery.storage.v1.AppendRowsResponse;
@@ -38,8 +40,10 @@
 import java.io.ByteArrayInputStream;
 import java.io.IOException;
 import java.io.InputStream;
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.atomic.AtomicReference;
 import org.apache.avro.Schema;
 import org.apache.avro.generic.GenericData;
 import org.apache.avro.generic.GenericRecordBuilder;
@@ -159,7 +163,19 @@ public static void processRowsAtSnapshot(
               ReadSession.TableReadOptions.newBuilder().setRowRestriction(filter).build());
     }
 
-    ReadSession session = client.createReadSession(createSessionRequestBuilder.build());
+    CreateReadSessionRequest request = createSessionRequestBuilder.build();
+    AtomicReference<ReadSession> sessionRef = new AtomicReference<>();
+    await()
+        .atMost(Duration.ofMinutes(1))
+        .pollInterval(Duration.ofSeconds(1))
+        // retry if the newly-created table has not yet fully propagated
+        .ignoreException(NotFoundException.class)
+        .until(
+            () -> {
+              sessionRef.set(client.createReadSession(request));
+              return true;
+            });
+    ReadSession session = sessionRef.get();
     assertEquals(
         1,
         session.getStreamsCount(),

java-bigquerystorage/google-cloud-bigquerystorage-it/src/test/java/com/google/cloud/bigquery/storage/v1beta1/it/ITBigQueryStorageTest.java

@@ -1236,7 +1236,7 @@ private void ProcessRowsAtSnapshot(
     CreateReadSessionRequest request = createSessionRequestBuilder.build();
     AtomicReference<ReadSession> sessionRef = new AtomicReference<>();
     await()
-        .atMost(Duration.ofSeconds(10))
+        .atMost(Duration.ofMinutes(1))
         .pollInterval(Duration.ofSeconds(1))
         // retry if the newly-created table has not yet fully propagated
         .ignoreException(NotFoundException.class)

java-bigquerystorage/google-cloud-bigquerystorage-it/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryStorageTest.java

@@ -1217,7 +1217,7 @@ private void ProcessRowsAtSnapshot(
     CreateReadSessionRequest request = createSessionRequestBuilder.build();
     AtomicReference<ReadSession> sessionRef = new AtomicReference<>();
     await()
-        .atMost(Duration.ofSeconds(10))
+        .atMost(Duration.ofMinutes(1))
         .pollInterval(Duration.ofSeconds(1))
         // retry if the newly-created table has not yet fully propagated
         .ignoreException(NotFoundException.class)