Skip to content

Commit

Permalink
Address peer review comments
Browse files Browse the repository at this point in the history
Signed-off-by: Michel Hidalgo <[email protected]>
  • Loading branch information
mhidalgo-bdai committed Nov 25, 2024
1 parent a76b9fa commit a581ebe
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 2 deletions.
1 change: 1 addition & 0 deletions bdai_ros2_wrappers/bdai_ros2_wrappers/feeds.py
Original file line number Diff line number Diff line change
Expand Up @@ -197,6 +197,7 @@ def __init__(
self,
feed: MessageFeed,
fn: Callable[..., MessageT],
*,
autostart: bool = True,
**kwargs: Any,
) -> None:
Expand Down
5 changes: 3 additions & 2 deletions bdai_ros2_wrappers/bdai_ros2_wrappers/filters.py
Original file line number Diff line number Diff line change
Expand Up @@ -220,6 +220,7 @@ def __init__(
target_frame_id: str,
tf_buffer: tf2_ros.Buffer,
tolerance_sec: float,
*,
logger: Optional[RcutilsLogger] = None,
autostart: bool = True,
) -> None:
Expand Down Expand Up @@ -331,7 +332,7 @@ def add(self, *messages: Any) -> None:
class Adapter(Filter):
"""A message filter for data adaptation."""

def __init__(self, upstream: Filter, fn: Callable, autostart: bool = True) -> None:
def __init__(self, upstream: Filter, fn: Callable, *, autostart: bool = True) -> None:
"""Initializes the adapter.
Args:
Expand Down Expand Up @@ -369,7 +370,7 @@ def add(self, *messages: Any) -> None:
class Tunnel(Filter):
"""A message filter that simply forwards messages but can be detached."""

def __init__(self, upstream: Filter, autostart: bool = True) -> None:
def __init__(self, upstream: Filter, *, autostart: bool = True) -> None:
"""Initializes the tunnel.
Args:
Expand Down

0 comments on commit a581ebe

Please sign in to comment.