Check if an annotation is marked as Required/NotRequired. Returns: - True if required - False if not required - None if n

Parse arguments from a string.

Prepare input for a PULL task, based on the process's channels and triggers.

Strips Annotated, Required and NotRequired from a given type.

Strips Annotated, Required and NotRequired from a given type.

Generate a UUID from the SHA-1 hash of a namespace UUID and a name.

Return tuple of operator and value for WHERE clause predicate.

Inject `with vcr.cassette` into each code cell of the notebook.

Get a checkpoint tuple from the database asynchronously. Note: This async method is not supported by the SqliteSaver class.

Get a checkpoint tuple from the database asynchronously. This method retrieves a checkpoint tuple from the SQLite database based on the

Asynchronously fetch a checkpoint tuple using the given configuration. Args: config (RunnableConfig): Configuration specifying wh

List checkpoints from the database asynchronously. This method retrieves a list of checkpoint tuples from the SQLite database based o

Save a checkpoint to the database asynchronously. Note: This async method is not supported by the SqliteSaver class.

Save a checkpoint to the database asynchronously. This method saves a checkpoint to the SQLite database. The checkpoint is associated

Asynchronously store or update an item. Args: namespace: Hierarchical path for the item. key: Unique identifier withi

Store intermediate writes linked to a checkpoint asynchronously. This method saves intermediate writes associated with a checkpoint to the da

Store intermediate writes linked to a checkpoint asynchronously. This method saves intermediate writes associated with a checkpoint to the da

Asynchronous version of put_writes. This method is an asynchronous wrapper around put_writes that runs the synchronous method in a se

Run a task asynchronously with retries.

Mark the current value of the channel as consumed. By default, no-op. This is called by Pregel before the start of the next step, for all

Return True if the queue is empty, False otherwise (not reliable!).

Return the current value of the channel. Raises EmptyChannelError if the channel is empty (never updated yet).

Get a checkpoint tuple from the database. This method retrieves a checkpoint tuple from the Postgres database based on the provided c

Fetch a checkpoint tuple using the given configuration. Args: config (RunnableConfig): Configuration specifying which checkpoint

* Do not rely on globalThis.Response, rather just * do duck typing

Used by PregelNode to distinguish between writers and other runnables.

List checkpoints from the database. This method retrieves a list of checkpoint tuples from the SQLite database based on the provided

List checkpoints from the in-memory storage. This method retrieves a list of checkpoint tuples from the in-memory storage based on th

Map input chunk to a sequence of pending writes in the form (channel, value).

Map pending writes (a sequence of tuples (channel, value)) to output chunk.

Wrap serde old serde implementations in a class with loads_typed and dumps_typed for backwards compatibility.