Skip to content

Commit c09d361

Browse files
committed
Linter
1 parent 507387e commit c09d361

File tree

6 files changed

+17
-16
lines changed

6 files changed

+17
-16
lines changed

manager/manager/launcher/launcher_console.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ def run(self, config_file, callback):
4141

4242
def pause(self):
4343
pass
44-
44+
4545
def unpause(self):
4646
pass
4747

manager/manager/launcher/launcher_gazebo.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
import stat
1313
from typing import List, Any
1414

15+
1516
def call_service(self, service, service_type, request_data="{}"):
1617
command = f"ros2 service call {service} {service_type} '{request_data}'"
1718
subprocess.call(
@@ -23,6 +24,7 @@ def call_service(self, service, service_type, request_data="{}"):
2324
universal_newlines=True,
2425
)
2526

27+
2628
class LauncherGazebo(ILauncher):
2729
display: str
2830
internal_port: int
@@ -71,7 +73,7 @@ def unpause(self):
7173

7274
def reset(self):
7375
call_service("/reset_world", "std_srvs/srv/Empty")
74-
76+
7577
def is_running(self):
7678
return self.running
7779

manager/manager/launcher/launcher_gzsim.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
from typing import List, Any
1414
from manager.ram_logging.log_manager import LogManager
1515

16+
1617
def call_gzservice(self, service, reqtype, reptype, timeout, req):
1718
command = f"gz service -s {service} --reqtype {reqtype} --reptype {reptype} --timeout {timeout} --req '{req}'"
1819
subprocess.call(
@@ -24,6 +25,7 @@ def call_gzservice(self, service, reqtype, reptype, timeout, req):
2425
universal_newlines=True,
2526
)
2627

28+
2729
def call_service(self, service, service_type, request_data="{}"):
2830
command = f"ros2 service call {service} {service_type} '{request_data}'"
2931
subprocess.call(
@@ -35,6 +37,7 @@ def call_service(self, service, service_type, request_data="{}"):
3537
universal_newlines=True,
3638
)
3739

40+
3841
def is_ros_service_available(self, service_name):
3942
try:
4043
result = subprocess.run(
@@ -48,6 +51,7 @@ def is_ros_service_available(self, service_name):
4851
LogManager.logger.exception(f"Error checking service availability: {e}")
4952
return False
5053

54+
5155
class LauncherGzsim(ILauncher):
5256
display: str
5357
internal_port: int

manager/manager/launcher/launcher_tools.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -84,11 +84,11 @@ def process_terminated(name, exit_code):
8484
config = None
8585
if self.tools_config is not None and name in self.tools_config:
8686
config = self.tools_config[name]
87-
87+
8888
launcher = launcher_class.from_config(launcher_class, configuration)
8989
launcher.run(config, process_terminated)
9090
return launcher
91-
91+
9292
def pause(self):
9393
for launcher in self.launchers:
9494
launcher.pause()

manager/manager/launcher/launcher_web_gui.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,8 @@
33
from manager.comms.new_consumer import ManagerConsumer
44
from typing import Optional
55

6-
class LauncherWebGui():
6+
7+
class LauncherWebGui:
78
internal_port: int
89
consumer: ManagerConsumer
910
running: bool = False
@@ -35,7 +36,7 @@ def terminate(self):
3536

3637
def pause(self):
3738
pass
38-
39+
3940
def unpause(self):
4041
pass
4142

@@ -47,4 +48,4 @@ def died(self):
4748

4849
def from_config(cls, config):
4950
obj = cls(**config)
50-
return obj
51+
return obj

manager/manager/manager.py

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -346,9 +346,7 @@ def on_prepare_tools(self, event):
346346
tools = cfg_dict["tools"]
347347
config = cfg_dict["config"]
348348

349-
self.tools_launcher = LauncherTools(
350-
tools=tools, tools_config=config
351-
)
349+
self.tools_launcher = LauncherTools(tools=tools, tools_config=config)
352350

353351
self.tools_launcher.run(self.consumer)
354352
LogManager.logger.info("Tools transition finished")
@@ -782,9 +780,7 @@ def on_disconnect(self, event):
782780
try:
783781
self.tools_launcher.terminate()
784782
except Exception as e:
785-
LogManager.logger.exception(
786-
"Exception terminating tools launcher"
787-
)
783+
LogManager.logger.exception("Exception terminating tools launcher")
788784

789785
if self.robot_launcher:
790786
try:
@@ -893,9 +889,7 @@ def signal_handler(sign, frame):
893889
try:
894890
self.tools_launcher.terminate()
895891
except Exception as e:
896-
LogManager.logger.exception(
897-
"Exception terminating tools launcher"
898-
)
892+
LogManager.logger.exception("Exception terminating tools launcher")
899893

900894
if self.robot_launcher:
901895
try:

0 commit comments

Comments
 (0)