Skip to content

feat: add summary generators for map/parallel operations#84

Merged
1 commit merged intomainfrom
map-parallel-summary
Oct 22, 2025
Merged

feat: add summary generators for map/parallel operations#84
1 commit merged intomainfrom
map-parallel-summary

Conversation

@ghost
Copy link

@ghost ghost commented Oct 22, 2025

Implement summary generators to handle large BatchResult payloads (>256KB) in map and parallel operations, matching TypeScript SDK behavior. When results exceed checkpoint size limit, operations use ReplayChildren mode with compact JSON summaries instead of full result serialization.

Key changes:

  • Add SummaryGenerator protocol and default implementations
  • Extend ParallelConfig/MapConfig with summary_generator field
  • Update ConcurrentExecutor to pass summary generators to child contexts
  • Implement replay_children logic based on payload size, not generator presence
  • Add test coverage for small/large payload scenarios

This enables efficient handling of large concurrent operation results while maintaining deterministic replay behavior and preventing checkpoint size violations.

By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.

Implement summary generators to handle large BatchResult payloads
(>256KB) in map and parallel operations, matching TypeScript SDK
behavior. When results exceed checkpoint size limit, operations
use ReplayChildren mode with compact JSON summaries instead of
full result serialization.

Key changes:
- Add SummaryGenerator protocol and default implementations
- Extend ParallelConfig/MapConfig with summary_generator field
- Update ConcurrentExecutor to pass summary generators to child contexts
- Implement replay_children logic based on payload size, not generator
  presence
- Add test coverage for small/large payload scenarios

This enables efficient handling of large concurrent operation results
while maintaining deterministic replay behavior and preventing
checkpoint size violations.
@ghost ghost merged commit 5abdb88 into main Oct 22, 2025
6 checks passed
@wangyb-A wangyb-A deleted the map-parallel-summary branch December 9, 2025 22:29
This pull request was closed.
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