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.

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