temporalio.worker.Replayer
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 |
Replay a workflow for the given history. |
| Async Method | replay |
Replay workflows for the given histories. |
| Method | workflow |
Replay workflows for the given histories. |
| Instance Variable | plugins |
Undocumented |
| Async Method | _workflow |
Undocumented |
| Instance Variable | _config |
Undocumented |
| Instance Variable | _initial |
Undocumented |
Create a replayer to replay workflows from history.
See temporalio.worker.Worker.__init__ for a description of
most of the arguments. Most of the same arguments need to be passed to
the replayer that were passed to the worker when the workflow originally
ran.
Note, unlike the worker, for the replayer the workflow_task_executor will default to a new thread pool executor with no max_workers set that will be shared across all replay calls and never explicitly shut down. Users are encouraged to provide their own if needing more control.
Config, as a dictionary, used to create this replayer.
| Parameters | |
activebool | If true, return the modified configuration in use rather than the initial one provided to the client. |
Replay a workflow for the given history.
Replay workflows for the given histories.
This is a shortcut for workflow_replay_iterator that iterates
all results and aggregates information about them.
| Parameters | |
histories:AsyncIterator[ | The histories to replay, from an async iterator. |
raisebool | If True (the default), this will raise the first replay failure seen. |
Replay workflows for the given histories.
This is a context manager for use via async with. The value is an iterator for use via async for.
| Returns | |
AbstractAsyncContextManager[ | An async iterator that returns replayed workflow results as they are replayed. |