ExecutionContext

ExecutionContext reference.

Methods

cancel(self) -> 'Self'

No docstring.

checkpoint(self) -> 'Awaitable'

No docstring.

claim(self, worker: 'WorkerInfo') -> 'Self'

No docstring.

complete(self, id: 'str', output: 'Any') -> 'Self'

No docstring.

emit_progress(self, task_id: 'str', task_name: 'str', value: 'Any') -> 'None'

No docstring.

fail(self, id: 'str', output: 'Any') -> 'Self'

No docstring.

force_start_resuming(self, input: 'Any | None' = None) -> 'Self'

Transition to RESUMING regardless of the current state.

An approval can be decided before the worker has recorded the WORKFLOW_PAUSED transition, so the execution may still be RUNNING or CLAIMED when the decide handler needs to queue the resume. Only the approval decide path should use this; normal resumes go through start_resuming(), which enforces the PAUSED precondition.

from_json(data: 'dict', checkpoint: 'Callable[[ExecutionContext], Awaitable] | None' = None) -> 'ExecutionContext'

No docstring.

get() -> 'ExecutionContext'

No docstring.

mark_transient(self) -> 'ExecutionContext'

No docstring.

pause(self, id: 'str', name: 'str', output: 'Any' = None) -> 'Self'

No docstring.

reset(token: 'Token') -> 'None'

No docstring.

resume(self) -> 'Any'

No docstring.

resume_claim(self, worker: 'WorkerInfo') -> 'Self'

No docstring.

resume_schedule(self, worker: 'WorkerInfo') -> 'Self'

No docstring.

schedule(self, worker: 'WorkerInfo') -> 'Self'

No docstring.

set(ctx: 'ExecutionContext') -> 'Token'

No docstring.

set_checkpoint(self, checkpoint: 'Callable[[ExecutionContext], Awaitable]') -> 'Self'

No docstring.

set_exec_token(self, token: 'str | None') -> 'None'

No docstring.

set_progress_callback(self, callback: 'Callable') -> 'Self'

No docstring.

start(self, id: 'str') -> 'Self'

No docstring.

start_cancel(self) -> 'Self'

No docstring.

start_resuming(self, input: 'Any | None' = None) -> 'Self'

No docstring.

summary(self)

No docstring.

to_dict(self)

No docstring.

to_json(self)

No docstring.

Generated from flux/ExecutionContext. Last verified against Flux 0.56.0.