temporalio.testing._activity._Activity

temporalio.testing._activity._Activity

class documentation

class _Activity: (source)

Constructor: _Activity(env, fn, client)

View In Hierarchy

Undocumented

def __init__(self, env: ActivityEnvironment, fn: Callable, client: Client | None): (source)

Undocumented

def cancel(self): (source)

Undocumented

def run(self, *args: Any, **kwargs: Any) -> Any: (source)

Undocumented

def worker_shutdown(self): (source)

Undocumented

cancel_thread_raiser: None | temporalio.worker._activity._ThreadExceptionRaiser = (source)

Undocumented

context = (source)

Undocumented

env = (source)

Undocumented

fn = (source)

Undocumented

is_async = (source)

Undocumented

task: asyncio.Task | None = (source)

Undocumented