nebius.aio._runtime._WorkItem

class documentation

class _WorkItem: (source)

Constructor: _WorkItem(future, fn, args, kwargs)

View In Hierarchy

Store one function call for a daemon worker.

A work item writes the call result or exception to a concurrent future.

Method __init__ Initialize a worker item.
Method run Run the stored call and complete its future.
Instance Variable args Undocumented
Instance Variable fn Undocumented
Instance Variable future Undocumented
Instance Variable kwargs Undocumented
def __init__(self, future: Future[Any], fn: Callable[..., Any], args: tuple[Any, ...], kwargs: dict[str, Any]): (source)

Initialize a worker item.

Parameters
future:Future[Any]Future that receives the call result.
fn:Callable[..., Any]Function to call.
args:tuple[Any, ...]Positional arguments for fn.
kwargs:dict[str, Any]Keyword arguments for fn.
def run(self): (source)

Run the stored call and complete its future.

args = (source)

Undocumented

fn = (source)

Undocumented

future = (source)

Undocumented

kwargs = (source)

Undocumented