-
Notifications
You must be signed in to change notification settings - Fork 1.1k
[WIP] CoordinatedShutdown and ClusterDaemon fixes #3497
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
[WIP] CoordinatedShutdown and ClusterDaemon fixes #3497
Conversation
@@ -534,7 +534,7 @@ internal static void InitPhaseActorSystemTerminate(ActorSystem system, Config co | |||
// We must spawn a separate Task to not block current thread, | |||
// since that would have blocked the shutdown of the ActorSystem. | |||
var timeout = coord.Timeout(PhaseActorSystemTerminate); | |||
return Task.Run(() => | |||
Task.Run(() => |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Not supposed to return a Task
here. Supposed to just let the process run asynchronously and invoke once the ActorSystem
has finished terminating.
{ | ||
// forces downstream error propagation if recover is disabled | ||
var force = tr.Result; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Let the task run asynchronously, but still propagate failures downstream.
@Horusiath thanks for the suggestions; was able to reproduce the issue with #3413 - I think I can TDD it from here. |
e7439de
to
d8d80de
Compare
Looks like it's the reproduction spec for this that's failing. |
Designed to reproduce and fix #3413