Merge pull request #138 from nrkno/blocking-again

creation, update and deletion are blocking
nrkno · Jul 28, 2023 · 66b1e09 · 66b1e09
2 parents 2b667a5 + 64ec027
commit 66b1e09
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/core/src/main/scala/no/nrk/bigquery/BigQueryClient.scala b/core/src/main/scala/no/nrk/bigquery/BigQueryClient.scala
@@ -493,13 +493,13 @@ class BigQueryClient[F[_]](
     }
 
   def create(table: TableInfo): F[Table] =
-    F.delay(bigQuery.create(table))
+    F.blocking(bigQuery.create(table))
 
   def update(table: TableInfo): F[Table] =
-    F.delay(bigQuery.update(table))
+    F.blocking(bigQuery.update(table))
 
   def delete(tableId: BQTableId): F[Boolean] =
-    F.delay(bigQuery.delete(tableId.underlying))
+    F.blocking(bigQuery.delete(tableId.underlying))
 
   def tablesIn(
       dataset: BQDataset,
@@ -541,13 +541,13 @@ class BigQueryClient[F[_]](
     }
 
   def create(info: RoutineInfo): F[Routine] =
-    F.delay(bigQuery.create(info))
+    F.blocking(bigQuery.create(info))
 
   def update(info: RoutineInfo): F[Routine] =
-    F.delay(bigQuery.update(info))
+    F.blocking(bigQuery.update(info))
 
   def delete(udfId: UDF.UDFId.PersistentId): F[Boolean] =
-    F.delay(bigQuery.delete(RoutineId.of(udfId.dataset.project.value, udfId.dataset.id, udfId.name.value)))
+    F.blocking(bigQuery.delete(RoutineId.of(udfId.dataset.project.value, udfId.dataset.id, udfId.name.value)))
 
 }