Skip to content

Commit

Permalink
add comment
Browse files Browse the repository at this point in the history
Signed-off-by: Justin Yu <[email protected]>
  • Loading branch information
justinvyu committed Jan 17, 2025
1 parent 1894848 commit d3561fd
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion python/ray/train/v2/_internal/callbacks/user_callback.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,14 @@
WorkerGroupCallback,
)
from ray.train.v2._internal.execution.context import TrainRunContext
from ray.train.v2._internal.execution.worker_group import WorkerGroupStatus
from ray.train.v2.api.callback import UserCallback


class UserCallbackHandler(WorkerGroupCallback, ReportCallback):
"""Responsible for calling methods of subscribers implementing
the `UserCallback` interface.
"""
def __init__(
self, user_callbacks: List[UserCallback], train_run_context: TrainRunContext
):
Expand All @@ -34,7 +38,7 @@ def after_report(
# WorkerGroupCallback
# --------------------------

def after_worker_group_poll_status(self, worker_group_status):
def after_worker_group_poll_status(self, worker_group_status: WorkerGroupStatus):
if not worker_group_status.errors:
return

Expand Down

0 comments on commit d3561fd

Please sign in to comment.