resonate.scheduler.scheduler.Scheduler

class documentation

class Scheduler(IScheduler):

Constructor: Scheduler(deps, pid, registry, store, ...)

Undocumented

Method	`__init__`	Undocumented
Method	`get`	Undocumented
Method	`run`	Undocumented
Method	`start`	Undocumented
Method	`stop`	Undocumented
Method	`_add_to_awaiting_local`	Undocumented
Method	`_add_to_awaiting_remote`	Undocumented
Method	`_blocked_only_on_remote`	Undocumented
Method	`_complete_task`	Undocumented
Method	`_get_info_from_rfi`	Undocumented
Method	`_handle_claim`	Undocumented
Method	`_handle_complete`	Undocumented
Method	`_handle_continue`	Undocumented
Method	`_handle_fork_or_join`	Undocumented
Method	`_handle_invoke`	Undocumented
Method	`_handle_notify`	Undocumented
Method	`_handle_resume`	Undocumented
Method	`_handle_subscribe`	Undocumented
Method	`_heartbeat`	Undocumented
Method	`_loop`	Undocumented
Method	`_process_detached`	Undocumented
Method	`_process_final_value`	Undocumented
Method	`_process_invoke_msg`	Undocumented
Method	`_process_lfc`	Undocumented
Method	`_process_lfi`	Undocumented
Method	`_process_promise`	Undocumented
Method	`_process_resume_msg`	Undocumented
Method	`_process_rfc`	Undocumented
Method	`_process_rfi`	Undocumented
Method	`_step`	Undocumented
Method	`_stop`	Undocumented
Method	`_unblock_awaiting_local`	Undocumented
Method	`_unblock_awaiting_remote`	Undocumented
Instance Variable	`_awaiting_lfi`	Undocumented
Instance Variable	`_awaiting_rfi`	Undocumented
Instance Variable	`_cmd_queue`	Undocumented
Instance Variable	`_delay_queue`	Undocumented
Instance Variable	`_deps`	Undocumented
Instance Variable	`_encoder`	Undocumented
Instance Variable	`_heartbeat_thread`	Undocumented
Instance Variable	`_pid`	Undocumented
Instance Variable	`_processor`	Undocumented
Instance Variable	`_records`	Undocumented
Instance Variable	`_recv`	Undocumented
Instance Variable	`_registry`	Undocumented
Instance Variable	`_scheduler_thread`	Undocumented
Instance Variable	`_store`	Undocumented
Instance Variable	`_subsriptions`	Undocumented
Instance Variable	`_task_source`	Undocumented

def __init__(self, deps: Dependencies, pid: str, registry: FunctionRegistry, store: LocalStore | RemoteStore, task_source: ITaskSource): ¶

Undocumented

def get(self, id: str) -> Handle[Any]: ¶

overrides resonate.scheduler.traits.IScheduler.get

Undocumented

def run(self, id: str, func: DurableCoro[P, T] | DurableFn[P, T], /, *args: P.args, **kwargs: P.kwargs) -> Handle[T]: ¶

overrides resonate.scheduler.traits.IScheduler.run

Undocumented

def start(self): ¶

overrides resonate.scheduler.traits.IScheduler.start

Undocumented

def stop(self): ¶

overrides resonate.scheduler.traits.IScheduler.stop

Undocumented

def _add_to_awaiting_local(self, id: str, blocked: str): ¶

Undocumented

def _add_to_awaiting_remote(self, id: str, blocked: str): ¶

Undocumented

def _blocked_only_on_remote(self, id: str, *, root: bool = True) -> bool: ¶

Undocumented

def _complete_task(self, id: str): ¶

Undocumented

def _get_info_from_rfi(self, rfi: RFI) -> tuple[Data, Headers, Tags, int | None]: ¶

Undocumented

def _handle_claim(self, claim: Claim) -> list[Command]: ¶

Undocumented

def _handle_complete(self, complete: Complete) -> list[Command]: ¶

Undocumented

def _handle_continue(self, id: str, next_value: Result[Any, Exception] | None) -> list[Command]: ¶

Undocumented

def _handle_fork_or_join(self, fork_or_join: ForkOrJoin) -> list[Command]: ¶

Undocumented

def _handle_invoke(self, invoke: Invoke) -> list[Command]: ¶

Undocumented

def _handle_notify(self, notify: Notify) -> list[Command]: ¶

Undocumented

def _handle_resume(self, resume: Resume) -> list[Command]: ¶

Undocumented

def _handle_subscribe(self, subscribe: Subscribe) -> list[Command]: ¶

Undocumented

@utils.exit_on_exception
def _heartbeat(self): ¶

Undocumented

@utils.exit_on_exception
def _loop(self): ¶

Undocumented

def _process_detached(self, record: Record[Any], detached: DI) -> list[Command]: ¶

Undocumented

def _process_final_value(self, record: Record[Any], final_value: Result[Any, Exception]) -> list[Command]: ¶

Undocumented

def _process_invoke_msg(self, invoke_msg: InvokeMsg, task: TaskRecord) -> list[Command]: ¶

Undocumented

def _process_lfc(self, record: Record[Any], lfc: LFC) -> list[Command]: ¶

Undocumented

def _process_lfi(self, record: Record[Any], lfi: LFI) -> list[Command]: ¶

Undocumented

def _process_promise(self, record: Record[Any], promise: Promise[Any]) -> list[Command]: ¶

Undocumented

def _process_resume_msg(self, resume_msg: ResumeMsg, task: TaskRecord) -> list[Command]: ¶

Undocumented

def _process_rfc(self, record: Record[Any], rfc: RFC) -> list[Command]: ¶

Undocumented

def _process_rfi(self, record: Record[Any], rfi: RFI) -> list[Command]: ¶

Undocumented

def _step(self, cmd: Command) -> list[Command]: ¶

Undocumented

def _stop(self): ¶

Undocumented

def _unblock_awaiting_local(self, id: str) -> list[Command]: ¶

Undocumented

def _unblock_awaiting_remote(self, id: str) -> list[Command]: ¶

Undocumented

_awaiting_lfi: dict[str, list[str]] = ¶

Undocumented

_awaiting_rfi: dict[str, list[str]] = ¶

Undocumented

_cmd_queue: CommandQ = ¶

Undocumented

_delay_queue = ¶

Undocumented

_deps = ¶

Undocumented

_encoder = ¶

Undocumented

_heartbeat_thread = ¶

Undocumented

_pid = ¶

Undocumented

_processor = ¶

Undocumented

_records: dict[str, Record[Any]] = ¶

Undocumented

_recv = ¶

Undocumented

_registry = ¶

Undocumented

_scheduler_thread = ¶

Undocumented

_store = ¶

Undocumented

_subsriptions: dict[str, list[Handle[Any]]] = ¶

Undocumented

_task_source = ¶

Undocumented