temporalio.client.ActivityExecutionAsyncIterator

class documentation

class ActivityExecutionAsyncIterator: (source)

Constructor: ActivityExecutionAsyncIterator(client, input)

View In Hierarchy

Asynchronous iterator for activity execution values.

You should typically use async for on this iterator and not call any of its methods.

Warning

This API is experimental.

Method __aiter__ Return self as the iterator.
Async Method __anext__ Get the next execution on this iterator, fetching next page if necessary.
Method __init__ Create an asynchronous iterator for the given input.
Async Method fetch_next_page Fetch the next page of results.
Property current_page Current page, if it has been fetched yet.
Property current_page_index Index of the entry in the current page that will be returned from the next __anext__ call.
Property next_page_token Token for the next page request if any.
Instance Variable _client Undocumented
Instance Variable _current_page Undocumented
Instance Variable _current_page_index Undocumented
Instance Variable _input Undocumented
Instance Variable _limit Undocumented
Instance Variable _next_page_token Undocumented
Instance Variable _yielded Undocumented
def __aiter__(self) -> ActivityExecutionAsyncIterator: (source)

Return self as the iterator.

async def __anext__(self) -> ActivityExecution: (source)

Get the next execution on this iterator, fetching next page if necessary.

def __init__(self, client: Client, input: ListActivitiesInput): (source)

Create an asynchronous iterator for the given input.

Users should not create this directly, but rather use Client.list_activities.

async def fetch_next_page(self, *, page_size: int | None = None): (source)

Fetch the next page of results.

Parameters
page_size:int | NoneOverride the page size this iterator was originally created with.
current_page: Sequence[ActivityExecution] | None = (source)

Current page, if it has been fetched yet.

current_page_index: int = (source)

Index of the entry in the current page that will be returned from the next __anext__ call.

next_page_token: bytes | None = (source)

Token for the next page request if any.

_client = (source)

Undocumented

_current_page: Sequence[ActivityExecution] | None = (source)

Undocumented

_current_page_index: int = (source)

Undocumented

_input = (source)

Undocumented

_limit = (source)

Undocumented

_next_page_token = (source)

Undocumented

_yielded: int = (source)

Undocumented