Skip to content

Commit

Permalink
WIP Debug CI
Browse files Browse the repository at this point in the history
Signed-off-by: Chi-Sheng Liu <[email protected]>
  • Loading branch information
MortalHappiness committed Jan 20, 2025
1 parent 974e551 commit ad9caea
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 1 deletion.
2 changes: 2 additions & 0 deletions python/ray/_raylet.pyx
Original file line number Diff line number Diff line change
Expand Up @@ -1959,6 +1959,8 @@ cdef void execute_task(
(ray._private.worker.global_worker
.debugger_breakpoint) = b""
task_exception = False
except ValueError as e:
exit_current_actor_if_asyncio()
except Exception as e:
is_retryable_error[0] = determine_if_retryable(
should_retry_exceptions,
Expand Down
3 changes: 2 additions & 1 deletion python/ray/actor.py
Original file line number Diff line number Diff line change
Expand Up @@ -1777,7 +1777,8 @@ def exit_actor():
# asyncio.Event for synchronization across multiple asyncio tasks.
if worker.core_worker.current_actor_is_asyncio():
worker.core_worker.is_current_async_actor_exited = True
return
# return
raise ValueError()

# Set a flag to indicate this is an intentional actor exit. This
# reduces log verbosity.
Expand Down

0 comments on commit ad9caea

Please sign in to comment.