Skip to content

Commit 08488a8

Browse files
committed
fix: Update module and action names in ModuleManager and command executors for consistency
1 parent 4e820ab commit 08488a8

File tree

6 files changed

+43
-23
lines changed

6 files changed

+43
-23
lines changed

adf_core_python/core/agent/module/module_manager.py

Lines changed: 35 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,11 @@ def get_module(
6868
return instance
6969

7070
class_name = self._module_config.get_value(module_name)
71+
if class_name is None:
72+
self._logger.warning(
73+
f"Module {module_name} not found in config. Using default module {default_module_class_name}"
74+
)
75+
7176
if class_name is not None:
7277
try:
7378
module_class: type = self._load_module(class_name)
@@ -124,9 +129,12 @@ def get_module(
124129
def get_extend_action(
125130
self, action_name: str, default_action_class_name: str
126131
) -> ExtendAction:
127-
class_name = self._module_config.get_value_or_default(
128-
action_name, default_action_class_name
129-
)
132+
class_name = self._module_config.get_value(action_name)
133+
if class_name is None:
134+
self._logger.warning(
135+
f"Action {action_name} not found in config. Using default action {default_action_class_name}"
136+
)
137+
class_name = default_action_class_name
130138

131139
action_class: type = self._load_module(class_name)
132140

@@ -150,9 +158,12 @@ def get_extend_action(
150158
def get_channel_subscriber(
151159
self, channel_subscriber_name: str, default_channel_subscriber_name: str
152160
) -> ChannelSubscriber:
153-
class_name = self._module_config.get_value_or_default(
154-
channel_subscriber_name, default_channel_subscriber_name
155-
)
161+
class_name = self._module_config.get_value(channel_subscriber_name)
162+
if class_name is None:
163+
self._logger.warning(
164+
f"Channel subscriber {channel_subscriber_name} not found in config. Using default channel subscriber {default_channel_subscriber_name}"
165+
)
166+
class_name = default_channel_subscriber_name
156167

157168
channel_subscriber_class: type = self._load_module(class_name)
158169

@@ -172,9 +183,12 @@ def get_channel_subscriber(
172183
def get_message_coordinator(
173184
self, message_coordinator_name: str, default_message_coordinator_name: str
174185
) -> MessageCoordinator:
175-
class_name = self._module_config.get_value_or_default(
176-
message_coordinator_name, default_message_coordinator_name
177-
)
186+
class_name = self._module_config.get_value(message_coordinator_name)
187+
if class_name is None:
188+
self._logger.warning(
189+
f"Channel subscriber {message_coordinator_name} not found in config. Using default channel subscriber {default_message_coordinator_name}"
190+
)
191+
class_name = default_message_coordinator_name
178192

179193
message_coordinator_class: type = self._load_module(class_name)
180194

@@ -194,9 +208,12 @@ def get_message_coordinator(
194208
def get_command_executor(
195209
self, command_executor_name: str, default_command_executor_name: str
196210
) -> CommandExecutor:
197-
class_name = self._module_config.get_value_or_default(
198-
command_executor_name, default_command_executor_name
199-
)
211+
class_name = self._module_config.get_value(command_executor_name)
212+
if class_name is None:
213+
self._logger.warning(
214+
f"Command executor {command_executor_name} not found in config. Using default command executor {default_command_executor_name}"
215+
)
216+
class_name = default_command_executor_name
200217

201218
command_executor_class: type = self._load_module(class_name)
202219

@@ -220,9 +237,12 @@ def get_command_executor(
220237
def get_command_picker(
221238
self, command_picker_name: str, default_command_picker_name: str
222239
) -> CommandPicker:
223-
class_name = self._module_config.get_value_or_default(
224-
command_picker_name, default_command_picker_name
225-
)
240+
class_name = self._module_config.get_value(command_picker_name)
241+
if class_name is None:
242+
self._logger.warning(
243+
f"Command picker {command_picker_name} not found in config. Using default command picker {default_command_picker_name}"
244+
)
245+
class_name = default_command_picker_name
226246

227247
command_picker_class: type = self._load_module(class_name)
228248

adf_core_python/implement/centralized/default_command_executor_ambulance.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -58,11 +58,11 @@ def __init__(
5858
),
5959
)
6060
self._action_transport = module_manager.get_extend_action(
61-
"DefaultCommandExecutorAmbulance.ExtActionTransport",
61+
"DefaultCommandExecutorAmbulance.ExtendActionTransport",
6262
"adf_core_python.implement.action.default_extend_action_transport.DefaultExtendActionTransport",
6363
)
6464
self._action_move = module_manager.get_extend_action(
65-
"DefaultCommandExecutorAmbulance.ExtActionMove",
65+
"DefaultCommandExecutorAmbulance.ExtendActionMove",
6666
"adf_core_python.implement.action.default_extend_action_move.DefaultExtendActionMove",
6767
)
6868

adf_core_python/implement/centralized/default_command_executor_fire.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,11 +55,11 @@ def __init__(
5555
),
5656
)
5757
self._action_fire_rescue = module_manager.get_extend_action(
58-
"DefaultCommandExecutorFire.ExtActionFireRescue",
58+
"DefaultCommandExecutorFire.ExtendActionFireRescue",
5959
"adf_core_python.implement.action.default_extend_action_rescue.DefaultExtendActionRescue",
6060
)
6161
self._action_move = module_manager.get_extend_action(
62-
"DefaultCommandExecutorFire.ExtActionMove",
62+
"DefaultCommandExecutorFire.ExtendActionMove",
6363
"adf_core_python.implement.action.default_extend_action_move.DefaultExtendActionMove",
6464
)
6565

adf_core_python/implement/centralized/default_command_executor_police.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,11 +56,11 @@ def __init__(
5656
),
5757
)
5858
self._action_clear = module_manager.get_extend_action(
59-
"DefaultCommandExecutorPolice.ExtActionClear",
59+
"DefaultCommandExecutorPolice.ExtendActionClear",
6060
"adf_core_python.implement.action.default_extend_action_clear.DefaultExtendActionClear",
6161
)
6262
self._action_move = module_manager.get_extend_action(
63-
"DefaultCommandExecutorPolice.ExtActionMove",
63+
"DefaultCommandExecutorPolice.ExtendActionMove",
6464
"adf_core_python.implement.action.default_extend_action_move.DefaultExtendActionMove",
6565
)
6666

adf_core_python/implement/centralized/default_command_executor_scout_police.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ def __init__(
5151
),
5252
)
5353
self._action_clear: ExtendAction = module_manager.get_extend_action(
54-
"DefaultCommandExecutorScoutPolice.ExtActionClear",
54+
"DefaultCommandExecutorScoutPolice.ExtendActionClear",
5555
"adf_core_python.implement.action.default_extend_action_clear.DefaultExtendActionClear",
5656
)
5757

config/module.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ DefaultCommandExecutorAmbulance:
6363

6464
DefaultCommandExecutorFire:
6565
PathPlanning: adf_core_python.implement.module.algorithm.a_star_path_planning.AStarPathPlanning
66-
EtxActionFireRescue: adf_core_python.implement.action.default_extend_action_rescue.DefaultExtendActionRescue
66+
ExtendActionFireRescue: adf_core_python.implement.action.default_extend_action_rescue.DefaultExtendActionRescue
6767
ExtendActionMove: adf_core_python.implement.action.default_extend_action_move.DefaultExtendActionMove
6868

6969
DefaultCommandExecutorPolice:

0 commit comments

Comments
 (0)