neograph::program::SyncTaskGraphFragmentStore Class Reference

Base of a TaskGraphFragmentStore whose backend is synchronous. More...

#include <task_graph_fragment.h>

Inheritance diagram for neograph::program::SyncTaskGraphFragmentStore:

Collaboration diagram for neograph::program::SyncTaskGraphFragmentStore:

Public Member Functions
bool	completes_at_once () const noexcept
	True when every awaitable operation completes at once on the calling thread, not on a pool thread.
asio::awaitable< std::optional< TaskGraphFragmentRecord > >	find_published (std::string_view owner_scope, std::string_view parent_run_id, std::string_view expansion_operation_id, std::string_view proposal_hash) const final
	Locate an already published expansion by immutable parent lineage and proposal identity.
asio::awaitable< std::optional< TaskGraphFragmentRecord > >	find_published_lineage (std::string_view owner_scope, std::string_view parent_run_id, std::string_view expansion_operation_id) const final
	Locate the published expansion for one immutable parent operation.

Protected Member Functions
virtual bool	offloads () const noexcept
	True for a backend that blocks for long: each operation then runs on a pool thread.

Detailed Description

Base of a TaskGraphFragmentStore whose backend is synchronous.

A derived class implements the ..._sync operations and gets the awaitable interface from them, as SyncProgramTransitionStore does.

Definition at line 230 of file task_graph_fragment.h.

Member Function Documentation

find_published()

asio::awaitable< std::optional< TaskGraphFragmentRecord > > neograph::program::SyncTaskGraphFragmentStore::find_published ( std::string_view  owner_scope, std::string_view  parent_run_id, std::string_view  expansion_operation_id, std::string_view  proposal_hash  ) const

finalvirtual

Locate an already published expansion by immutable parent lineage and proposal identity.

The default is deliberately empty for legacy stores; such stores remain safe but cannot recover an expansion without replanning.

Reimplemented from neograph::program::TaskGraphFragmentStore.

find_published_lineage()

asio::awaitable< std::optional< TaskGraphFragmentRecord > > neograph::program::SyncTaskGraphFragmentStore::find_published_lineage ( std::string_view  owner_scope, std::string_view  parent_run_id, std::string_view  expansion_operation_id  ) const

finalvirtual

Locate the published expansion for one immutable parent operation.

This lookup is used before reading the proposal source during recovery. A durable fragment is the source of truth after publication; the proposal is only needed on the first execution or when no fragment has crossed the publication boundary.

Reimplemented from neograph::program::TaskGraphFragmentStore.

---

The documentation for this class was generated from the following file:

• include/neograph/program/task_graph_fragment.h