fix: fix typo spelling code commented and data_model.rst
This commit is contained in:
Родитель
665a9aa818
Коммит
c73d73bfc7
|
@ -8,7 +8,7 @@ the backend language for improving the execution reference. What's more,
|
|||
the backend store is a pluggable design, user can choose different backend
|
||||
implementation based on their real performance requirement and device limitation.
|
||||
|
||||
Currenty there are two data model backend implementation: static and dynamic.
|
||||
Currently there are two data model backend implementation: static and dynamic.
|
||||
Static implementation used Numpy as its data store, do not support dynamic
|
||||
attribute length, the advance of this version is that its memory size is same as its
|
||||
declaration.
|
||||
|
|
|
@ -25,7 +25,7 @@ def list_available():
|
|||
# maro env list
|
||||
def list_scenarios(**kwargs):
|
||||
"""
|
||||
Show all avaiable scenarios
|
||||
Show all available scenarios
|
||||
"""
|
||||
|
||||
for scenario in get_scenarios():
|
||||
|
|
|
@ -17,7 +17,7 @@ def start_geo_vis(start: str, experiment_name: str, front_end_port: int, **kwarg
|
|||
grader_path = os.path.dirname(os.path.dirname(os.path.abspath(os.path.dirname(__file__))))
|
||||
if start == 'database':
|
||||
|
||||
# Start the databse container.
|
||||
# Start the database container.
|
||||
database_start_path = f"{grader_path}/streamit/server"
|
||||
subprocess.check_call(
|
||||
'sh run_docker.sh',
|
||||
|
|
|
@ -213,13 +213,13 @@ class CimBaseDataContainer(ABC):
|
|||
|
||||
@property
|
||||
def vessel_period(self) -> int:
|
||||
"""Wrapper to get vessel's planed sailing period (without noise to complete a whole route).
|
||||
"""Wrapper to get vessel's planned sailing period (without noise to complete a whole route).
|
||||
|
||||
Examples:
|
||||
|
||||
.. code-block:: python
|
||||
|
||||
# Get planed sailing for vessel 0.
|
||||
# Get planned sailing for vessel 0.
|
||||
period = data_cntr.vessel_period[0]
|
||||
"""
|
||||
return self._data_collection.vessel_period_without_noise
|
||||
|
|
|
@ -23,7 +23,7 @@ def gen_matrix(port_num: int, vessel_num: int):
|
|||
full_on_ports = NodeAttribute("i", slot_num=port_num * port_num)
|
||||
# distribution of full from vessel to port
|
||||
full_on_vessels = NodeAttribute("i", slot_num=vessel_num * port_num)
|
||||
# planed route info for vessels
|
||||
# planned route info for vessels
|
||||
vessel_plans = NodeAttribute("i", slot_num=vessel_num * port_num)
|
||||
|
||||
def __init__(self):
|
||||
|
|
|
@ -45,11 +45,11 @@ class TestEventBuffer(unittest.TestCase):
|
|||
def cb(evt):
|
||||
# test event tick
|
||||
self.assertEqual(
|
||||
1, evt.tick, msg="recieved event tick should be 1")
|
||||
1, evt.tick, msg="received event tick should be 1")
|
||||
|
||||
# test event payload
|
||||
self.assertTupleEqual(
|
||||
(1, 3), evt.payload, msg="recieved event's payload should be (1, 3)")
|
||||
(1, 3), evt.payload, msg="received event's payload should be (1, 3)")
|
||||
|
||||
evt = self.eb.gen_atom_event(1, 1, (1, 3))
|
||||
|
||||
|
@ -142,7 +142,7 @@ class TestEventBuffer(unittest.TestCase):
|
|||
self.assertEqual(1, len(decision_events))
|
||||
self.assertEqual(evt1, decision_events[0])
|
||||
|
||||
# mark decision event as executing to make it process folloing events
|
||||
# mark decision event as executing to make it process following events
|
||||
decision_events[0].state = EventState.FINISHED
|
||||
|
||||
# then there will be 2 additional decision event from sub events
|
||||
|
|
|
@ -147,7 +147,7 @@ class TestFrame(unittest.TestCase):
|
|||
self.assertListEqual(list(states[0].astype("i")), [100 * i + 1 for i in range(
|
||||
len(frame.static_nodes))], msg="a2 at tick 1 for all nodes should be correct")
|
||||
|
||||
# 2nd row should be lastest one
|
||||
# 2nd row should be latest one
|
||||
self.assertEqual(
|
||||
1000, states[1][0], msg="a2 for 1st static node for 2nd row should be 1000")
|
||||
|
||||
|
|
Загрузка…
Ссылка в новой задаче