Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[2.6] Enhance launcher executor #2744

Open
wants to merge 2 commits into
base: main
Choose a base branch
from

Conversation

YuanTingHsieh
Copy link
Collaborator

Description

  • Add clear of peer_is_up_or_dead
  • Enhance error messages

Types of changes

  • Non-breaking change (fix or new feature that would not break existing functionality).
  • Breaking change (fix or new feature that would cause existing functionality to change).
  • New tests added to cover the changes.
  • Quick tests passed locally by running ./runtest.sh.
  • In-line docstrings updated.
  • Documentation updated.

@YuanTingHsieh YuanTingHsieh force-pushed the enhance_launcher_executor_and_subprocess_launcher branch from 02adcf3 to a16b814 Compare July 30, 2024 21:10
@YuanTingHsieh YuanTingHsieh changed the title Enhance launcher executor and subprocess launcher Enhance launcher executor Jul 30, 2024
@YuanTingHsieh YuanTingHsieh changed the title Enhance launcher executor [2.6] Enhance launcher executor Jul 30, 2024
Copy link
Collaborator

@yanchengnv yanchengnv left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Looks good in general. Please improve log message text.

@@ -242,13 +243,15 @@ def _initialize_external_execution(
abort_signal.trigger("launch task failed")
return False

self.log_info(fl_ctx, f"External execution for task ({task_name}) is launched.")
self.log_info(fl_ctx, f"launcher launch_task for ({task_name}) succeed.")
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Improve the log message:
Launcher successfully launched task {task_name}.

# wait for external execution to set up their pipe_handler
setup_success = self._wait_external_setup(task_name, fl_ctx, abort_signal)
if not setup_success:
self.log_error(fl_ctx, "External execution set up failed.")
abort_signal.trigger("External execution set up failed.")
error = f"External execution set up for task ({task_name}) failed."
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Improve error test:
Failed external setup for task {task_name}.

return False
self.log_info(fl_ctx, f"External execution set up for task ({task_name}) succeed.")
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Improve log message:
External setup for task ({task_name}) succeeded.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants