-
Notifications
You must be signed in to change notification settings - Fork 110
WIP: Remove monitor #10565
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
base: main
Are you sure you want to change the base?
WIP: Remove monitor #10565
Conversation
63091df
to
6bc0bdf
Compare
81c6998
to
bcf9998
Compare
CodSpeed Performance ReportMerging #10565 will not alter performanceComparing Summary
|
a010046
to
205514f
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Copilot reviewed 10 out of 10 changed files in this pull request and generated 8 comments.
await evaluator_task | ||
return [] | ||
|
||
logger.debug("observed that model was finished, waiting tasks completion...") | ||
# The model has finished, we indicate this by sending a DONE | ||
logger.debug("tasks complete") | ||
|
||
if not self._end_queue.empty(): | ||
if self._cancelled: | ||
print("YEGA!") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Remove the debug print 'print("YEGA!")' and replace it with an appropriate logger.debug call.
print("YEGA!") | |
logger.debug("YEGA!") |
Copilot uses AI. Check for mistakes.
try: | ||
await evaluator_task | ||
except Exception as e: | ||
print(f"1: {e!s}") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Remove the debug print 'print(f"1: {e!s}")' and use the logging framework (e.g. logger.error) to log exceptions.
print(f"1: {e!s}") | |
logger.error(f"1: {e!s}") |
Copilot uses AI. Check for mistakes.
raise Exception( | ||
"Exception occured during user initiatied termination of experiment" | ||
) from e | ||
print("RAISING USER_CANCELLED") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Remove the debug print 'print("RAISING USER_CANCELLED")' and replace it with a proper logging call.
print("RAISING USER_CANCELLED") | |
logger.debug("RAISING USER_CANCELLED") |
Copilot uses AI. Check for mistakes.
raise UserCancelled("Experiment cancelled by user in post evaluation") | ||
|
||
else: | ||
print("HELL NAH!") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Remove the debug print 'print("HELL NAH!")' and use the logging framework for consistency.
print("HELL NAH!") | |
logger.debug("HELL NAH!") |
Copilot uses AI. Check for mistakes.
|
||
async def handle_client_event(self, event: EEEvent) -> None: | ||
if type(event) is EEUserCancel: | ||
print("EE GOT CANCEL EVENT") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Replace the debug print 'print("EE GOT CANCEL EVENT")' with an appropriate logger.debug call to maintain consistent logging practices.
print("EE GOT CANCEL EVENT") | |
logger.debug("EE GOT CANCEL EVENT") |
Copilot uses AI. Check for mistakes.
self._monitoring_result.set_result(False) | ||
# self._clients_empty.set() | ||
elif type(event) is EEUserDone: | ||
print("EE GOT USER DONE EVENT") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Replace the debug print 'print("EE GOT USER DONE EVENT")' with a logger.debug call for consistent logging.
print("EE GOT USER DONE EVENT") | |
logger.debug("EE GOT USER DONE EVENT") |
Copilot uses AI. Check for mistakes.
raise task_exception | ||
elif task.get_name() == "server_task": | ||
print("EXITED MONITOR AN DHANDLE TASKS") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Remove or replace the debug print 'print("EXITED MONITOR AN DHANDLE TASKS")' with an appropriate logger.debug statement.
print("EXITED MONITOR AN DHANDLE TASKS") | |
logger.debug("EXITED MONITOR AN DHANDLE TASKS") |
Copilot uses AI. Check for mistakes.
return | ||
elif task.get_name() in { | ||
"ensemble_task", | ||
"listener_task", | ||
"ensemble_cancellation_task", | ||
}: | ||
timeout = self.CLOSE_SERVER_TIMEOUT | ||
self._monitoring_result.set_result(False) | ||
print("WAS HERE") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Remove or replace the debug print 'print("WAS HERE")' with a proper logging call to ensure consistency.
print("WAS HERE") | |
logger.info("WAS HERE") |
Copilot uses AI. Check for mistakes.
Issue
Resolves #my_issue
Approach
Short description of the approach
(Screenshot of new behavior in GUI if applicable)
git rebase -i main --exec 'just rapid-tests'
)When applicable