StateStorage
Abstract interface for state persistence - supports both sync and async operations
Functions
func
asave_executor_stateasave_executor_state(self, /, execution_id, state) -> None
param
selfparam
execution_idUUID
param
statedict[str, Any]
Returns
None
func
aload_executor_stateaload_executor_state(self, /, execution_id) -> dict[str, Any] | None
param
selfparam
execution_idUUID
Returns
dict[str, Any] | None
func
asave_actor_stateasave_actor_state(self, /, execution_id, actor_id, state) -> None
param
selfparam
execution_idUUID
param
actor_idUUID
param
statedict[str, Any]
Returns
None
func
aload_actor_stateaload_actor_state(self, /, execution_id, actor_id) -> dict[str, Any] | None
param
selfparam
execution_idUUID
param
actor_idUUID
Returns
dict[str, Any] | None
func
adelete_execution_stateadelete_execution_state(self, /, execution_id) -> None
param
selfparam
execution_idUUID
Returns
None
func
save_executor_statesave_executor_state(self, /, execution_id, state) -> None
param
selfparam
execution_idUUID
param
statedict[str, Any]
Returns
None
func
load_executor_stateload_executor_state(self, /, execution_id) -> dict[str, Any] | None
param
selfparam
execution_idUUID
Returns
dict[str, Any] | None
func
save_actor_statesave_actor_state(self, /, execution_id, actor_id, state) -> None
param
selfparam
execution_idUUID
param
actor_idUUID
param
statedict[str, Any]
Returns
None
func
load_actor_stateload_actor_state(self, /, execution_id, actor_id) -> dict[str, Any] | None
param
selfparam
execution_idUUID
param
actor_idUUID
Returns
dict[str, Any] | None
func
delete_execution_statedelete_execution_state(self, /, execution_id) -> None
param
selfparam
execution_idUUID
Returns
None
Last updated on