Method●Since v2.0

aput_writes

Asynchronous version of put_writes.

This method is an asynchronous wrapper around put_writes that runs the synchronous method in a separate thread using asyncio.

aput_writes(
  self,
  config: RunnableConfig,
  writes: Sequence[tuple[str, Any]],
  task_id: str,
  task_path: str = ''
) -> None

Parameters

Name	Type	Description
`config`*	`RunnableConfig`	The config to associate with the writes.
`writes`*	`Sequence[tuple[str, Any]]`	The writes to save, each as a (channel, value) pair.
`task_id`*	`str`	Identifier for the task creating the writes.
`task_path`	`str`	Default:`''` Path of the task creating the writes.