temporalio.testing._activity._Activity

class documentation

class _Activity: (source)

Constructor: _Activity(env, fn, client)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method cancel Undocumented
Method run Undocumented
Method worker_shutdown Undocumented
Instance Variable cancel_thread_raiser Undocumented
Instance Variable context Undocumented
Instance Variable env Undocumented
Instance Variable fn Undocumented
Instance Variable is_async Undocumented
Instance Variable task Undocumented
def __init__(self, env: ActivityEnvironment, fn: Callable, client: Client | None): (source)

Undocumented

def cancel(self): (source)

Undocumented

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

Undocumented

def worker_shutdown(self): (source)

Undocumented

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

Undocumented

context = (source)

Undocumented

env = (source)

Undocumented

fn = (source)

Undocumented

is_async = (source)

Undocumented

task: asyncio.Task | None = (source)

Undocumented