Skip to content

[WIP] Switch to tokio's LocalRuntime for partition processors#4671

Draft
AhmedSoliman wants to merge 1 commit intomainfrom
pr4671
Draft

[WIP] Switch to tokio's LocalRuntime for partition processors#4671
AhmedSoliman wants to merge 1 commit intomainfrom
pr4671

Conversation

@AhmedSoliman
Copy link
Copy Markdown
Contributor

@AhmedSoliman AhmedSoliman commented Apr 29, 2026

This variant allows spawn_local without the need for the localset.


Stack created with Sapling. Best reviewed with ReviewStack.

This variant allows spawn_local without the need for the localset.
@AhmedSoliman AhmedSoliman mentioned this pull request Apr 29, 2026
@github-actions
Copy link
Copy Markdown

Test Results

  8 files  ± 0    8 suites  ±0   2m 5s ⏱️ - 3m 15s
 50 tests  -  3   50 ✅  -  3  0 💤 ±0  0 ❌ ±0 
218 runs   - 15  218 ✅  - 15  0 💤 ±0  0 ❌ ±0 

Results for commit 998eddf. ± Comparison against base commit a0d94a4.

This pull request removes 4 and adds 1 tests. Note that renamed tests count towards both.
dev.restate.sdktesting.tests.KafkaIngress ‑ handleEventInCounterService(URI, int, Client)
dev.restate.sdktesting.tests.KafkaIngress ‑ handleEventInEventHandler(URI, int, Client)
dev.restate.sdktesting.tests.UpgradeWithInFlightInvocation ‑ inFlightInvocation(Client, URI)
dev.restate.sdktesting.tests.UpgradeWithNewInvocation ‑ executesNewInvocationWithLatestServiceRevisions(Client, URI)
dev.restate.sdktesting.tests.Custom ‑ run(CustomTestConfig, URI, URI)[1]

@github-actions
Copy link
Copy Markdown

github-actions Bot commented Apr 29, 2026

Test Results

  7 files   -  1    7 suites   - 1   2m 56s ⏱️ - 2m 24s
 47 tests  -  6   47 ✅  -  6  0 💤 ±0  0 ❌ ±0 
200 runs   - 33  200 ✅  - 33  0 💤 ±0  0 ❌ ±0 

Results for commit 998eddf. ± Comparison against base commit a0d94a4.

This pull request removes 6 tests.
dev.restate.sdktesting.tests.Combinators ‑ awakeableOrTimeoutUsingAwaitAny(Client)
dev.restate.sdktesting.tests.Combinators ‑ firstSuccessfulCompletedAwakeable(Client)
dev.restate.sdktesting.tests.UserErrors ‑ failSeveralTimesWithMetadata(URI)
dev.restate.sdktesting.tests.UserErrors ‑ internalCallFailurePropagationWithMetadata(URI)
dev.restate.sdktesting.tests.UserErrors ‑ invokeTerminallyFailingCallWithMetadata(URI)
dev.restate.sdktesting.tests.UserErrors ‑ sideEffectWithTerminalErrorWithMetadata(URI)

♻️ This comment has been updated with latest results.

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.

1 participant