Unverified Commit 306451d3 authored by Jakob Görgen's avatar Jakob Görgen
Browse files

fixed return filter object + removed useless executor param

parent d260790e
...@@ -94,7 +94,7 @@ class ExperimentBaseRunner(abc.ABC): ...@@ -94,7 +94,7 @@ class ExperimentBaseRunner(abc.ABC):
if len(wait_socks) > 0: if len(wait_socks) > 0:
if self._verbose: if self._verbose:
print(f'{self._simulation.name}: waiting for sockets {name}') print(f'{self._simulation.name}: waiting for sockets {name}')
await self._instantiation.wait_for_sockets(executor=executor, sockets=wait_socks) await self._instantiation.wait_for_sockets(sockets=wait_socks)
if self._verbose: if self._verbose:
print(f'{self._simulation.name}: waited successfully for sockets {name}') print(f'{self._simulation.name}: waited successfully for sockets {name}')
......
...@@ -80,7 +80,7 @@ class Simulator(utils_base.IdObj): ...@@ -80,7 +80,7 @@ class Simulator(utils_base.IdObj):
sockets: list[inst_base.Socket], sockets: list[inst_base.Socket],
filter_type: inst_base.SockType = inst_base.SockType.LISTEN, filter_type: inst_base.SockType = inst_base.SockType.LISTEN,
) -> list[inst_base.Socket]: ) -> list[inst_base.Socket]:
res = filter(lambda sock: sock._type == filter_type, sockets) res = list(filter(lambda sock: sock._type == filter_type, sockets))
return res return res
@staticmethod @staticmethod
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment