formatting python code with black

Author: mgonzs13

simple_node/simple_node/__init__.py

@@ -1,2 +1 @@
-
-from .node import Node
+from simple_node.node import Node

simple_node/simple_node/actions/action_client.py

@@ -30,7 +30,7 @@ def __init__(
         node: Node,
         action_type: Type,
         action_name: str,
-        feedback_cb: Callable = None
+        feedback_cb: Callable = None,
     ) -> None:
 
         self._action_done_event = Event()
@@ -46,10 +46,7 @@ def __init__(
         self.feedback_cb = feedback_cb
 
         super().__init__(
-            node,
-            action_type,
-            action_name,
-            callback_group=ReentrantCallbackGroup()
+            node, action_type, action_name, callback_group=ReentrantCallbackGroup()
         )
 
     def get_status(self) -> int:
@@ -74,7 +71,7 @@ def is_working(self) -> bool:
             return self._goal_handle is not None
 
     def is_terminated(self) -> bool:
-        return (self.is_succeeded() or self.is_canceled() or self.is_aborted())
+        return self.is_succeeded() or self.is_canceled() or self.is_aborted()
 
     def wait_for_result(self) -> None:
         self._action_done_event.clear()
@@ -94,8 +91,7 @@ def send_goal(self, goal, feedback_cb: Callable = None) -> None:
         if not feedback_cb is None:
             _feedback_cb = feedback_cb
 
-        send_goal_future = self.send_goal_async(
-            goal, feedback_callback=_feedback_cb)
+        send_goal_future = self.send_goal_async(goal, feedback_callback=_feedback_cb)
         send_goal_future.add_done_callback(self._goal_response_callback)
 
     def _goal_response_callback(self, future) -> None:
@@ -113,8 +109,7 @@ def cancel_goal(self) -> None:
         with self._goal_handle_lock:
             if self._goal_handle is not None:
 
-                cancel_goal_future = self._cancel_goal_async(
-                    self._goal_handle)
+                cancel_goal_future = self._cancel_goal_async(self._goal_handle)
                 cancel_goal_future.add_done_callback(self._cancel_done)
 
                 self._cancel_done_event.clear()

simple_node/simple_node/actions/action_server.py

@@ -27,15 +27,15 @@
 
 
 class ActionServer(ActionServer2):
-    """ Action Server Class """
+    """Action Server Class"""
 
     def __init__(
         self,
         node: Node,
         action_type,
         action_name: str,
         execute_callback: Callable,
-        cancel_callback: Callable = None
+        cancel_callback: Callable = None,
     ) -> None:
 
         self.__goal_lock = Lock()
@@ -46,27 +46,29 @@ def __init__(
         self.node = node
 
         super().__init__(
-            node, action_type, action_name,
+            node,
+            action_type,
+            action_name,
             execute_callback=self.__execute_callback,
             goal_callback=self.__goal_callback,
             handle_accepted_callback=self.__handle_accepted_callback,
             cancel_callback=self.__cancel_callback,
-            callback_group=ReentrantCallbackGroup()
+            callback_group=ReentrantCallbackGroup(),
         )
 
     def is_working(self) -> bool:
         return self._goal_handle is not None
 
     def __goal_callback(self, goal_request) -> int:
-        """ goal callback """
+        """goal callback"""
 
         return GoalResponse.ACCEPT
 
     def __handle_accepted_callback(self, goal_handle: ServerGoalHandle) -> None:
         """
-            handle accepted calback for a single goal server
-            only one goal can be treated
-            if other goal is send, old goal is aborted and replaced with the new one
+        handle accepted calback for a single goal server
+        only one goal can be treated
+        if other goal is send, old goal is aborted and replaced with the new one
         """
 
         with self.__goal_lock:
@@ -77,7 +79,7 @@ def __handle_accepted_callback(self, goal_handle: ServerGoalHandle) -> None:
             self._goal_handle.execute()
 
     def __cancel_callback(self, goal_handle: ServerGoalHandle) -> int:
-        """ cancel calback """
+        """cancel calback"""
 
         if self.__user_cancel_callback is not None:
             self.__cancel_thread = Thread(target=self.__user_cancel_callback)
@@ -87,7 +89,7 @@ def __cancel_callback(self, goal_handle: ServerGoalHandle) -> int:
 
     def __execute_callback(self, goal_handle: ServerGoalHandle):
         """
-            execute callback
+        execute callback
         """
 
         self.__cancel_thread = None

simple_node/simple_node/node.py

@@ -34,7 +34,7 @@
 
 
 class Node(Node2):
-    """ Node Class """
+    """Node Class"""
 
     def __init__(
         self,
@@ -48,7 +48,7 @@ def __init__(
         parameter_overrides: List[Parameter] = None,
         allow_undeclared_parameters: bool = False,
         automatically_declare_parameters_from_overrides: bool = False,
-        executor: Executor = None
+        executor: Executor = None,
     ) -> None:
 
         super().__init__(
@@ -61,7 +61,7 @@ def __init__(
             start_parameter_services=start_parameter_services,
             parameter_overrides=parameter_overrides,
             allow_undeclared_parameters=allow_undeclared_parameters,
-            automatically_declare_parameters_from_overrides=automatically_declare_parameters_from_overrides
+            automatically_declare_parameters_from_overrides=automatically_declare_parameters_from_overrides,
         )
 
         if not executor:
@@ -76,7 +76,7 @@ def __init__(
         self._wake_thread.start()
 
     def _run_executor(self) -> None:
-        """ run an executer with self (node) """
+        """run an executer with self (node)"""
 
         self._executor.add_node(self)
         try:
@@ -90,7 +90,7 @@ def _wake_node(self) -> None:
             time.sleep(1)
 
     def join_spin(self) -> None:
-        """ wait for spin thread """
+        """wait for spin thread"""
 
         try:
             self._spin_thread.join()
@@ -99,20 +99,15 @@ def join_spin(self) -> None:
             self.get_logger().info("Destroying node " + self.get_name())
             self.destroy_node()
 
-    def create_client(
-        self,
-        srv_type: Type,
-        srv_name: str
-    ) -> Client:
-        return super().create_client(srv_type, srv_name, callback_group=ReentrantCallbackGroup())
+    def create_client(self, srv_type: Type, srv_name: str) -> Client:
+        return super().create_client(
+            srv_type, srv_name, callback_group=ReentrantCallbackGroup()
+        )
 
     def create_action_client(
-        self,
-        action_type: Type,
-        action_name: str,
-        feedback_cb: Callable = None
+        self, action_type: Type, action_name: str, feedback_cb: Callable = None
     ) -> ActionClient:
-        """ create action client from node
+        """create action client from node
 
         Args:
             action_type ([type]): action type (msg action)
@@ -129,9 +124,9 @@ def create_action_server(
         action_type: Type,
         action_name: str,
         execute_callback: Callable,
-        cancel_callback: Callable = None
+        cancel_callback: Callable = None,
     ) -> ActionServer:
-        """ create action server from node
+        """create action server from node
 
         Args:
             action_type ([type]): action type (msg action)
@@ -148,5 +143,5 @@ def create_action_server(
             action_type,
             action_name,
             execute_callback,
-            cancel_callback=cancel_callback
+            cancel_callback=cancel_callback,
         )