@@ -579,8 +579,8 @@ def __init__(
579579 self ._runLoop : Thread | None = None
580580 # Extra worker capabilities advertised to the backend in
581581 # GetWorkItemsRequest (in addition to ones derived from worker state such
582- # as LARGE_PAYLOADS). Feature -enablement helpers like
583- # TaskHubGrpcWorker.configure_scheduled_tasks register theirs here.
582+ # as LARGE_PAYLOADS). A feature -enablement helper like
583+ # TaskHubGrpcWorker.configure_scheduled_tasks registers its own here.
584584 self ._capabilities : set [int ] = set ()
585585
586586 @property
@@ -645,8 +645,8 @@ def add_capability(self, capability: int) -> None:
645645 """Advertise a worker capability to the backend in ``GetWorkItemsRequest``.
646646
647647 Most users do not call this directly; feature-enablement helpers such as
648- :meth:`configure_scheduled_tasks` use it to advertise the capabilities
649- (``pb.WORKER_CAPABILITY_*``) their feature relies on.
648+ :meth:`TaskHubGrpcWorker. configure_scheduled_tasks` use it to advertise
649+ the capabilities (``pb.WORKER_CAPABILITY_*``) their feature relies on.
650650 """
651651 if self ._is_running :
652652 raise RuntimeError (
@@ -668,8 +668,9 @@ def configure_scheduled_tasks(self) -> None:
668668 )
669669 # Imported lazily to avoid a circular import: durabletask.scheduled
670670 # imports from durabletask.worker.
671- from durabletask .scheduled .orchestrator import \
672- execute_schedule_operation_orchestrator
671+ from durabletask .scheduled .orchestrator import (
672+ execute_schedule_operation_orchestrator ,
673+ )
673674 from durabletask .scheduled .schedule_entity import ENTITY_NAME , Schedule
674675
675676 self .add_entity (Schedule , ENTITY_NAME )
0 commit comments