-
Notifications
You must be signed in to change notification settings - Fork 217
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
Enable parallel runtimes #3299
Enable parallel runtimes #3299
Conversation
Two tests failing are inherited from block-merge branch, see #3277 |
@@ -315,6 +315,16 @@ class ReplayRSpace[F[_]: Sync, C, P, A, K]( | |||
comms.tailRecM(go).map(_.toOption) | |||
} | |||
|
|||
def spawn: F[IReplaySpace[F, C, P, A, K]] = { |
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.
I think we should keep the idea of manager to spawn new instance like KeyValueStoreManger and RUntimeManager.
I am thinking maybe I should follow your path and merge it first then clear things up later. Others can not easily code something into this feature branch now. |
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.
I am going to approve this one and let's polish it later with some other prs. I am sorry to be picky on the details with previous pr. I found that I should work with your pace instead of my pace which would make it easier for me to make pr on the branch. In that way , I can help you fix tests, too.
This PR enables parallel Runtimes to be constructed, which is a requirement for block merge.
This is a very simple minimal working fix, heavy refactoring of RSpace/ReplayRspace/RSpaceOps still needed.
The commit with adding syntax is not related to this, but as this PR is an attempt to split the huge #3238, it is small enough, so I decided to make it accompany the parallel runtimes commit.