class documentation

class Replayer: (source)

View In Hierarchy

Replayer to replay workflows from history.

Method __init__ Create a replayer to replay workflows from history.
Method config Config, as a dictionary, used to create this replayer.
Async Method replay_workflow Replay a workflow for the given history.
Instance Variable _config Undocumented
def __init__(self, *, workflows: Sequence[Type], workflow_task_executor: Optional[concurrent.futures.ThreadPoolExecutor] = None, workflow_runner: WorkflowRunner = UnsandboxedWorkflowRunner(), namespace: str = 'ReplayNamespace', data_converter: temporalio.converter.DataConverter = temporalio.converter.default(), interceptors: Sequence[Interceptor] = [], build_id: Optional[str] = None, identity: Optional[str] = None, debug_mode: bool = False): (source)

Create a replayer to replay workflows from history.

See temporalio.worker.Worker.__init__ for a description of arguments. The same arguments need to be passed to the replayer that were passed to the worker when the workflow originally ran.

def config(self) -> ReplayerConfig: (source)

Config, as a dictionary, used to create this replayer.

Returns
ReplayerConfigConfiguration, shallow-copied.
async def replay_workflow(self, history: Union[temporalio.api.history.v1.History, str, Dict[str, Any]]): (source)

Replay a workflow for the given history.

Parameters
history:Union[temporalio.api.history.v1.History, str, Dict[str, Any]]The history to replay. Can be a proto history object or JSON history as exported via web/tctl. If JSON history, can be a JSON string or a JSON dictionary as returned by json.load.
_config = (source)

Undocumented