handle-exceed-column-limit amendments 2

snowplow-incubator · Apr 2, 2024 · 479e759 · 479e759
1 parent 85e0f07
commit 479e759
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/...core/src/main/scala/com.snowplowanalytics.snowplow.bigquery/processing/TableManager.scala b/...core/src/main/scala/com.snowplowanalytics.snowplow.bigquery/processing/TableManager.scala
@@ -87,6 +87,13 @@ object TableManager {
       def createTable: F[Unit] =
         BigQueryRetrying.withRetries(appHealth, retries, monitoring, Alert.FailedToCreateEventsTable(_)) {
           underlying.createTable
+            .recoverWith {
+              case bqe: BigQueryException if bqe.lowerCaseReason === "duplicate" =>
+                // Table already exists
+                Logger[F].info(s"Ignoring error when creating table: ${bqe.getMessage}")
+              case bqe: BigQueryException if bqe.lowerCaseReason === "accessdenied" =>
+                Logger[F].info(s"Access denied when trying to create table. Will ignore error and assume table already exists.")
+            }
         }
     }
 
@@ -112,13 +119,6 @@ object TableManager {
         Sync[F]
           .blocking(client.create(tableInfo))
           .void
-          .recoverWith {
-            case bqe: BigQueryException if bqe.lowerCaseReason === "duplicate" =>
-              // Table already exists
-              Logger[F].info(s"Ignoring error when creating table: ${bqe.getMessage}")
-            case bqe: BigQueryException if bqe.lowerCaseReason === "accessdenied" =>
-              Logger[F].info(s"Access denied when trying to create table. Will ignore error and assume table already exists.")
-          }
     }
   }