Skip to content

Commit 7725f61

Browse files
committed
restore default chunk logging for now
1 parent e0dbbb3 commit 7725f61

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

core/src/main/scala/no/nrk/bigquery/BigQueryClient.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ class BigQueryClient[F[_]](
5858
legacySql: Boolean,
5959
jobOptions: Seq[JobOption]
6060
): Stream[F, A] =
61-
synchronousQuery(jobName, query, legacySql, jobOptions, logStream = false)
61+
synchronousQuery(jobName, query, legacySql, jobOptions, logStream = true)
6262

6363
def synchronousQuery[A](
6464
jobName: BQJobName,

core/src/main/scala/no/nrk/bigquery/util/StreamUtils.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ object StreamUtils {
3838
maybeTotal.fold("")(total => s"of $total")
3939
).mkString(" ")
4040

41-
logger.debug(msg).as((acc + chunk.size, chunk))
41+
logger.info(msg).as((acc + chunk.size, chunk))
4242
}.map(_._2)
4343

4444
def log[F[_]: Functor, T](

0 commit comments

Comments
 (0)