Skip to content

Commit

Permalink
update code comment
Browse files Browse the repository at this point in the history
  • Loading branch information
davidangb committed Oct 31, 2024
1 parent 4c9772a commit 47cd878
Showing 1 changed file with 3 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -402,16 +402,15 @@ class HttpGoogleServicesDAO(priceListUrl: String, defaultPriceList: GooglePriceL
.getTokenValue

override def listBucket(bucketName: GcsBucketName, prefix: Option[String]): List[GcsObjectName] = {
// listObjectsWithPrefix handles paginating through results if there are more results than
// the `maxPageSize` setting.
val listAttempt = getStorageResource.use { storageService =>
storageService
.listObjectsWithPrefix(bucketName, prefix.getOrElse(""), maxPageSize = 5000, isRecursive = true)
.listObjectsWithPrefix(bucketName, prefix.getOrElse(""), maxPageSize = 2000, isRecursive = true)
.compile
.toList
}

// TODO: recurse if there are more files in the bucket and we need to paginate? Does
// listObjectsWithPrefix handle that internally?

// execute the upload
listAttempt.unsafeRunSync()
}
Expand Down

0 comments on commit 47cd878

Please sign in to comment.