Skip to content

perf(cli): parallelize scenario log downloads with max concurrency of 50#176

Merged
jrvb-rl merged 1 commit intomainfrom
agent/parallel-bmj-logs
Mar 17, 2026
Merged

perf(cli): parallelize scenario log downloads with max concurrency of 50#176
jrvb-rl merged 1 commit intomainfrom
agent/parallel-bmj-logs

Conversation

@rlagentflowbeta
Copy link
Contributor

Summary

  • Replace the serial download loop in rli bmj logs with a concurrent executor capped at 50 simultaneous downloads
  • Adds a small runWithConcurrency helper that distributes tasks across N workers using a shared index
  • Output lines are printed atomically per-download (one full line with ✓ on success) since the old "write prefix / complete line" pattern doesn't work in parallel

Test plan

  • Run rli bmj logs <job-id> on a job with many scenarios and confirm downloads complete much faster
  • Verify the output directory structure matches the previous behaviour (<output-dir>/<agent>/<scenario>/)
  • Verify results.json is written correctly for each scenario
  • Confirm failed downloads still produce warning messages and the final summary counts correctly

🤖 Generated with Claude Code

Replace the serial download loop in `bmj logs` with a concurrent executor
capped at 50 simultaneous downloads. This significantly reduces wall-clock
time when a job has many scenarios. Output lines are printed atomically as
each download completes.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
@rlagentflowbeta
Copy link
Contributor Author

🤖 This PR was created by Agent Flow.

View the agent run →

@jrvb-rl jrvb-rl changed the title perf(bmj): parallelize scenario log downloads with max concurrency of 50 perf(cli): parallelize scenario log downloads with max concurrency of 50 Mar 17, 2026
@jrvb-rl
Copy link
Contributor

jrvb-rl commented Mar 17, 2026

Patched into a local copy and verified that this works as expected (and it's definitely much faster!)

@jrvb-rl jrvb-rl enabled auto-merge (squash) March 17, 2026 09:58
Copy link
Contributor

@james-rl james-rl left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Looks great! I'm very excited for this change!

Tiny comment: if you change the await to allSettled instead all then the entire promise array will execute instead of bailing if one of the operations fails. I think this is probably better in this particular case.

{ length: Math.min(maxConcurrency, tasks.length) },
() => worker(),
);
await Promise.all(workers);
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

consider making this allSettled instead of all

@jrvb-rl jrvb-rl merged commit a5828a2 into main Mar 17, 2026
14 of 15 checks passed
@jrvb-rl jrvb-rl deleted the agent/parallel-bmj-logs branch March 17, 2026 16:36
dines-rl pushed a commit that referenced this pull request Mar 25, 2026
🤖 I have created a release *beep* *boop*
---


##
[1.14.0](v1.13.3...v1.14.0)
(2026-03-25)


### Features

* add 'logs' command to download info from devboxes
([#164](#164))
([d5354be](d5354be))
* use total_count field from Pagination API response
([#175](#175))
([4e84f30](4e84f30))


### Bug Fixes

* **benchmark:** fix benchmark id when creating job with benchmark
([#170](#170))
([2c73cba](2c73cba))
* bmj list now counts finished scenarios from in-progress runs
([#168](#168))
([123f1d4](123f1d4))
* **cli:** show failure reason when benchmark job fails with no outcomes
([#182](#182))
([817b5cd](817b5cd))
* **cli:** use allSettled() instead of all() so one bad download doesn't
spoil the barrel
([#178](#178))
([8f4145a](8f4145a))
* don't reset TUI menu cursor on back
([#181](#181))
([6cc35a7](6cc35a7))
* eliminate flicker in bmj watch and show job elapsed time
([#167](#167))
([9b1deed](9b1deed))
* prevent double devbox creation when pressing Enter in interactive form
([#173](#173))
([23f8a28](23f8a28))
* scenarios sometimes listed as in progress after bmj completes
([#174](#174))
([78f8f55](78f8f55))
* update broken tests
([#169](#169))
([d8b35a2](d8b35a2))


### Performance Improvements

* **cli:** parallelize scenario log downloads with max concurrency of 50
([#176](#176))
([a5828a2](a5828a2))
* **cli:** parallelize scenario run fetching and name resolution in bmj
logs ([#179](#179))
([227d0fd](227d0fd))

---
This PR was generated with [Release
Please](https://github.com/googleapis/release-please). See
[documentation](https://github.com/googleapis/release-please#release-please).

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants