format

libs/scenario_execution_kubernetes/scenario_execution_kubernetes/kubernetes_wait_for_pod_status.py

@@ -28,7 +28,8 @@ class KubernetesWaitForPodStatusState(Enum):
     IDLE = 1
     MONITORING = 2
     FAILURE = 3
-
+
+
 class KubernetesWaitForPodStatus(BaseAction):
 
     def __init__(self, target: str, regex: bool, status: tuple, namespace: str, within_cluster: bool):
@@ -85,7 +86,8 @@ def update(self) -> py_trees.common.Status:
     def watch_pods(self):
         w = watch.Watch()
         try:
-            for event in w.stream(self.client.list_namespaced_pod, namespace=self.namespace): # TODO: make use of send_initial_events=false in the future
+            # TODO: make use of send_initial_events=false in the future
+            for event in w.stream(self.client.list_namespaced_pod, namespace=self.namespace):
                 pod_name = event['object'].metadata.name
                 pod_status = event['object'].status.phase
                 if self.current_state == KubernetesWaitForPodStatusState.MONITORING:

scenario_execution_ros/scenario_execution_ros/actions/assert_lifecycle_state.py

@@ -68,7 +68,8 @@ def setup(self, **kwargs):
     def execute(self, node_name: str, state_sequence: list, allow_initial_skip: bool, fail_on_unexpected: bool, keep_running: bool):
         print(f"AAAAAAAAAAAAAAAAAAA EXECUTE {node_name} {state_sequence} {allow_initial_skip} {fail_on_unexpected } {keep_running}")
         if self.node_name != node_name or self.state_sequence != state_sequence:
-            raise ValueError(f"Updating node name or state_sequence not supported. {self.node_name} != {node_name}, {self.state_sequence} != {state_sequence}")
+            raise ValueError(
+                f"Updating node name or state_sequence not supported. {self.node_name} != {node_name}, {self.state_sequence} != {state_sequence}")
 
         if all(isinstance(state, tuple) and len(state) == 2 for state in self.state_sequence):
             self.state_sequence = [state[0] for state in self.state_sequence]