Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Prevent race condition in ResponseTracker by using entry which holds the lock #1532

Merged
merged 1 commit into from
May 22, 2024

Prevent race condition in ResponseTracker by using entry which holds …

abed7e0
Select commit
Loading
Failed to load commit list.
Sign in for the full log view
Merged

Prevent race condition in ResponseTracker by using entry which holds the lock #1532

Prevent race condition in ResponseTracker by using entry which holds …
abed7e0
Select commit
Loading
Failed to load commit list.
GitHub Actions / Test Results succeeded May 22, 2024 in 0s

All 82 tests pass, 1 skipped in 8m 21s

 99 files  + 65   99 suites  +65   8m 21s ⏱️ + 5m 30s
 83 tests + 10   82 ✅ +  9  1 💤 +1  0 ❌ ±0 
212 runs  +139  209 ✅ +136  3 💤 +3  0 ❌ ±0 

Results for commit abed7e0. ± Comparison against earlier commit 58479ca.

Annotations

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

1 skipped test found

There is 1 skipped test, see "Raw output" for the name of the skipped test.
Raw output
dev.restate.e2e.NodeWorkflowAPITest ‑ Set and resolve durable promise leads to completion

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

83 tests found

There are 83 tests, see "Raw output" for the full list of tests.
Raw output
dev.restate.e2e.JavaAwaitTimeoutTest ‑ Test Awaitable#await(Duration)
dev.restate.e2e.JavaAwakeableTest ‑ generate(IngressClient)
dev.restate.e2e.JavaCancelInvocationTest ‑ cancel blocked invocation on AWAKEABLE
dev.restate.e2e.JavaCancelInvocationTest ‑ cancel blocked invocation on CALL
dev.restate.e2e.JavaCancelInvocationTest ‑ cancel blocked invocation on SLEEP
dev.restate.e2e.JavaCoordinatorWithNodeReceiverServiceToServiceCallTest ‑ synchronousCall(IngressClient)
dev.restate.e2e.JavaErrorsTest ‑ Test calling method that fails terminally
dev.restate.e2e.JavaErrorsTest ‑ Test calling method that fails terminally multiple times
dev.restate.e2e.JavaErrorsTest ‑ Test invocations are retried until they succeed
dev.restate.e2e.JavaErrorsTest ‑ Test propagate failure from another service
dev.restate.e2e.JavaErrorsTest ‑ Test propagate failure from sideEffect and internal invoke
dev.restate.e2e.JavaErrorsTest ‑ Test set then fail should persist the set
dev.restate.e2e.JavaErrorsTest ‑ Test side effects are retried until they succeed
dev.restate.e2e.JavaErrorsTest ‑ Test terminal error of side effects is propagated
dev.restate.e2e.JavaKafkaIngressTest ‑ handleEventInCounterService(URL, int, IngressClient)
dev.restate.e2e.JavaKafkaIngressTest ‑ handleEventInEventHandler(URL, int, IngressClient)
dev.restate.e2e.JavaNonDeterminismTest ‑ backgroundInvokeWithDifferentTargets
dev.restate.e2e.JavaNonDeterminismTest ‑ callDifferentMethod
dev.restate.e2e.JavaNonDeterminismTest ‑ leftSleepRightCall
dev.restate.e2e.JavaNonDeterminismTest ‑ setDifferentKey
dev.restate.e2e.JavaRequestSigningTest ‑ requestSigningPass(IngressClient)
dev.restate.e2e.JavaSampleWorkflowTest ‑ Sample workflow with sleep, side effect, call and one way call
dev.restate.e2e.JavaServiceToServiceCallTest ‑ synchronousCall(IngressClient)
dev.restate.e2e.JavaSideEffectTest ‑ Side effect should wait on acknowledgements
dev.restate.e2e.JavaSimpleSleepTest ‑ manySleeps(IngressClient)
dev.restate.e2e.JavaSimpleSleepTest ‑ sleep(IngressClient)
dev.restate.e2e.JavaSleepWithFailuresTest ‑ sleepAndKillServiceEndpoint(IngressClient, ContainerHandle)
dev.restate.e2e.JavaSleepWithFailuresTest ‑ sleepAndTerminateServiceEndpoint(IngressClient, ContainerHandle)
dev.restate.e2e.JavaStateTest ‑ add(IngressClient)
dev.restate.e2e.JavaStateTest ‑ getAndSet(IngressClient)
dev.restate.e2e.JavaStateTest ‑ listStateAndClearAll(IngressClient)
dev.restate.e2e.JavaStateTest ‑ setStateViaOneWayCallFromAnotherService(IngressClient)
dev.restate.e2e.JavaWorkflowAPITest ‑ Set and resolve durable promise leads to completion
dev.restate.e2e.NodeAwaitTimeoutTest ‑ Test Awaitable#await(Duration)
dev.restate.e2e.NodeAwakeableTest ‑ generate(IngressClient)
dev.restate.e2e.NodeCancelInvocationTest ‑ cancel blocked invocation on AWAKEABLE
dev.restate.e2e.NodeCancelInvocationTest ‑ cancel blocked invocation on CALL
dev.restate.e2e.NodeCancelInvocationTest ‑ cancel blocked invocation on SLEEP
dev.restate.e2e.NodeCoordinatorWithJavaReceiverServiceToServiceCallTest ‑ synchronousCall(IngressClient)
dev.restate.e2e.NodeErrorsTest ‑ Test calling method that fails terminally
dev.restate.e2e.NodeErrorsTest ‑ Test calling method that fails terminally multiple times
dev.restate.e2e.NodeErrorsTest ‑ Test invocations are retried until they succeed
dev.restate.e2e.NodeErrorsTest ‑ Test propagate failure from another service
dev.restate.e2e.NodeErrorsTest ‑ Test set then fail should persist the set
dev.restate.e2e.NodeErrorsTest ‑ Test side effects are retried until they succeed
dev.restate.e2e.NodeErrorsTest ‑ Test terminal error of side effects is propagated
dev.restate.e2e.NodeKafkaIngressTest ‑ handleEventInCounterService(URL, int, IngressClient)
dev.restate.e2e.NodeKafkaIngressTest ‑ handleEventInEventHandler(URL, int, IngressClient)
dev.restate.e2e.NodeNonDeterminismTest ‑ backgroundInvokeWithDifferentTargets
dev.restate.e2e.NodeNonDeterminismTest ‑ callDifferentMethod
dev.restate.e2e.NodeNonDeterminismTest ‑ leftSleepRightCall
dev.restate.e2e.NodeNonDeterminismTest ‑ setDifferentKey
dev.restate.e2e.NodeRequestSigningTest ‑ requestSigningPass(IngressClient)
dev.restate.e2e.NodeServiceToServiceCallTest ‑ synchronousCall(IngressClient)
dev.restate.e2e.NodeSideEffectTest ‑ Side effect should wait on acknowledgements
dev.restate.e2e.NodeSimpleSleepTest ‑ manySleeps(IngressClient)
dev.restate.e2e.NodeSimpleSleepTest ‑ sleep(IngressClient)
dev.restate.e2e.NodeSleepWithFailuresTest ‑ sleepAndKillServiceEndpoint(IngressClient, ContainerHandle)
dev.restate.e2e.NodeSleepWithFailuresTest ‑ sleepAndTerminateServiceEndpoint(IngressClient, ContainerHandle)
dev.restate.e2e.NodeStateTest ‑ add(IngressClient)
dev.restate.e2e.NodeStateTest ‑ getAndSet(IngressClient)
dev.restate.e2e.NodeStateTest ‑ listStateAndClearAll(IngressClient)
dev.restate.e2e.NodeStateTest ‑ setStateViaOneWayCallFromAnotherService(IngressClient)
dev.restate.e2e.NodeWorkflowAPITest ‑ Set and resolve durable promise leads to completion
dev.restate.e2e.node.InterpreterTest ‑ simple(int)
dev.restate.e2e.node.StateSerDeTest ‑ addAndClear(IngressClient)
dev.restate.e2e.runtime.IngressTest ‑ Idempotent invocation to a service
dev.restate.e2e.runtime.IngressTest ‑ Idempotent invocation to a virtual object
dev.restate.e2e.runtime.IngressTest ‑ Idempotent invocation to a virtual object using send
dev.restate.e2e.runtime.IngressTest ‑ Idempotent send then attach/getOutput
dev.restate.e2e.runtime.IngressTest ‑ headersPassThrough(IngressClient)
dev.restate.e2e.runtime.InvokeOrderingTest ‑ [1] [true, false, false]
dev.restate.e2e.runtime.InvokeOrderingTest ‑ [2] [false, true, false]
dev.restate.e2e.runtime.InvokeOrderingTest ‑ [3] [true, true, false]
dev.restate.e2e.runtime.KillTestInvocationTest ‑ kill(IngressClient, URL)
dev.restate.e2e.runtime.PersistenceTest ‑ startAndKillRuntimeRetainsTheState(IngressClient, ContainerHandle)
dev.restate.e2e.runtime.PersistenceTest ‑ startAndStopRuntimeRetainsTheState(IngressClient, ContainerHandle)
dev.restate.e2e.runtime.PrivateServiceTest ‑ privateService(URL, IngressClient)
dev.restate.e2e.runtime.RetryOnUnknownServiceTest ‑ retryOnUnknownServiceUsingCall(IngressClient, URL)
dev.restate.e2e.runtime.RetryOnUnknownServiceTest ‑ retryOnUnknownServiceUsingOneWayCall(IngressClient, URL)
dev.restate.e2e.runtime.UpgradeServiceTest ‑ executesNewInvocationWithLatestServiceRevisions(IngressClient, URL)
dev.restate.e2e.runtime.UpgradeServiceTest ‑ inFlightInvocation(IngressClient, URL)
dev.restate.e2e.runtime.UpgradeServiceTest ‑ inFlightInvocationStoppingTheRuntime(IngressClient, URL, ContainerHandle)