-
Notifications
You must be signed in to change notification settings - Fork 0
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
Reduced the number of channels between service and process #1
Conversation
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.
Good start I think, please look at my comments.
@@ -129,7 +128,6 @@ def test_get_set_var_using_var_api(self): | |||
process.run(condition=RunSteps(num_steps=5), run_cfg=run_config) | |||
assert np.array_equal(process.u.get(), expected_result_u) | |||
assert np.array_equal(process.v.get(), expected_result_v) | |||
self.assertEqual(process.runtime.global_time, 15) |
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.
Same as above, compare with the time step in ProcModel
@@ -59,7 +59,6 @@ def test_synchronization_single_process_model(self): | |||
run_config = SimpleRunConfig(sync_domains=[simple_sync_domain]) | |||
process.run(condition=RunSteps(num_steps=10), run_cfg=run_config) | |||
process.run(condition=RunSteps(num_steps=5), run_cfg=run_config) | |||
self.assertEqual(process.runtime.global_time, 15) |
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.
Same
exe: Executable, | ||
message_infrastructure_type: ActorType): | ||
self._run_cond: AbstractRunCondition = run_cond | ||
self._run_cond: typing.Optional[AbstractRunCondition] = None |
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.
Why is the RunCondition optional? This internal RunCondition is and was not used by the Runtime, as far as I can see. I think we do not need it, correct?
…-nc#157) * Reduced the number of channels between service and process (#1) * Reduced the number of channels between service and process * Fixed the bug with failing monitor cases * Reduce the number of channels to communicate between runtime and runtime_service * Fix flake8 related issues * Fix flake8 related issues Co-authored-by: Joyesh Mishra <joyesh.mishra@intel.com>
Issue Number: Remove hacks and refactor Runtime and RuntimeService/Synchronizer lava-nc#86
Objective of pull request: Reduced the number of channels between service and process
Pull request checklist
Your PR fulfills the following requirements:
pyb
) passes locallypyb -E unit
) or (python -m unittest
) passes locallyPull request type
Please check your PR type:
What is the current behavior?
What is the new behavior?
Does this introduce a breaking change?
Supplemental information