Skip to content

feat: [Parallel] Remove duplicate complete furture#239

Merged
wangyb-A merged 1 commit intomainfrom
parallel/complete
Mar 19, 2026
Merged

feat: [Parallel] Remove duplicate complete furture#239
wangyb-A merged 1 commit intomainfrom
parallel/complete

Conversation

@wangyb-A
Copy link
Contributor

@wangyb-A wangyb-A commented Mar 19, 2026

By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.

Issue Link, if available

Description

  • Remove duplicate complete furture for concurrency op
  • Add markAlreadyCompleted() for no-checkpoint replay
  • Update unit tests

Demo/Screenshots

iShot_2026-03-19_14 45 15

Checklist

  • I have filled out every section of the PR template
  • I have thoroughly tested this change

Testing

Unit Tests

Have unit tests been written for these changes? Yes

Integration Tests

Have integration tests been written for these changes? Not yet

Examples

Has a new example been added for the change? (if applicable) Existing

@wangyb-A wangyb-A requested a review from a team March 19, 2026 21:47
@@ -69,25 +70,41 @@ void setUp() {
when(mockIdGenerator.nextOperationId()).thenAnswer(inv -> "child-" + operationIdCounter.incrementAndGet());
Copy link
Contributor

Choose a reason for hiding this comment

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

We don't have to mock OperationIdGenerator. We can use TestUtil::hashOperationId to generate a real one

@wangyb-A wangyb-A merged commit 0f073af into main Mar 19, 2026
12 checks passed
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