diff --git a/CHANGELOG.unreleased.md b/CHANGELOG.unreleased.md index 62c4fccb26e..cabd0d4c689 100644 --- a/CHANGELOG.unreleased.md +++ b/CHANGELOG.unreleased.md @@ -20,7 +20,8 @@ For upgrade instructions, please check the [migration guide](MIGRATIONS.released ### Fixed - Fixed a benign error message which briefly appeared after logging in. [#6810](https://github.com/scalableminds/webknossos/pull/6810) -- Fixed saving allowed teams in dataset settings [#6817](https://github.com/scalableminds/webknossos/pull/6817) +- Fixed saving allowed teams in dataset settings. [#6817](https://github.com/scalableminds/webknossos/pull/6817) +- Fixed log streaming in Voxelytics workflow reports. [#6828](https://github.com/scalableminds/webknossos/pull/6828) ### Removed diff --git a/app/models/voxelytics/LokiClient.scala b/app/models/voxelytics/LokiClient.scala index f1acfcfd566..66b75892f63 100644 --- a/app/models/voxelytics/LokiClient.scala +++ b/app/models/voxelytics/LokiClient.scala @@ -95,9 +95,9 @@ class LokiClient @Inject()(wkConf: WkConf, rpc: RPC, val system: ActorSystem)(im currentStartTime, currentEndTime, limit.getOrElse(LOG_ENTRY_BATCH_SIZE).min(LOG_ENTRY_BATCH_SIZE)) - newLimit = limit.map(l => l - headBatch.length) + newLimit = limit.map(l => (l - headBatch.length).max(0)) buffer <- if (headBatch.isEmpty) { - if (currentStartTime == startTime) { + if (currentStartTime == startTime || newLimit.contains(0L)) { Fox.successful(List()) } else { for {