temporalio.contrib.workflow_streams.WorkflowStreamItem

class documentation

class WorkflowStreamItem(Generic[T]): (source)

View In Hierarchy

A single item in the workflow stream's log.

Warning

This class is experimental and may change in future versions.

The data field carries the decoded value produced by WorkflowStreamClient.subscribe. The generic parameter T matches the result_type passed to subscribe: an instance of T when result_type=T, the converter's default Any decoding when result_type is omitted, or a temporalio.common.RawValue wrapping the original Payload when result_type=RawValue.

The offset field is populated at poll time from the item's position in the global log.

Class Variable data Undocumented
Class Variable offset Undocumented
Class Variable topic Undocumented
data: T = (source)

Undocumented

offset: int = (source)

Undocumented

topic: str = (source)

Undocumented