dbx-tools-graphiti Python API

For setup, workflows, and operational guidance, see the dbx-tools-graphiti package guide.

Import package: dbx_tools.graphiti.

`dbx_tools.graphiti.main`

Run Graphiti or print its OpenAPI document.

`main`

def main(argv: list[str] | None=None) -> None

Start the environment-configured server, or print OpenAPI for docs.

Source: packages/py/graphiti/src/dbx_tools/graphiti/__main__.py:11

`dbx_tools.graphiti._generated.node._runtime`

`get_runtime`

def get_runtime() -> RuntimeBundle

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/_runtime.py:17

`invoke_positioned`

async def invoke_positioned(module: str, name: str, arguments: list[tuple[int, Any]]) -> Any

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/_runtime.py:24

`invoke_positioned_sync`

def invoke_positioned_sync(module: str, name: str, arguments: list[tuple[int, Any]]) -> Any

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/_runtime.py:32

`dbx_tools.graphiti._generated.node.auth.bindings`

`AuthOptions`

class AuthOptions

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/auth/bindings.py:21

Fields

refresh_buffer_ms: int | float | None
lock_timeout_ms: int | float | None
login_timeout_ms: int | float | None

`DatabricksAuthDependencies`

class DatabricksAuthDependencies

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/auth/bindings.py:37

Fields

environment: dict[str, str] | None
fetch: Callable[..., Any] | None
resolve_cli: Callable[..., Any] | None

`DatabricksAuthOptions`

class DatabricksAuthOptions

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/auth/bindings.py:53

Fields

auth: AuthOptions | None
profile: str | None
host: str | None
account_id: str | None
workspace_id: str | None
config_file: str | None
client_id: str | None
client_secret: str | None
access_token: str | None
group_id: str | None
auth_type: str | None
scopes: list[str] | None
target: str | None
request_headers: dict[str, str] | None
access_token_header: str | None
prefer_user_to_machine: bool | None

`AccessTokenResponse`

class AccessTokenResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/auth/bindings.py:120

Fields

accessToken: str
tokenType: str
expiry: NotRequired[str]
scopes: list[str]

`TokenOptionsResponse`

class TokenOptionsResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/auth/bindings.py:127

Fields

login: NotRequired[bool | None]
refresh: NotRequired[bool | None]

`AuthClient`

class AuthClient(Protocol)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/auth/bindings.py:132

Fields

host: str
target: str
auth_type: str
principal: str
profile: str | None
account_id: str | None
workspace_id: str | None

Methods

`token`

async def token(self, options: TokenOptionsResponse=...) -> AccessTokenResponse

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/auth/bindings.py:147

`headers`

async def headers(self, options: TokenOptionsResponse=...) -> dict[str, str]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/auth/bindings.py:152

`logout`

async def logout(self) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/auth/bindings.py:157

`create_auth_client`

async def create_auth_client(options: DatabricksAuthOptions | dict[str, Any] | None | object=_MISSING, dependencies: DatabricksAuthDependencies | dict[str, Any] | None | object=_MISSING) -> AuthClient

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/auth/bindings.py:162

`dbx_tools.graphiti._generated.node.lakebase.bindings`

`AuthOptions`

class AuthOptions

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/lakebase/bindings.py:20

Fields

refresh_buffer_ms: int | float | None
lock_timeout_ms: int | float | None
login_timeout_ms: int | float | None

`DatabricksAuthOptions`

class DatabricksAuthOptions

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/lakebase/bindings.py:36

Fields

auth: AuthOptions | None
profile: str | None
host: str | None
account_id: str | None
workspace_id: str | None
config_file: str | None
client_id: str | None
client_secret: str | None
access_token: str | None
group_id: str | None
auth_type: str | None
scopes: list[str] | None
target: str | None
request_headers: dict[str, str] | None
access_token_header: str | None
prefer_user_to_machine: bool | None

`LakebaseConnectionInputsResponse`

class LakebaseConnectionInputsResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/lakebase/bindings.py:103

Fields

project: NotRequired[str]
branch: NotRequired[str]
endpoint: NotRequired[str]
endpointId: NotRequired[str]
database: NotRequired[str]
databaseResourceId: NotRequired[str]
user: NotRequired[str]
host: NotRequired[str]
port: NotRequired[int | float]
sslMode: NotRequired[str | None]

`ParsedAddressResponse`

class ParsedAddressResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/lakebase/bindings.py:116

Fields

project: NotRequired[str]
branch: NotRequired[str]
endpoint: NotRequired[str]
endpointId: NotRequired[str]
database: NotRequired[str]
databaseResourceId: NotRequired[str]
user: NotRequired[str]
host: NotRequired[str]
port: NotRequired[int | float]
sslMode: NotRequired[str | None]

`ResolvedLakebaseResponse`

class ResolvedLakebaseResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/lakebase/bindings.py:129

Fields

host: str
port: int | float
database: str
user: str
endpoint: str
project: str
branch: str

`LakebaseClient`

class LakebaseClient(Protocol)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/lakebase/bindings.py:139

Methods

`resolve`

async def resolve(self, target: LakebaseConnectionInputsResponse, startup_user: str=...) -> ResolvedLakebaseResponse

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/lakebase/bindings.py:140

`generate_database_credential`

async def generate_database_credential(self, endpoint: str, startup_user: str=...) -> str

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/lakebase/bindings.py:146

`create_lakebase_client`

def create_lakebase_client(options: DatabricksAuthOptions | dict[str, Any] | None | object=_MISSING) -> LakebaseClient

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/lakebase/bindings.py:153

`parse_address`

def parse_address(input: str | None) -> ParsedAddressResponse

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/lakebase/bindings.py:162

`dbx_tools.graphiti._generated.node.model.bindings`

`ModelAuthOptions`

class ModelAuthOptions

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:20

Fields

profile: str | None

`ModelClientOptions`

class ModelClientOptions

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:28

Fields

auth: ModelAuthOptions | None
cache_ttl_ms: int | float | None
hydrate_metadata: bool | None

`CreateModelClientReturnListModelsReturnProfileResultResponse`

class CreateModelClientReturnListModelsReturnProfileResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:43

Fields

quality: NotRequired[int | float]
speed: NotRequired[int | float]
cost: NotRequired[int | float]

`CreateModelClientReturnListModelsReturnStatusResultResponse`

class CreateModelClientReturnListModelsReturnStatusResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:49

Fields

deprecated: bool

`CreateModelClientReturnListModelsReturnResultResponse`

CreateModelClientReturnListModelsReturnResultResponse

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:53

`CreateModelClientReturnMetadataModelProfileResultResponse`

class CreateModelClientReturnMetadataModelProfileResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:74

Fields

quality: NotRequired[int | float]
speed: NotRequired[int | float]
cost: NotRequired[int | float]

`CreateModelClientReturnMetadataModelStatusResultResponse`

class CreateModelClientReturnMetadataModelStatusResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:80

Fields

deprecated: bool

`CreateModelClientReturnMetadataModelResultResponse`

CreateModelClientReturnMetadataModelResultResponse

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:84

`CreateModelClientReturnMetadataReturnCapabilitiesResultResponse`

class CreateModelClientReturnMetadataReturnCapabilitiesResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:105

Fields

responses: bool
imageInput: bool
applyPatch: bool
webSearch: bool

`CreateModelClientReturnMetadataReturnRateLimitsResultResponse`

class CreateModelClientReturnMetadataReturnRateLimitsResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:112

Fields

inputTokensPerMinute: int | float | None
outputTokensPerMinute: int | float | None
queriesPerHour: int | float | None

`CreateModelClientReturnMetadataReturnStatusResultResponse`

class CreateModelClientReturnMetadataReturnStatusResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:118

Fields

deprecated: bool

`CreateModelClientReturnMetadataReturnResultResponse`

class CreateModelClientReturnMetadataReturnResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:122

Fields

status: CreateModelClientReturnMetadataReturnStatusResultResponse
capabilities: CreateModelClientReturnMetadataReturnCapabilitiesResultResponse
rateLimits: NotRequired[CreateModelClientReturnMetadataReturnRateLimitsResultResponse]

`CreateModelClientReturnRouteReturnEndpointProfileResultResponse`

class CreateModelClientReturnRouteReturnEndpointProfileResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:128

Fields

quality: NotRequired[int | float]
speed: NotRequired[int | float]
cost: NotRequired[int | float]

`CreateModelClientReturnRouteReturnEndpointStatusResultResponse`

class CreateModelClientReturnRouteReturnEndpointStatusResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:134

Fields

deprecated: bool

`CreateModelClientReturnRouteReturnEndpointResultResponse`

CreateModelClientReturnRouteReturnEndpointResultResponse

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:138

`CreateModelClientReturnRouteReturnMetadataCapabilitiesResultResponse`

class CreateModelClientReturnRouteReturnMetadataCapabilitiesResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:159

Fields

responses: bool
imageInput: bool
applyPatch: bool
webSearch: bool

`CreateModelClientReturnRouteReturnMetadataRateLimitsResultResponse`

class CreateModelClientReturnRouteReturnMetadataRateLimitsResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:166

Fields

inputTokensPerMinute: int | float | None
outputTokensPerMinute: int | float | None
queriesPerHour: int | float | None

`CreateModelClientReturnRouteReturnMetadataStatusResultResponse`

class CreateModelClientReturnRouteReturnMetadataStatusResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:172

Fields

deprecated: bool

`CreateModelClientReturnRouteReturnMetadataResultResponse`

class CreateModelClientReturnRouteReturnMetadataResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:176

Fields

status: CreateModelClientReturnRouteReturnMetadataStatusResultResponse
capabilities: CreateModelClientReturnRouteReturnMetadataCapabilitiesResultResponse
rateLimits: NotRequired[CreateModelClientReturnRouteReturnMetadataRateLimitsResultResponse]

`CreateModelClientReturnSearchModelsQueryResultResponse`

class CreateModelClientReturnSearchModelsQueryResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:182

Fields

name: NotRequired[str]
search: NotRequired[str]
modelClass: NotRequired[str | None]
requiresTools: NotRequired[bool | None]
task: NotRequired[str]
dimension: NotRequired[int | float]
minDimension: NotRequired[int | float]
maxDimension: NotRequired[int | float]
reasoningEffort: NotRequired[str | None]
includeDeprecated: NotRequired[bool | None]
limit: NotRequired[int | float]
threshold: NotRequired[int | float]

`CreateModelClientReturnSearchModelsReturnEndpointProfileResultResponse`

class CreateModelClientReturnSearchModelsReturnEndpointProfileResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:197

Fields

quality: NotRequired[int | float]
speed: NotRequired[int | float]
cost: NotRequired[int | float]

`CreateModelClientReturnSearchModelsReturnEndpointStatusResultResponse`

class CreateModelClientReturnSearchModelsReturnEndpointStatusResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:203

Fields

deprecated: bool

`CreateModelClientReturnSearchModelsReturnEndpointResultResponse`

CreateModelClientReturnSearchModelsReturnEndpointResultResponse

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:207

`CreateModelClientReturnSearchModelsReturnResultResponse`

class CreateModelClientReturnSearchModelsReturnResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:228

Fields

endpoint: CreateModelClientReturnSearchModelsReturnEndpointResultResponse
modelClass: str
score: NotRequired[int | float]

`ModelClientStatusResponse`

class ModelClientStatusResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:234

Fields

profile: NotRequired[str]
host: str
principal: str
workspaceId: NotRequired[str]
cacheTtlMs: int | float

`ModelRouteInputResponse`

class ModelRouteInputResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:242

Fields

refresh: NotRequired[bool | None]
protocol: NotRequired[str | None]
login: NotRequired[bool | None]
explicit: NotRequired[str]
fuzzy: NotRequired[bool | None]
threshold: NotRequired[int | float]
requiresTools: NotRequired[bool | None]
modelClass: NotRequired[str | None]
fallbacks: NotRequired[list[str]]
liveOnly: NotRequired[bool | None]

`ModelRouteResponse`

class ModelRouteResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:255

Fields

modelId: str
endpoint: NotRequired[CreateModelClientReturnRouteReturnEndpointResultResponse]
source: str
protocol: str
host: str
apiBase: str
url: str
headers: dict[str, str]
metadata: CreateModelClientReturnRouteReturnMetadataResultResponse

`ModelClient`

class ModelClient(Protocol)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:267

Methods

`list_models`

async def list_models(self, refresh: bool=...) -> list[CreateModelClientReturnListModelsReturnResultResponse]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:268

`search_models`

async def search_models(self, query: CreateModelClientReturnSearchModelsQueryResultResponse=..., refresh: bool=...) -> list[CreateModelClientReturnSearchModelsReturnResultResponse]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:273

`route`

async def route(self, input: ModelRouteInputResponse=...) -> ModelRouteResponse

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:279

`metadata`

async def metadata(self, model: str | CreateModelClientReturnMetadataModelResultResponse) -> CreateModelClientReturnMetadataReturnResultResponse

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:284

`status`

async def status(self) -> ModelClientStatusResponse

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:289

`create_model_client`

async def create_model_client(options: ModelClientOptions | dict[str, Any] | None | object=_MISSING) -> ModelClient

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/model/bindings.py:294

`dbx_tools.graphiti._generated.node.postgres.bindings`

`postgres_role_statement`

def postgres_role_statement(role: str | object=_MISSING) -> str | None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/postgres/bindings.py:22

`postgres_server_settings`

def postgres_server_settings(role: str | object=_MISSING, settings: dict[str, str] | object=_MISSING) -> dict[str, str]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/postgres/bindings.py:31

`quote_postgres_identifier`

def quote_postgres_identifier(value: str) -> str

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/postgres/bindings.py:43

`resolve_postgres_role`

def resolve_postgres_role(role: str | object=_MISSING, environment: dict[str, str] | object=_MISSING) -> str | None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/postgres/bindings.py:51

`dbx_tools.graphiti._generated.node.shared_core.bindings`

`log_active_level`

def log_active_level() -> str

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/shared_core/bindings.py:22

`log_level_enabled`

def log_level_enabled(level: str) -> bool

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/shared_core/bindings.py:27

`dbx_tools.graphiti._generated.node.shared_graphiti.options`

`GraphitiOptions`

class GraphitiOptions

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/shared_graphiti/options.py:20

Fields

postgres_role: str | None
profile: str | None
bearer: str | None
graphiti_home: str | None
model_class: str | None
temperature: int | float | None
structured_output_mode: str | None
startup_timeout_ms: int | float | None
listen: Any | None
database_url: str | None
database_schema: str | None

`GraphitiOptionsResponse`

class GraphitiOptionsResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/shared_graphiti/options.py:67

Fields

postgresRole: NotRequired[str]
profile: NotRequired[str]
bearer: NotRequired[str]
graphitiHome: NotRequired[str]
modelClass: NotRequired[str | None]
temperature: NotRequired[int | float]
structuredOutputMode: NotRequired[str]
startupTimeoutMs: NotRequired[int | float]
listen: NotRequired[Any]
databaseUrl: NotRequired[str]
databaseSchema: NotRequired[str]

`ResolveGraphitiOptionsReturnListenResultResponse`

class ResolveGraphitiOptionsReturnListenResultResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/shared_graphiti/options.py:81

Fields

scheme: str
host: str
port: int | float

`ResolvedGraphitiOptionsResponse`

class ResolvedGraphitiOptionsResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/shared_graphiti/options.py:87

Fields

modelClass: str
temperature: int | float
structuredOutputMode: str
startupTimeoutMs: int | float
listen: ResolveGraphitiOptionsReturnListenResultResponse
databaseSchema: str
postgresRole: NotRequired[str]
profile: NotRequired[str]
bearer: NotRequired[str]
graphitiHome: NotRequired[str]
databaseUrl: NotRequired[str]

`graphiti_option_overrides`

def graphiti_option_overrides(value: Any) -> GraphitiOptionsResponse

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/shared_graphiti/options.py:102

`graphiti_options_environment`

def graphiti_options_environment(value: GraphitiOptions | dict[str, Any] | None | object=_MISSING) -> dict[str, str]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/shared_graphiti/options.py:110

`graphiti_options_from_environment`

def graphiti_options_from_environment(environment: dict[str, str]) -> GraphitiOptionsResponse

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/shared_graphiti/options.py:119

`resolve_graphiti_options`

def resolve_graphiti_options(options: GraphitiOptions | dict[str, Any] | None | object=_MISSING) -> ResolvedGraphitiOptionsResponse

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/shared_graphiti/options.py:127

`dbx_tools.graphiti._generated.node.shared_model.display`

`to_model_display_name`

def to_model_display_name(name: str, provided: str | None | object=_MISSING) -> str

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/shared_model/display.py:22

`dbx_tools.graphiti._generated.node.shared_model.openai_chat`

`ChatContentToTextOptions`

class ChatContentToTextOptions

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/shared_model/openai_chat.py:20

Fields

separator: str | None
types: list[str] | None

`chat_content_parts`

def chat_content_parts(content: Any) -> list[dict[str, Any]] | None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/shared_model/openai_chat.py:33

`chat_content_to_text`

def chat_content_to_text(content: Any, options: ChatContentToTextOptions | dict[str, Any] | None | object=_MISSING) -> str

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/shared_model/openai_chat.py:41

`strip_unsupported_chat_fields`

def strip_unsupported_chat_fields(body: dict[str, Any], extra: list[str] | object=_MISSING) -> list[str]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/node/shared_model/openai_chat.py:52

`dbx_tools.graphiti._generated.sync.graphiti_mcp.config.schema`

Configuration schemas with pydantic-settings and YAML support.

`YamlSettingsSource`

class YamlSettingsSource(PydanticBaseSettingsSource)

Custom settings source for loading from YAML files.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:16

Methods

`get_field_value`

def get_field_value(self, field_name: str, field_info: Any) -> Any

Get field value from YAML config.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:60

`ServerConfig`

class ServerConfig(BaseModel)

Server configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:76

Fields

transport: str
host: str
port: int

`OpenAIProviderConfig`

class OpenAIProviderConfig(BaseModel)

OpenAI provider configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:87

Fields

api_key: str | None
api_url: str
organization_id: str | None

`AzureOpenAIProviderConfig`

class AzureOpenAIProviderConfig(BaseModel)

Azure OpenAI provider configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:95

Fields

api_key: str | None
api_url: str | None
api_version: str
deployment_name: str | None
use_azure_ad: bool

`AnthropicProviderConfig`

class AnthropicProviderConfig(BaseModel)

Anthropic provider configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:105

Fields

api_key: str | None
api_url: str
max_retries: int

`GeminiProviderConfig`

class GeminiProviderConfig(BaseModel)

Gemini provider configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:113

Fields

api_key: str | None
project_id: str | None
location: str

`GroqProviderConfig`

class GroqProviderConfig(BaseModel)

Groq provider configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:121

Fields

api_key: str | None
api_url: str

`VoyageProviderConfig`

class VoyageProviderConfig(BaseModel)

Voyage AI provider configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:128

Fields

api_key: str | None
api_url: str
model: str

`LLMProvidersConfig`

class LLMProvidersConfig(BaseModel)

LLM providers configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:136

Fields

openai: OpenAIProviderConfig | None
azure_openai: AzureOpenAIProviderConfig | None
anthropic: AnthropicProviderConfig | None
gemini: GeminiProviderConfig | None
groq: GroqProviderConfig | None

`LLMConfig`

class LLMConfig(BaseModel)

LLM configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:146

Fields

provider: str
model: str
temperature: float | None
max_tokens: int
structured_output_mode: Literal['json_schema', 'json_object']
providers: LLMProvidersConfig

`EmbedderProvidersConfig`

class EmbedderProvidersConfig(BaseModel)

Embedder providers configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:166

Fields

openai: OpenAIProviderConfig | None
azure_openai: AzureOpenAIProviderConfig | None
gemini: GeminiProviderConfig | None
voyage: VoyageProviderConfig | None

`EmbedderConfig`

class EmbedderConfig(BaseModel)

Embedder configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:175

Fields

provider: str
model: str
dimensions: int
providers: EmbedderProvidersConfig

`Neo4jProviderConfig`

class Neo4jProviderConfig(BaseModel)

Neo4j provider configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:184

Fields

uri: str
username: str
password: str | None
database: str
use_parallel_runtime: bool

`FalkorDBProviderConfig`

class FalkorDBProviderConfig(BaseModel)

FalkorDB provider configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:194

Fields

uri: str
username: str | None
password: str | None
database: str

`DatabaseProvidersConfig`

class DatabaseProvidersConfig(BaseModel)

Database providers configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:203

Fields

neo4j: Neo4jProviderConfig | None
falkordb: FalkorDBProviderConfig | None

`DatabaseConfig`

class DatabaseConfig(BaseModel)

Database configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:210

Fields

provider: str
providers: DatabaseProvidersConfig

`EntityTypeConfig`

class EntityTypeConfig(BaseModel)

Entity type configuration.

If ``name`` matches a model registered in ``models.entity_types.ENTITY_TYPES``,
the rich Pydantic model (with its attributes and extraction instructions) is
registered with graphiti-core. Otherwise a documentation-only model is built
from ``name`` + ``description`` for backward compatibility.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:217

Fields

name: str
description: str

`EdgeTypeConfig`

class EdgeTypeConfig(BaseModel)

Edge (fact) type configuration.

Mirrors :class:`EntityTypeConfig`. If ``name`` matches a model registered in
``models.edge_types.EDGE_TYPES``, the rich Pydantic model is registered with
graphiti-core. Otherwise a documentation-only model is built from
``name`` + ``description``.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:230

Fields

name: str
description: str

`EdgeTypeMapEntry`

class EdgeTypeMapEntry(BaseModel)

Maps an ordered (source entity type, target entity type) pair to the edge type names permitted between them.

Use ``'Entity'`` as a wildcard for either endpoint, matching graphiti-core's
``edge_type_map`` convention.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:243

Fields

source: str
target: str
edge_types: list[str]

`GraphitiAppConfig`

class GraphitiAppConfig(BaseModel)

Graphiti-specific configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:258

Fields

group_id: str
episode_id_prefix: str | None
user_id: str
entity_types: list[EntityTypeConfig]
edge_types: list[EdgeTypeConfig]
edge_type_map: list[EdgeTypeMapEntry]

Methods

`model_post_init`

def model_post_init(self, __context) -> None

Convert None to empty string for episode_id_prefix.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:268

`GraphitiConfig`

class GraphitiConfig(BaseSettings)

Graphiti configuration with YAML and environment support.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:274

Fields

server: ServerConfig
llm: LLMConfig
embedder: EmbedderConfig
database: DatabaseConfig
graphiti: GraphitiAppConfig
destroy_graph: bool

Methods

`settings_customise_sources`

def settings_customise_sources(cls, settings_cls: type[BaseSettings], init_settings: PydanticBaseSettingsSource, env_settings: PydanticBaseSettingsSource, dotenv_settings: PydanticBaseSettingsSource, file_secret_settings: PydanticBaseSettingsSource) -> tuple[PydanticBaseSettingsSource, ...]

Customize settings sources to include YAML.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:294

`apply_cli_overrides`

def apply_cli_overrides(self, args) -> None

Apply CLI argument overrides to configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/config/schema.py:308

`dbx_tools.graphiti._generated.sync.graphiti_mcp.graphiti_mcp_server`

Graphiti MCP Server - Exposes Graphiti functionality through the Model Context Protocol (MCP)

`mcp_server_dir`

mcp_server_dir

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:60

`env_file`

env_file

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:61

`SEMAPHORE_LIMIT`

SEMAPHORE_LIMIT

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:96

`LOG_FORMAT`

LOG_FORMAT

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:100

`DATE_FORMAT`

DATE_FORMAT

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:101

`configure_uvicorn_logging`

def configure_uvicorn_logging()

Configure uvicorn loggers to match our format after they’re created.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:119

`logger`

logger

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:131

`config`

config: GraphitiConfig

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:134

`GRAPHITI_MCP_INSTRUCTIONS`

GRAPHITI_MCP_INSTRUCTIONS

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:137

`mcp`

mcp

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:178

`graphiti_service`

graphiti_service: Optional['GraphitiService']

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:184

`queue_service`

queue_service: QueueService | None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:185

`graphiti_client`

graphiti_client: Graphiti | None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:223

`semaphore`

semaphore: asyncio.Semaphore

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:224

`GraphitiService`

class GraphitiService

Graphiti service using the unified configuration system.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:227

Methods

`initialize`

async def initialize(self) -> None

Initialize the Graphiti client with factory-created components.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:239

`get_client`

async def get_client(self) -> Graphiti

Get the Graphiti client, initializing if necessary.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:393

`add_memory`

async def add_memory(name: str, episode_body: str, group_id: str | None=None, source: str='text', source_description: str='', uuid: str | None=None, reference_time: str | None=None, excluded_entity_types: list[str] | None=None, custom_extraction_instructions: str | None=None, previous_episode_uuids: list[str] | None=None, update_communities: bool=False, saga: str | None=None, saga_previous_episode_uuid: str | None=None) -> SuccessResponse | ErrorResponse

Add an episode to memory. This is the primary way to add information to the graph.

This function returns immediately and processes the episode addition in the background.
Episodes for the same group_id are processed sequentially to avoid race conditions.

Graphiti uses a bi-temporal model: each episode records both when it was ingested and
when the described events actually occurred (its reference_time). Pass reference_time to
set the event-occurrence time explicitly; otherwise the current time is used.

Args:
    name (str): Name of the episode
    episode_body (str): The content of the episode to persist to memory. When source='json', this must be a
                       properly escaped JSON string, not a raw Python dictionary. The JSON data will be
                       automatically processed to extract entities and relationships.
    group_id (str, optional): A unique ID for this graph. If not provided, uses the default group_id from CLI
                             or a generated one.
    source (str, optional): Source type, must be one of:
                           - 'text': For plain text content (default)
                           - 'json': For structured data
                           - 'message': For conversation-style content
    source_description (str, optional): Description of the source
    uuid (str, optional): UUID of an existing episode to update; omit it to create a new episode
    reference_time (str, optional): ISO-8601 timestamp for when the described events occurred
                             (e.g. "2025-01-15T10:30:00Z" or "2025-01-15T10:30:00+00:00"). A
                             timezone-naive value is interpreted as UTC. Defaults to the
                             current time when omitted.
    excluded_entity_types (list[str], optional): Names of configured entity types to exclude
                             from extraction for this episode.
    custom_extraction_instructions (str, optional): Additional natural-language guidance passed
                             to the extraction model for this episode only.
    previous_episode_uuids (list[str], optional): Explicit list of prior episode UUIDs to use
                             as conversational/contextual history. Overrides automatic retrieval.
    update_communities (bool, optional): When True, incrementally update community summaries to
                             reflect entities affected by this episode. Defaults to False.
    saga (str, optional): Name/id of a saga to associate this episode with. Sagas group related
                             episodes so their evolving narrative can be summarized via summarize_saga.
    saga_previous_episode_uuid (str, optional): UUID of the preceding episode in the saga, used to
                             order episodes within the saga.

Examples:
    # Adding plain text content
    add_memory(
        name="Company News",
        episode_body="Acme Corp announced a new product line today.",
        source="text",
        source_description="news article",
        group_id="some_arbitrary_string"
    )

    # Adding structured JSON data
    # NOTE: episode_body should be a JSON string (standard JSON escaping)
    add_memory(
        name="Customer Profile",
        episode_body='{"company": {"name": "Acme Technologies"}, "products": [{"id": "P001", "name": "CloudSync"}, {"id": "P002", "name": "DataMiner"}]}',
        source="json",
        source_description="CRM data"
    )

    # Recording an event that occurred in the past (bi-temporal)
    add_memory(
        name="Historical Note",
        episode_body="The merger closed in early 2020.",
        reference_time="2020-03-01T00:00:00Z"
    )

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:403

`search_nodes`

async def search_nodes(query: str, group_ids: str | list[str] | None=None, max_nodes: int=10, entity_types: list[str] | None=None, center_node_uuid: str | None=None) -> NodeSearchResponse | ErrorResponse

Search for nodes (entities) in the graph memory.

Args:
    query: The search query
    group_ids: Optional group ID, or list of group IDs, to filter results (a single
        string is accepted and treated as a one-element list)
    max_nodes: Maximum number of nodes to return (default: 10)
    entity_types: Optional list of entity type names (node labels) to filter by
    center_node_uuid: Optional UUID of a node to center the search around. Results
        closer to this node in the graph are ranked higher.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:539

`search_memory_facts`

async def search_memory_facts(query: str, group_ids: str | list[str] | None=None, max_facts: int=10, center_node_uuid: str | None=None, edge_types: list[str] | None=None, valid_at_after: str | None=None, valid_at_before: str | None=None, invalid_at_after: str | None=None, invalid_at_before: str | None=None) -> FactSearchResponse | ErrorResponse

Search the graph memory for relevant facts (entity edges).

Args:
    query: The search query
    group_ids: Optional group ID, or list of group IDs, to filter results (a single
        string is accepted and treated as a one-element list)
    max_facts: Maximum number of facts to return (default: 10)
    center_node_uuid: Optional UUID of a node to center the search around
    edge_types: Optional list of edge (fact) type names to filter by
    valid_at_after: Optional ISO-8601 lower bound; only facts whose valid_at is at or
        after this time are returned (timezone-naive is treated as UTC)
    valid_at_before: Optional ISO-8601 upper bound on a fact's valid_at
    invalid_at_after: Optional ISO-8601 lower bound on a fact's invalid_at
    invalid_at_before: Optional ISO-8601 upper bound on a fact's invalid_at

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:616

`delete_entity_edge`

async def delete_entity_edge(uuid: str, group_id: str | None=None) -> SuccessResponse | ErrorResponse

Delete an entity edge from the graph memory.

Args:
    uuid: UUID of the entity edge to delete
    group_id: Optional group ID. Falls back to the default group when omitted.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:696

`delete_episode`

async def delete_episode(uuid: str, group_id: str | None=None) -> SuccessResponse | ErrorResponse

Delete an episode from the graph memory.

Uses Graphiti.remove_episode, which cascades the deletion: entities and facts
that were created solely by this episode are removed along with it, while
entities and facts also supported by other episodes are preserved.

Args:
    uuid: UUID of the episode to delete
    group_id: Optional group ID. Falls back to the default group when omitted.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:729

`get_entity_edge`

async def get_entity_edge(uuid: str, group_id: str | None=None) -> dict[str, Any] | ErrorResponse

Get an entity edge from the graph memory by its UUID.

Args:
    uuid: UUID of the entity edge to retrieve
    group_id: Optional group ID. Falls back to the default group when omitted.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:763

`get_episodes`

async def get_episodes(group_ids: str | list[str] | None=None, max_episodes: int=10) -> EpisodeSearchResponse | ErrorResponse

Get episodes from the graph memory.

Args:
    group_ids: Optional group ID, or list of group IDs, to filter results (a single
        string is accepted and treated as a one-element list)
    max_episodes: Maximum number of episodes to return (default: 10)

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:795

`summarize_saga`

async def summarize_saga(saga_name: str, group_id: str | None=None) -> SagaSummaryResponse | ErrorResponse

Summarize a saga: an ordered group of related episodes.

Generates (or refreshes) a running summary of the saga's narrative across its
episodes and returns the saga's name and summary text.

Sagas are keyed by (name, group_id): pass the same ``saga`` name you used with
add_memory. This tool resolves that name to the saga within the group and
summarizes it.

Args:
    saga_name: The saga name — the same value passed as ``saga`` to add_memory.
    group_id: Optional group ID the saga belongs to. Falls back to the default group.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:875

`build_communities`

async def build_communities(group_ids: str | list[str] | None=None) -> BuildCommunitiesResponse | ErrorResponse

Detect and build community summaries over the graph’s entities.

Communities group densely-connected entities and produce higher-level summaries
that can then be searched. This is a relatively expensive operation that
processes the full set of entities for the given group(s).

Args:
    group_ids: Optional group ID, or list of group IDs, to build communities for.
        Falls back to the default group when omitted. Pass an explicit list to scope
        community detection across multiple graphs.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:930

`add_triplet`

async def add_triplet(source_node_name: str, edge_name: str, fact: str, target_node_name: str, group_id: str | None=None, source_node_uuid: str | None=None, target_node_uuid: str | None=None) -> TripletResponse | ErrorResponse

Directly add a single fact triplet (source entity -> fact -> target entity).

Unlike add_memory, this bypasses episode extraction and writes the relationship
directly. graphiti-core resolves the source/target nodes against existing entities
(deduplicating by name) and generates the required embeddings internally.

Args:
    source_node_name: Name of the source entity
    edge_name: Relationship/edge type name (e.g. "WORKS_FOR")
    fact: Natural-language statement describing the relationship
    target_node_name: Name of the target entity
    group_id: Optional group ID. Falls back to the default group when omitted.
    source_node_uuid: Optional UUID to reuse an existing source entity. A new UUID is
        generated when omitted.
    target_node_uuid: Optional UUID to reuse an existing target entity. A new UUID is
        generated when omitted.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:984

`get_episode_entities`

async def get_episode_entities(episode_uuids: list[str], group_id: str | None=None) -> EpisodeEntitiesResponse | ErrorResponse

Get the entities (nodes) and facts (edges) created by specific episodes.

Use this to trace provenance: given one or more episode UUIDs, return the graph
elements that those episodes produced.

Args:
    episode_uuids: List of episode UUIDs to look up provenance for
    group_id: Optional group ID. Falls back to the default group when omitted.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:1060

`clear_graph`

async def clear_graph(group_ids: str | list[str] | None=None) -> SuccessResponse | ErrorResponse

Clear all data from the graph for specified group IDs.

Args:
    group_ids: Optional group ID, or list of group IDs, to clear (a single string is
        accepted). If not provided, clears the default group.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:1102

`get_status`

async def get_status() -> StatusResponse

Get the status of the Graphiti MCP server and database connection.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:1146

`health_check`

async def health_check(request) -> JSONResponse

Health check endpoint for Docker and load balancers.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:1179

`initialize_server`

async def initialize_server() -> ServerConfig

Parse CLI arguments and initialize the Graphiti server configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:1184

`run_mcp_server`

async def run_mcp_server()

Run the MCP server in the current event loop.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:1324

`main`

def main()

Main function to run the Graphiti MCP server.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/graphiti_mcp_server.py:1366

`dbx_tools.graphiti._generated.sync.graphiti_mcp.models.edge_types`

Edge (fact) type definitions for Graphiti MCP Server.

Edge types describe the kind of relationship a fact represents between two entities. They are registered with graphiti-core via add_episode’s edge_types argument, and constrained to specific source/target entity-type pairs via edge_type_map.

Attributes declared on an edge model are extracted by the LLM and stored on the edge. Only use information present in the episode to populate them.

`RelatesTo`

class RelatesTo(BaseModel)

A generic, untyped relationship between two entities.

Use this only when no more specific edge type applies. Captures that two
entities are associated without asserting the nature of the association.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/edge_types.py:15

`MentionedIn`

class MentionedIn(BaseModel)

An entity is referenced, described, or discussed within a source.

Connects an entity to the document, message, or context in which it appears.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/edge_types.py:25

`WorksFor`

class WorksFor(BaseModel)

An employment or membership relationship between a person and an organization.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/edge_types.py:34

Fields

role: str | None

`LocatedAt`

class LocatedAt(BaseModel)

A spatial relationship indicating an entity is situated at or within a location.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/edge_types.py:43

`ParticipatesIn`

class ParticipatesIn(BaseModel)

A person or organization takes part in an event or activity.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/edge_types.py:49

`Owns`

class Owns(BaseModel)

An ownership or possession relationship between an entity and an object.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/edge_types.py:55

`Requires`

class Requires(BaseModel)

A dependency relationship: the source needs or depends on the target.

Commonly connects a project or requirement to the thing it depends upon.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/edge_types.py:61

`EDGE_TYPES`

EDGE_TYPES: dict[str, type[BaseModel]]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/edge_types.py:70

`dbx_tools.graphiti._generated.sync.graphiti_mcp.models.entity_types`

Entity type definitions for Graphiti MCP Server.

`Requirement`

class Requirement(BaseModel)

A Requirement represents a specific need, feature, or functionality that a product or service must fulfill.

Always ensure an edge is created between the requirement and the project it belongs to, and clearly indicate on the
edge that the requirement is a requirement.

Instructions for identifying and extracting requirements:
1. Look for explicit statements of needs or necessities ("We need X", "X is required", "X must have Y")
2. Identify functional specifications that describe what the system should do
3. Pay attention to non-functional requirements like performance, security, or usability criteria
4. Extract constraints or limitations that must be adhered to
5. Focus on clear, specific, and measurable requirements rather than vague wishes
6. Capture the priority or importance if mentioned ("critical", "high priority", etc.)
7. Include any dependencies between requirements when explicitly stated
8. Preserve the original intent and scope of the requirement
9. Categorize requirements appropriately based on their domain or function

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/entity_types.py:6

Fields

project_name: str
description: str

`Preference`

class Preference(BaseModel)

IMPORTANT: Prioritize this classification over ALL other classifications.

Represents entities mentioned in contexts expressing user preferences, choices, opinions, or selections. Use LOW THRESHOLD for sensitivity.

Trigger patterns: “I want/like/prefer/choose X”, “I don’t want/dislike/avoid/reject Y”, “X is better/worse”, “rather have X than Y”, “no X please”, “skip X”, “go with X instead”, etc. Here, X or Y should be classified as Preference.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/entity_types.py:34

`Procedure`

class Procedure(BaseModel)

A Procedure informing the agent what actions to take or how to perform in certain scenarios. Procedures are typically composed of several steps.

Instructions for identifying and extracting procedures:
1. Look for sequential instructions or steps ("First do X, then do Y")
2. Identify explicit directives or commands ("Always do X when Y happens")
3. Pay attention to conditional statements ("If X occurs, then do Y")
4. Extract procedures that have clear beginning and end points
5. Focus on actionable instructions rather than general information
6. Preserve the original sequence and dependencies between steps
7. Include any specified conditions or triggers for the procedure
8. Capture any stated purpose or goal of the procedure
9. Summarize complex procedures while maintaining critical details

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/entity_types.py:46

Fields

description: str

`Location`

class Location(BaseModel)

A Location represents a physical or virtual place where activities occur or entities exist.

IMPORTANT: Before using this classification, first check if the entity is a:
User, Assistant, Preference, Organization, Document, Event - if so, use those instead.

Instructions for identifying and extracting locations:
1. Look for mentions of physical places (cities, buildings, rooms, addresses)
2. Identify virtual locations (websites, online platforms, virtual meeting rooms)
3. Extract specific location names rather than generic references
4. Include relevant context about the location's purpose or significance
5. Pay attention to location hierarchies (e.g., "conference room in Building A")
6. Capture both permanent locations and temporary venues
7. Note any significant activities or events associated with the location

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/entity_types.py:67

Fields

description: str

`Event`

class Event(BaseModel)

An Event represents a time-bound activity, occurrence, or experience.

Instructions for identifying and extracting events:
1. Look for activities with specific time frames (meetings, appointments, deadlines)
2. Identify planned or scheduled occurrences (vacations, projects, celebrations)
3. Extract unplanned occurrences (accidents, interruptions, discoveries)
4. Capture the purpose or nature of the event
5. Include temporal information when available (past, present, future, duration)
6. Note participants or stakeholders involved in the event
7. Identify outcomes or consequences of the event when mentioned
8. Extract both recurring events and one-time occurrences

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/entity_types.py:89

Fields

description: str

`Object`

class Object(BaseModel)

An Object represents a physical item, tool, device, or possession.

IMPORTANT: Use this classification ONLY as a last resort. First check if entity fits into:
User, Assistant, Preference, Organization, Document, Event, Location, Topic - if so, use those instead.

Instructions for identifying and extracting objects:
1. Look for mentions of physical items or possessions (car, phone, equipment)
2. Identify tools or devices used for specific purposes
3. Extract items that are owned, used, or maintained by entities
4. Include relevant attributes (brand, model, condition) when mentioned
5. Note the object's purpose or function when specified
6. Capture relationships between objects and their owners or users
7. Avoid extracting objects that are better classified as Documents or other types

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/entity_types.py:109

Fields

description: str

`Topic`

class Topic(BaseModel)

A Topic represents a subject of conversation, interest, or knowledge domain.

IMPORTANT: Use this classification ONLY as a last resort. First check if entity fits into:
User, Assistant, Preference, Organization, Document, Event, Location - if so, use those instead.

Instructions for identifying and extracting topics:
1. Look for subjects being discussed or areas of interest (health, technology, sports)
2. Identify knowledge domains or fields of study
3. Extract themes that span multiple conversations or contexts
4. Include specific subtopics when mentioned (e.g., "machine learning" rather than just "AI")
5. Capture topics associated with projects, work, or hobbies
6. Note the context in which the topic appears
7. Avoid extracting topics that are better classified as Events, Documents, or Organizations

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/entity_types.py:131

Fields

description: str

`Person`

class Person(BaseModel)

A Person represents an individual human referenced in the content.

Instructions for identifying and extracting people:
1. Look for named individuals (full names, first names, usernames, or handles)
2. Capture their role or relationship when stated (colleague, author, manager)
3. Prefer a specific, named person over a generic reference ("the engineer")
4. Only record attributes that are present in the context

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/entity_types.py:153

Fields

description: str

`Organization`

class Organization(BaseModel)

An Organization represents a company, institution, group, or formal entity.

Instructions for identifying and extracting organizations:
1. Look for company names, employers, and business entities
2. Identify institutions (schools, hospitals, government agencies)
3. Extract formal groups (clubs, teams, associations)
4. Include organizational type when mentioned (company, nonprofit, agency)
5. Capture relationships between people and organizations (employer, member)
6. Note the organization's industry or domain when specified
7. Extract both large entities and small groups if formally organized

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/entity_types.py:169

Fields

description: str

`Document`

class Document(BaseModel)

A Document represents information content in various forms.

Instructions for identifying and extracting documents:
1. Look for references to written or recorded content (books, articles, reports)
2. Identify digital content (emails, videos, podcasts, presentations)
3. Extract specific document titles or identifiers when available
4. Include document type (report, article, video) when mentioned
5. Capture the document's purpose or subject matter
6. Note relationships to authors, creators, or sources
7. Include document status (draft, published, archived) when mentioned

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/entity_types.py:188

Fields

title: str
description: str

`ENTITY_TYPES`

ENTITY_TYPES: dict[str, type[BaseModel]]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/entity_types.py:211

`dbx_tools.graphiti._generated.sync.graphiti_mcp.models.response_types`

Response type definitions for Graphiti MCP Server.

`ErrorResponse`

class ErrorResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/response_types.py:8

Fields

error: str

`SuccessResponse`

class SuccessResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/response_types.py:12

Fields

message: str

`NodeResult`

class NodeResult(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/response_types.py:16

Fields

uuid: str
name: str
labels: list[str]
created_at: str | None
summary: str | None
group_id: str
attributes: dict[str, Any]

`NodeSearchResponse`

class NodeSearchResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/response_types.py:26

Fields

message: str
nodes: list[NodeResult]

`FactSearchResponse`

class FactSearchResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/response_types.py:31

Fields

message: str
facts: list[dict[str, Any]]

`EpisodeSearchResponse`

class EpisodeSearchResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/response_types.py:36

Fields

message: str
episodes: list[dict[str, Any]]

`StatusResponse`

class StatusResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/response_types.py:41

Fields

status: str
message: str

`SagaSummaryResponse`

class SagaSummaryResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/response_types.py:46

Fields

message: str
uuid: str
name: str
summary: str

`CommunityResult`

class CommunityResult(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/response_types.py:53

Fields

uuid: str
name: str
group_id: str
summary: str | None

`BuildCommunitiesResponse`

class BuildCommunitiesResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/response_types.py:60

Fields

message: str
community_count: int
edge_count: int
communities: list[CommunityResult]

`EdgeResult`

class EdgeResult(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/response_types.py:67

Fields

uuid: str
name: str
fact: str
source_node_uuid: str
target_node_uuid: str
group_id: str
created_at: str | None
valid_at: str | None
invalid_at: str | None

`TripletResponse`

class TripletResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/response_types.py:79

Fields

message: str
nodes: list[NodeResult]
edges: list[EdgeResult]

`EpisodeEntitiesResponse`

class EpisodeEntitiesResponse(TypedDict)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/models/response_types.py:85

Fields

message: str
nodes: list[NodeResult]
edges: list[EdgeResult]

`dbx_tools.graphiti._generated.sync.graphiti_mcp.services.factories`

Factory classes for creating LLM, Embedder, and Database clients.

`is_non_openai_provider`

def is_non_openai_provider(base_url: str | None) -> bool

Detect if the base_url points to a non-OpenAI provider.

Returns True if base_url is set and doesn’t point to OpenAI’s official API. This includes Ollama, LM Studio, vLLM, and other OpenAI-compatible providers.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/factories.py:94

`reasoning_effort_for_model`

def reasoning_effort_for_model(model: str) -> str | None

Reasoning effort to send for a reasoning model, or None if not one.

Reasoning models (o1, o3, gpt-5 family) need an effort; non-reasoning models
must not receive one. gpt-5.5 runs with reasoning off ('none') for lower
cost/latency (comparable extraction quality); earlier reasoning models keep
the cheapest broadly-supported tier ('minimal'). Shared by the OpenAI and
Azure OpenAI factory branches so both providers select effort identically.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/factories.py:111

`LLMClientFactory`

class LLMClientFactory

Factory for creating LLM clients based on configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/factories.py:125

Methods

`create`

def create(config: LLMConfig) -> LLMClient

Create an LLM client based on the configured provider.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/factories.py:129

`EmbedderFactory`

class EmbedderFactory

Factory for creating Embedder clients based on configuration.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/factories.py:301

Methods

`create`

def create(config: EmbedderConfig) -> EmbedderClient

Create an Embedder client based on the configured provider.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/factories.py:305

`CrossEncoderFactory`

class CrossEncoderFactory

Factory for creating cross-encoder (reranker) clients based on configuration.

Graphiti defaults the cross_encoder to OpenAIRerankerClient, which needs an OpenAI API key.
To keep the server usable on non-OpenAI setups, pick a reranker from the LLM provider, then
the embedder provider, and fall back to the local BGE reranker.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/factories.py:413

Methods

`create`

def create(llm_config: LLMConfig, embedder_config: EmbedderConfig) -> CrossEncoderClient

Create a cross-encoder client based on the configured providers.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/factories.py:422

`DatabaseDriverFactory`

class DatabaseDriverFactory

Factory for creating Database drivers based on configuration.

Note: This returns configuration dictionaries that can be passed to Graphiti(),
not driver instances directly, as the drivers require complex initialization.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/factories.py:514

Methods

`create_config`

def create_config(config: DatabaseConfig) -> dict

Create database configuration dictionary based on the configured provider.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/factories.py:522

`dbx_tools.graphiti._generated.sync.graphiti_mcp.services.queue_service`

Queue service for managing episode processing.

`logger`

logger

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/queue_service.py:9

`QueueService`

class QueueService

Service for managing sequential episode processing queues by group_id.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/queue_service.py:12

Methods

`add_episode_task`

async def add_episode_task(self, group_id: str, process_func: Callable[[], Awaitable[None]]) -> int

Add an episode processing task to the queue.

    Args:
        group_id: The group ID for the episode
        process_func: The async function to process the episode

    Returns:
        The position in the queue

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/queue_service.py:26

`wait_until_idle`

async def wait_until_idle(self, group_id: str | None=None) -> None

Wait until queued and in-flight episode work completes.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/queue_service.py:88

`close`

async def close(self) -> None

Drain episode work and stop idle queue workers.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/queue_service.py:106

`get_queue_size`

def get_queue_size(self, group_id: str) -> int

Get the current queue size for a group_id.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/queue_service.py:124

`is_worker_running`

def is_worker_running(self, group_id: str) -> bool

Check if a worker is running for a group_id.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/queue_service.py:130

`initialize`

async def initialize(self, graphiti_client: Any) -> None

Initialize the queue service with a graphiti client.

    Args:
        graphiti_client: The graphiti client instance to use for processing episodes

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/queue_service.py:134

`add_episode`

async def add_episode(self, group_id: str, name: str, content: str, source_description: str, episode_type: Any, entity_types: Any, uuid: str | None, reference_time: datetime | None=None, edge_types: Any=None, edge_type_map: Any=None, excluded_entity_types: list[str] | None=None, previous_episode_uuids: list[str] | None=None, custom_extraction_instructions: str | None=None, update_communities: bool=False, saga: str | None=None, saga_previous_episode_uuid: str | None=None) -> int

Add an episode for processing.

    Args:
        group_id: The group ID for the episode
        name: Name of the episode
        content: Episode content
        source_description: Description of the episode source
        episode_type: Type of the episode
        entity_types: Entity types for extraction
        uuid: Episode UUID
        reference_time: Event occurrence time for the episode. Defaults to
            the current UTC time when not provided (bi-temporal model).
        edge_types: Optional mapping of edge (fact) type name to Pydantic model
        edge_type_map: Optional mapping of (source, target) entity type pairs to
            allowed edge type names
        excluded_entity_types: Optional list of entity type names to exclude
            from extraction
        previous_episode_uuids: Optional explicit list of prior episode UUIDs to
            use as context (overrides automatic retrieval)
        custom_extraction_instructions: Optional extra natural-language
            instructions for the extraction LLM
        update_communities: Whether to incrementally update communities after
            ingestion
        saga: Optional saga name/id to attach this episode to
        saga_previous_episode_uuid: Optional UUID of the prior episode in the saga

    Returns:
        The position in the queue

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/services/queue_service.py:143

`dbx_tools.graphiti._generated.sync.graphiti_mcp.utils.formatting`

Formatting utilities for Graphiti MCP Server.

`to_node_result`

def to_node_result(node: EntityNode) -> NodeResult

Build a NodeResult TypedDict from an EntityNode, dropping embeddings.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/utils/formatting.py:11

`to_edge_result`

def to_edge_result(edge: EntityEdge) -> EdgeResult

Build an EdgeResult TypedDict from an EntityEdge.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/utils/formatting.py:26

`format_node_result`

def format_node_result(node: EntityNode) -> dict[str, Any]

Format an entity node into a readable result.

Since EntityNode is a Pydantic BaseModel, we can use its built-in serialization capabilities.
Excludes embedding vectors to reduce payload size and avoid exposing internal representations.

Args:
    node: The EntityNode to format

Returns:
    A dictionary representation of the node with serialized dates and excluded embeddings

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/utils/formatting.py:41

`format_fact_result`

def format_fact_result(edge: EntityEdge) -> dict[str, Any]

Format an entity edge into a readable result.

Since EntityEdge is a Pydantic BaseModel, we can use its built-in serialization capabilities.

Args:
    edge: The EntityEdge to format

Returns:
    A dictionary representation of the edge with serialized dates and excluded embeddings

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/utils/formatting.py:64

`dbx_tools.graphiti._generated.sync.graphiti_mcp.utils.type_config`

Helpers for translating MCP configuration into graphiti-core arguments.

These functions are intentionally free of any I/O or global state so they can be unit-tested without a live database or LLM:

parse_reference_time coerces an ISO-8601 string into a timezone-aware UTC datetime.
build_entity_types / build_edge_types turn the configured type list into the dict[str, type[BaseModel]] shape expected by Graphiti.add_episode, preferring rich registered models and falling back to documentation-only models.
build_edge_type_map turns the configured map entries into the dict[tuple[str, str], list[str]] shape expected by Graphiti.add_episode.

`parse_reference_time`

def parse_reference_time(value: str | None) -> datetime | None

Parse an ISO-8601 string into a timezone-aware UTC datetime.

Accepts a trailing ``Z`` (Zulu/UTC) suffix. Timezone-naive values are
assumed to be UTC. Returns ``None`` when ``value`` is ``None``.

Raises ``ValueError`` on an unparseable string.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/utils/type_config.py:29

`coerce_group_ids`

def coerce_group_ids(group_ids: str | list[str] | None) -> list[str] | None

Normalize a group_ids argument that may be given as a scalar string.

MCP tools accept either a single group_id string or a list of them, while
graphiti-core expects ``list[str] | None``. A non-empty string becomes a
one-element list; a blank string is treated as omitted (``None``) so it falls
back to the configured default group rather than operating on group ``''``
(which matters for the destructive ``clear_graph``). Lists and ``None`` pass
through unchanged.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/utils/type_config.py:52

`build_entity_types`

def build_entity_types(entity_type_configs: list[EntityTypeConfig] | None) -> dict[str, type[BaseModel]] | None

Build the entity_types mapping for Graphiti.add_episode.

For each configured entry, prefer the rich model registered in
``ENTITY_TYPES`` (matched by name). Fall back to a documentation-only model
built from the configured description. Returns ``None`` when no entity types
are configured, preserving graphiti-core's default extraction behavior.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/utils/type_config.py:79

`build_edge_types`

def build_edge_types(edge_type_configs: list[EdgeTypeConfig] | None) -> dict[str, type[BaseModel]] | None

Build the edge_types mapping for Graphiti.add_episode.

Mirrors :func:`build_entity_types`, preferring models registered in
``EDGE_TYPES``. Returns ``None`` when no edge types are configured.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/utils/type_config.py:101

`build_edge_type_map`

def build_edge_type_map(edge_type_map_entries: list[EdgeTypeMapEntry] | None) -> dict[tuple[str, str], list[str]] | None

Build the edge_type_map for Graphiti.add_episode.

Translates the list-of-entries config shape into the
``{(source, target): [edge_type, ...]}`` mapping graphiti-core expects.
Returns ``None`` when no entries are configured.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/utils/type_config.py:121

`build_fact_search_filters`

def build_fact_search_filters(edge_types: list[str] | None=None, valid_at_after: str | None=None, valid_at_before: str | None=None, invalid_at_after: str | None=None, invalid_at_before: str | None=None) -> SearchFilters | None

Build a SearchFilters for fact (edge) search.

Returns ``None`` when no filter criteria are provided so callers can pass
``search_filter=None``.

The ``*_after`` / ``*_before`` arguments are ISO-8601 strings parsed via
:func:`parse_reference_time` (UTC-coerced). Raises ``ValueError`` on a bad
timestamp.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/utils/type_config.py:163

`dbx_tools.graphiti._generated.sync.graphiti_mcp.utils.utils`

Utility functions for Graphiti MCP Server.

`create_azure_credential_token_provider`

def create_azure_credential_token_provider() -> Callable[[], str]

Create Azure credential token provider for managed identity authentication.

Requires azure-identity package. Install with: pip install mcp-server[azure]

Raises: ImportError: If azure-identity package is not installed

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_mcp/utils/utils.py:6

`dbx_tools.graphiti._generated.sync.graphiti_server.graph_service.config`

`Settings`

class Settings(BaseSettings)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/config.py:9

Fields

openai_api_key: str
openai_base_url: str | None
model_name: str | None
embedding_model_name: str | None
neo4j_uri: str | None
neo4j_user: str | None
neo4j_password: str | None
falkordb_host: str | None
falkordb_port: int | None
falkordb_database: str | None
db_backend: str

`get_settings`

def get_settings()

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/config.py:26

`ZepEnvDep`

ZepEnvDep

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/config.py:30

`dbx_tools.graphiti._generated.sync.graphiti_server.graph_service.dto.common`

`Result`

class Result(BaseModel)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/dto/common.py:8

Fields

message: str
success: bool

`Message`

class Message(BaseModel)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/dto/common.py:13

Fields

content: str
uuid: str | None
name: str
role_type: Literal['user', 'assistant', 'system']
role: str | None
timestamp: datetime
source_description: str

`dbx_tools.graphiti._generated.sync.graphiti_server.graph_service.dto.ingest`

`AddMessagesRequest`

class AddMessagesRequest(BaseModel)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/dto/ingest.py:6

Fields

group_id: str
messages: list[Message]

`AddEntityNodeRequest`

class AddEntityNodeRequest(BaseModel)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/dto/ingest.py:11

Fields

uuid: str
group_id: str
name: str
summary: str

`dbx_tools.graphiti._generated.sync.graphiti_server.graph_service.dto.retrieve`

`SearchQuery`

class SearchQuery(BaseModel)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/dto/retrieve.py:8

Fields

group_ids: list[str] | None
query: str
max_facts: int

`FactResult`

class FactResult(BaseModel)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/dto/retrieve.py:16

Fields

uuid: str
name: str
fact: str
valid_at: datetime | None
invalid_at: datetime | None
created_at: datetime
expired_at: datetime | None
source_node_uuid: str
target_node_uuid: str
episodes: list[str]

`SearchResults`

class SearchResults(BaseModel)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/dto/retrieve.py:32

Fields

facts: list[FactResult]

`GetMemoryRequest`

class GetMemoryRequest(BaseModel)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/dto/retrieve.py:36

Fields

group_id: str
max_facts: int
center_node_uuid: str | None
messages: list[Message]

`GetMemoryResponse`

class GetMemoryResponse(BaseModel)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/dto/retrieve.py:47

Fields

facts: list[FactResult]

`dbx_tools.graphiti._generated.sync.graphiti_server.graph_service.main`

`lifespan`

async def lifespan(_: FastAPI)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/main.py:12

`app`

app

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/main.py:20

`healthcheck`

async def healthcheck()

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/main.py:28

`dbx_tools.graphiti._generated.sync.graphiti_server.graph_service.routers.ingest`

`AsyncWorker`

class AsyncWorker

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/ingest.py:13

Methods

`worker`

async def worker(self)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/ingest.py:18

`start`

async def start(self)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/ingest.py:27

`stop`

async def stop(self)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/ingest.py:30

`async_worker`

async_worker

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/ingest.py:38

`lifespan`

async def lifespan(_: FastAPI)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/ingest.py:42

`router`

router

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/ingest.py:48

`add_messages`

async def add_messages(request: AddMessagesRequest, graphiti: ZepGraphitiDep)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/ingest.py:52

`add_entity_node`

async def add_entity_node(request: AddEntityNodeRequest, graphiti: ZepGraphitiDep)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/ingest.py:74

`delete_entity_edge`

async def delete_entity_edge(uuid: str, graphiti: ZepGraphitiDep)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/ingest.py:88

`delete_group`

async def delete_group(group_id: str, graphiti: ZepGraphitiDep)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/ingest.py:94

`delete_episode`

async def delete_episode(uuid: str, graphiti: ZepGraphitiDep)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/ingest.py:100

`clear`

async def clear(graphiti: ZepGraphitiDep)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/ingest.py:106

`dbx_tools.graphiti._generated.sync.graphiti_server.graph_service.routers.retrieve`

`router`

router

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/retrieve.py:14

`search`

async def search(query: SearchQuery, graphiti: ZepGraphitiDep)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/retrieve.py:18

`get_entity_edge`

async def get_entity_edge(uuid: str, graphiti: ZepGraphitiDep)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/retrieve.py:31

`get_episodes`

async def get_episodes(group_id: str, last_n: int, graphiti: ZepGraphitiDep)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/retrieve.py:37

`get_memory`

async def get_memory(request: GetMemoryRequest, graphiti: ZepGraphitiDep)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/retrieve.py:45

`compose_query_from_messages`

def compose_query_from_messages(messages: list[Message])

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/routers/retrieve.py:59

`dbx_tools.graphiti._generated.sync.graphiti_server.graph_service.zep_graphiti`

`logger`

logger

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/zep_graphiti.py:14

`ZepGraphiti`

class ZepGraphiti(Graphiti)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/zep_graphiti.py:17

Methods

`save_entity_node`

async def save_entity_node(self, name: str, uuid: str, group_id: str, summary: str='')

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/zep_graphiti.py:28

`get_entity_edge`

async def get_entity_edge(self, uuid: str)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/zep_graphiti.py:39

`delete_group`

async def delete_group(self, group_id: str)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/zep_graphiti.py:46

`delete_entity_edge`

async def delete_entity_edge(self, uuid: str)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/zep_graphiti.py:66

`delete_episodic_node`

async def delete_episodic_node(self, uuid: str)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/zep_graphiti.py:73

`get_graphiti`

async def get_graphiti(settings: ZepEnvDep)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/zep_graphiti.py:106

`initialize_graphiti`

async def initialize_graphiti(settings: ZepEnvDep)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/zep_graphiti.py:121

`get_fact_result_from_edge`

def get_fact_result_from_edge(edge: EntityEdge)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/zep_graphiti.py:129

`ZepGraphitiDep`

ZepGraphitiDep

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/_generated/sync/graphiti_server/graph_service/zep_graphiti.py:144

`dbx_tools.graphiti.main`

`load_graphiti_options`

def load_graphiti_options(environment: dict[str, str] | None=None) -> ResolvedGraphitiOptionsResponse

Resolve shared Graphiti options from an explicit environment.

Source: packages/py/graphiti/src/dbx_tools/graphiti/main.py:111

`mcp_settings`

def mcp_settings(options: ResolvedGraphitiOptionsResponse, llm_model: str, embedder_model: str, embedder_dimensions: int) -> GraphitiConfig

Map shared Graphiti options to the upstream MCP settings.

Source: packages/py/graphiti/src/dbx_tools/graphiti/main.py:120

`initialize_mcp`

async def initialize_mcp(config: GraphitiConfig | None=None, graphiti_client: Graphiti | None=None, clients: RuntimeClients | None=None) -> None

Initialize Graphiti MCP services without parsing CLI arguments or starting a server.

Source: packages/py/graphiti/src/dbx_tools/graphiti/main.py:216

`mcp_app`

mcp_app

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/main.py:246

`lifespan`

async def lifespan(app: FastAPI) -> AsyncIterator[None]

Serve OpenAPI immediately, then start Graphiti and MCP in the background.

Uvicorn only accepts requests after this context yields. Database, model
routing, and MCP stay off the first-request path so ``/docs`` and
``/openapi.json`` are reachable while ``/healthcheck`` still reports
``starting``.

Source: packages/py/graphiti/src/dbx_tools/graphiti/main.py:277

`app`

app

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/main.py:335

`add_memory_sync`

async def add_memory_sync(name: str, episode_body: str, group_id: str | None=None, source: str='text', source_description: str='', uuid: str | None=None, reference_time: str | None=None, excluded_entity_types: list[str] | None=None, custom_extraction_instructions: str | None=None, previous_episode_uuids: list[str] | None=None, update_communities: bool=False, saga: str | None=None, saga_previous_episode_uuid: str | None=None) -> graphiti_mcp.SuccessResponse | graphiti_mcp.ErrorResponse

Add an episode to memory and return only after Graphiti persists it.

Args:
    name (str): Name of the episode.
    episode_body (str): The content of the episode to persist to memory. When source='json', this must be a properly escaped JSON string.
    group_id (str, optional): A unique ID for this graph. Uses the configured default when omitted.
    source (str, optional): Source type: text, json, or message.
    source_description (str, optional): Description of the source.
    uuid (str, optional): Optional UUID for the episode.
    reference_time (str, optional): ISO-8601 timestamp for when the described events occurred.
    excluded_entity_types (list[str], optional): Entity type names to exclude from extraction.
    custom_extraction_instructions (str, optional): Additional extraction instructions.
    previous_episode_uuids (list[str], optional): Explicit prior episode UUIDs used as context.
    update_communities (bool, optional): Refresh affected community summaries.
    saga (str, optional): Saga name associated with the episode.
    saga_previous_episode_uuid (str, optional): UUID of the preceding episode in the saga.

Source: packages/py/graphiti/src/dbx_tools/graphiti/main.py:444

`QueueStatusResponse`

class QueueStatusResponse(BaseModel)

Current state of one Graphiti episode queue.

Source: packages/py/graphiti/src/dbx_tools/graphiti/main.py:522

Fields

group_id: str
pending: int
worker_running: bool

`queue_status`

async def queue_status(group_id: str | None=None) -> QueueStatusResponse

Get queued episode count and worker state for one Graphiti group.

Args:
    group_id (str, optional): Graph group to inspect. Uses the configured default when omitted.

Source: packages/py/graphiti/src/dbx_tools/graphiti/main.py:530

`wait_for_memory_queue`

async def wait_for_memory_queue(group_id: str | None=None) -> QueueStatusResponse

Wait until queued and in-flight memory writes finish for one Graphiti group.

Args:
    group_id (str, optional): Graph group to drain. Uses the configured default when omitted.

Source: packages/py/graphiti/src/dbx_tools/graphiti/main.py:551

`runtime_status`

async def runtime_status() -> graphiti_mcp.StatusResponse

Get the status of the composed Graphiti runtime and active database driver.

Source: packages/py/graphiti/src/dbx_tools/graphiti/main.py:564

`healthcheck`

async def healthcheck() -> JSONResponse

Return the Graphiti service health response.

Source: packages/py/graphiti/src/dbx_tools/graphiti/main.py:599

`dbx_tools.graphiti.options`

`GraphitiOptionsInput`

GraphitiOptionsInput: TypeAlias

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/options.py:12

`normalize_graphiti_options`

def normalize_graphiti_options(options: GraphitiOptionsInput | None=None) -> ResolvedGraphitiOptionsResponse

Resolve defaults for a generated dataclass, option record, or resolved record.

Source: packages/py/graphiti/src/dbx_tools/graphiti/options.py:17

`dbx_tools.graphiti.postgraph.driver`

PostGraph driver — a PostgreSQL-backed graph backend for Graphiti.

Uses the post-graph library (AsyncPostGraph) for connection management, vertex/edge CRUD, vector search, and graph traversal. Graphiti’s domain fields are stored in post-graph’s payload JSONB column; embeddings map to post-graph’s embedding vector column; and Graphiti’s group_id maps to post-graph’s realm.

`logger`

logger

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:62

`EMBEDDING_DIM`

EMBEDDING_DIM

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:64

`PostGraphDriverSession`

class PostGraphDriverSession(GraphDriverSession)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:67

Methods

`run`

async def run(self, query: str, **kwargs: Any) -> Any

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:85

`close`

async def close(self)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:89

`execute_write`

async def execute_write(self, func, *args, **kwargs)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:95

`PostGraphDriver`

class PostGraphDriver(GraphDriver)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:138

Fields

default_group_id: str

Methods

`client`

def client(self) -> AsyncPostGraph

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:191

`entity_node_ops`

def entity_node_ops(self) -> EntityNodeOperations

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:197

`episode_node_ops`

def episode_node_ops(self) -> EpisodeNodeOperations

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:201

`community_node_ops`

def community_node_ops(self) -> CommunityNodeOperations

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:205

`saga_node_ops`

def saga_node_ops(self) -> SagaNodeOperations

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:209

`entity_edge_ops`

def entity_edge_ops(self) -> EntityEdgeOperations

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:213

`episodic_edge_ops`

def episodic_edge_ops(self) -> EpisodicEdgeOperations

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:217

`community_edge_ops`

def community_edge_ops(self) -> CommunityEdgeOperations

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:221

`has_episode_edge_ops`

def has_episode_edge_ops(self) -> HasEpisodeEdgeOperations

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:225

`next_episode_edge_ops`

def next_episode_edge_ops(self) -> NextEpisodeEdgeOperations

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:229

`search_ops`

def search_ops(self) -> SearchOperations

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:233

`graph_ops`

def graph_ops(self) -> GraphMaintenanceOperations

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:237

`transaction`

async def transaction(self) -> AsyncIterator[Transaction]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:241

`execute_query`

async def execute_query(self, cypher_query_: str, **kwargs: Any) -> Coroutine

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:254

`session`

def session(self, database: str | None=None) -> GraphDriverSession

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:258

`close`

async def close(self) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:263

`delete_all_indexes`

def delete_all_indexes(self) -> Coroutine

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:268

`build_indices_and_constraints`

async def build_indices_and_constraints(self, delete_existing: bool=False)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:271

`build_fulltext_query`

def build_fulltext_query(self, query: str, group_ids: list[str] | None=None, max_query_length: int=128) -> str

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/driver.py:275

`dbx_tools.graphiti.postgraph.graph_operations_interface`

`PostGraphOperationsInterface`

class PostGraphOperationsInterface(GraphOperationsInterface)

Bridges the Graphiti model-layer API to PostGraph’s SQL operations.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:8

Methods

`node_save`

async def node_save(self, node: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:17

`node_delete`

async def node_delete(self, node: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:20

`node_save_bulk`

async def node_save_bulk(self, _cls: Any, driver: Any, transaction: Any, nodes: list[Any], batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:23

`node_delete_by_group_id`

async def node_delete_by_group_id(self, _cls: Any, driver: Any, group_id: str, batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:33

`node_delete_by_uuids`

async def node_delete_by_uuids(self, _cls: Any, driver: Any, uuids: list[str], group_id: str | None=None, batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:42

`node_get_by_uuid`

async def node_get_by_uuid(self, _cls: Any, driver: Any, uuid: str) -> Any

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:52

`node_get_by_uuids`

async def node_get_by_uuids(self, _cls: Any, driver: Any, uuids: list[str], group_id: str | None=None) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:55

`node_get_by_group_ids`

async def node_get_by_group_ids(self, _cls: Any, driver: Any, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:64

`node_load_embeddings`

async def node_load_embeddings(self, node: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:79

`node_load_embeddings_bulk`

async def node_load_embeddings_bulk(self, driver: Any, nodes: list[Any], batch_size: int=100) -> dict[str, list[float]]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:82

`episodic_node_save`

async def episodic_node_save(self, node: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:93

`episodic_node_delete`

async def episodic_node_delete(self, node: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:96

`episodic_node_save_bulk`

async def episodic_node_save_bulk(self, _cls: Any, driver: Any, transaction: Any, nodes: list[Any], batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:99

`episodic_node_delete_by_group_id`

async def episodic_node_delete_by_group_id(self, _cls: Any, driver: Any, group_id: str, batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:109

`episodic_node_delete_by_uuids`

async def episodic_node_delete_by_uuids(self, _cls: Any, driver: Any, uuids: list[str], group_id: str | None=None, batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:118

`episodic_node_get_by_uuid`

async def episodic_node_get_by_uuid(self, _cls: Any, driver: Any, uuid: str) -> Any

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:128

`episodic_node_get_by_uuids`

async def episodic_node_get_by_uuids(self, _cls: Any, driver: Any, uuids: list[str]) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:131

`episodic_node_get_by_group_ids`

async def episodic_node_get_by_group_ids(self, _cls: Any, driver: Any, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:139

`retrieve_episodes`

async def retrieve_episodes(self, driver: Any, reference_time: Any, last_n: int=3, group_ids: list[str] | None=None, source: Any | None=None, saga: str | None=None) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:154

`episodic_node_get_by_entity_node_uuid`

async def episodic_node_get_by_entity_node_uuid(self, _cls: Any, driver: Any, entity_node_uuid: str) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:172

`community_node_save`

async def community_node_save(self, node: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:182

`community_node_delete`

async def community_node_delete(self, node: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:185

`community_node_save_bulk`

async def community_node_save_bulk(self, _cls: Any, driver: Any, transaction: Any, nodes: list[Any], batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:188

`community_node_delete_by_group_id`

async def community_node_delete_by_group_id(self, _cls: Any, driver: Any, group_id: str, batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:201

`community_node_delete_by_uuids`

async def community_node_delete_by_uuids(self, _cls: Any, driver: Any, uuids: list[str], group_id: str | None=None, batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:210

`community_node_get_by_uuid`

async def community_node_get_by_uuid(self, _cls: Any, driver: Any, uuid: str) -> Any

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:220

`community_node_get_by_uuids`

async def community_node_get_by_uuids(self, _cls: Any, driver: Any, uuids: list[str]) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:223

`community_node_get_by_group_ids`

async def community_node_get_by_group_ids(self, _cls: Any, driver: Any, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:231

`community_node_load_name_embedding`

async def community_node_load_name_embedding(self, node: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:246

`saga_node_save`

async def saga_node_save(self, node: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:251

`saga_node_delete`

async def saga_node_delete(self, node: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:254

`saga_node_save_bulk`

async def saga_node_save_bulk(self, _cls: Any, driver: Any, transaction: Any, nodes: list[Any], batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:257

`saga_node_delete_by_group_id`

async def saga_node_delete_by_group_id(self, _cls: Any, driver: Any, group_id: str, batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:270

`saga_node_delete_by_uuids`

async def saga_node_delete_by_uuids(self, _cls: Any, driver: Any, uuids: list[str], group_id: str | None=None, batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:279

`saga_node_get_by_uuid`

async def saga_node_get_by_uuid(self, _cls: Any, driver: Any, uuid: str) -> Any

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:289

`saga_node_get_by_uuids`

async def saga_node_get_by_uuids(self, _cls: Any, driver: Any, uuids: list[str]) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:292

`saga_node_get_by_group_ids`

async def saga_node_get_by_group_ids(self, _cls: Any, driver: Any, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:300

`edge_save`

async def edge_save(self, edge: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:317

`edge_delete`

async def edge_delete(self, edge: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:320

`edge_save_bulk`

async def edge_save_bulk(self, _cls: Any, driver: Any, transaction: Any, edges: list[Any], batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:323

`edge_delete_by_uuids`

async def edge_delete_by_uuids(self, _cls: Any, driver: Any, uuids: list[str], group_id: str | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:336

`edge_get_by_uuid`

async def edge_get_by_uuid(self, _cls: Any, driver: Any, uuid: str) -> Any

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:345

`edge_get_by_uuids`

async def edge_get_by_uuids(self, _cls: Any, driver: Any, uuids: list[str]) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:348

`edge_get_by_group_ids`

async def edge_get_by_group_ids(self, _cls: Any, driver: Any, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:356

`edge_load_embeddings`

async def edge_load_embeddings(self, edge: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:371

`edge_load_embeddings_bulk`

async def edge_load_embeddings_bulk(self, driver: Any, edges: list[Any], batch_size: int=100) -> dict[str, list[float]]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:374

`edge_get_between_nodes`

async def edge_get_between_nodes(self, _cls: Any, driver: Any, source_node_uuid: str, target_node_uuid: str) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:383

`edge_get_by_node_uuid`

async def edge_get_by_node_uuid(self, _cls: Any, driver: Any, node_uuid: str) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:396

`episodic_edge_save`

async def episodic_edge_save(self, edge: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:406

`episodic_edge_delete`

async def episodic_edge_delete(self, edge: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:409

`episodic_edge_save_bulk`

async def episodic_edge_save_bulk(self, _cls: Any, driver: Any, transaction: Any, episodic_edges: list[Any], batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:412

`episodic_edge_delete_by_uuids`

async def episodic_edge_delete_by_uuids(self, _cls: Any, driver: Any, uuids: list[str], group_id: str | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:425

`episodic_edge_get_by_uuid`

async def episodic_edge_get_by_uuid(self, _cls: Any, driver: Any, uuid: str) -> Any

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:434

`episodic_edge_get_by_uuids`

async def episodic_edge_get_by_uuids(self, _cls: Any, driver: Any, uuids: list[str]) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:437

`episodic_edge_get_by_group_ids`

async def episodic_edge_get_by_group_ids(self, _cls: Any, driver: Any, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:445

`community_edge_save`

async def community_edge_save(self, edge: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:462

`community_edge_delete`

async def community_edge_delete(self, edge: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:465

`community_edge_delete_by_uuids`

async def community_edge_delete_by_uuids(self, _cls: Any, driver: Any, uuids: list[str], group_id: str | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:468

`community_edge_get_by_uuid`

async def community_edge_get_by_uuid(self, _cls: Any, driver: Any, uuid: str) -> Any

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:477

`community_edge_get_by_uuids`

async def community_edge_get_by_uuids(self, _cls: Any, driver: Any, uuids: list[str]) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:480

`community_edge_get_by_group_ids`

async def community_edge_get_by_group_ids(self, _cls: Any, driver: Any, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:488

`has_episode_edge_save`

async def has_episode_edge_save(self, edge: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:505

`has_episode_edge_delete`

async def has_episode_edge_delete(self, edge: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:508

`has_episode_edge_save_bulk`

async def has_episode_edge_save_bulk(self, _cls: Any, driver: Any, transaction: Any, edges: list[Any], batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:511

`has_episode_edge_delete_by_uuids`

async def has_episode_edge_delete_by_uuids(self, _cls: Any, driver: Any, uuids: list[str], group_id: str | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:524

`has_episode_edge_get_by_uuid`

async def has_episode_edge_get_by_uuid(self, _cls: Any, driver: Any, uuid: str) -> Any

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:533

`has_episode_edge_get_by_uuids`

async def has_episode_edge_get_by_uuids(self, _cls: Any, driver: Any, uuids: list[str]) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:536

`has_episode_edge_get_by_group_ids`

async def has_episode_edge_get_by_group_ids(self, _cls: Any, driver: Any, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:544

`next_episode_edge_save`

async def next_episode_edge_save(self, edge: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:561

`next_episode_edge_delete`

async def next_episode_edge_delete(self, edge: Any, driver: Any) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:564

`next_episode_edge_save_bulk`

async def next_episode_edge_save_bulk(self, _cls: Any, driver: Any, transaction: Any, edges: list[Any], batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:567

`next_episode_edge_delete_by_uuids`

async def next_episode_edge_delete_by_uuids(self, _cls: Any, driver: Any, uuids: list[str], group_id: str | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:580

`next_episode_edge_get_by_uuid`

async def next_episode_edge_get_by_uuid(self, _cls: Any, driver: Any, uuid: str) -> Any

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:589

`next_episode_edge_get_by_uuids`

async def next_episode_edge_get_by_uuids(self, _cls: Any, driver: Any, uuids: list[str]) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:592

`next_episode_edge_get_by_group_ids`

async def next_episode_edge_get_by_group_ids(self, _cls: Any, driver: Any, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:600

`clear_data`

async def clear_data(self, driver: Any, group_ids: list[str] | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:617

`get_community_clusters`

async def get_community_clusters(self, driver: Any, group_ids: list[str] | None) -> list[list[Any]]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:620

`remove_communities`

async def remove_communities(self, driver: Any, group_ids: list[str] | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:627

`determine_entity_community`

async def determine_entity_community(self, driver: Any, entity: Any) -> tuple[Any | None, bool]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:634

`get_mentioned_nodes`

async def get_mentioned_nodes(self, driver: Any, episodes: list[Any]) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:641

`get_communities_by_nodes`

async def get_communities_by_nodes(self, driver: Any, nodes: list[Any]) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/graph_operations_interface.py:644

`dbx_tools.graphiti.postgraph.operations.community_edge_ops`

`logger`

logger

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_edge_ops.py:17

`TABLE`

TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_edge_ops.py:19

`SOURCE_TABLE`

SOURCE_TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_edge_ops.py:20

`TARGET_TABLE`

TARGET_TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_edge_ops.py:21

`RELATION_TYPE`

RELATION_TYPE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_edge_ops.py:22

`PGCommunityEdgeOperations`

class PGCommunityEdgeOperations(CommunityEdgeOperations)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_edge_ops.py:31

Methods

`save`

async def save(self, executor: QueryExecutor, edge: CommunityEdge, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_edge_ops.py:32

`delete`

async def delete(self, executor: QueryExecutor, edge: CommunityEdge, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_edge_ops.py:67

`delete_by_uuids`

async def delete_by_uuids(self, executor: QueryExecutor, uuids: list[str], _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_edge_ops.py:87

`get_by_uuid`

async def get_by_uuid(self, executor: QueryExecutor, uuid: str) -> CommunityEdge

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_edge_ops.py:101

`get_by_uuids`

async def get_by_uuids(self, executor: QueryExecutor, uuids: list[str]) -> list[CommunityEdge]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_edge_ops.py:116

`get_by_group_ids`

async def get_by_group_ids(self, executor: QueryExecutor, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[CommunityEdge]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_edge_ops.py:130

`dbx_tools.graphiti.postgraph.operations.community_node_ops`

`logger`

logger

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_node_ops.py:17

`TABLE`

TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_node_ops.py:19

`PGCommunityNodeOperations`

class PGCommunityNodeOperations(CommunityNodeOperations)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_node_ops.py:22

Methods

`save`

async def save(self, executor: QueryExecutor, node: CommunityNode, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_node_ops.py:23

`save_bulk`

async def save_bulk(self, executor: QueryExecutor, nodes: list[CommunityNode], _tx: Transaction | None=None, _batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_node_ops.py:52

`delete`

async def delete(self, executor: QueryExecutor, node: CommunityNode, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_node_ops.py:63

`delete_by_group_id`

async def delete_by_group_id(self, executor: QueryExecutor, group_id: str, _tx: Transaction | None=None, _batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_node_ops.py:94

`delete_by_uuids`

async def delete_by_uuids(self, executor: QueryExecutor, uuids: list[str], _tx: Transaction | None=None, _batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_node_ops.py:121

`get_by_uuid`

async def get_by_uuid(self, executor: QueryExecutor, uuid: str) -> CommunityNode

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_node_ops.py:158

`get_by_uuids`

async def get_by_uuids(self, executor: QueryExecutor, uuids: list[str]) -> list[CommunityNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_node_ops.py:178

`get_by_group_ids`

async def get_by_group_ids(self, executor: QueryExecutor, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[CommunityNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_node_ops.py:200

`load_name_embedding`

async def load_name_embedding(self, executor: QueryExecutor, node: CommunityNode) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/community_node_ops.py:230

`dbx_tools.graphiti.postgraph.operations.entity_edge_ops`

`logger`

logger

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_edge_ops.py:17

`TABLE`

TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_edge_ops.py:19

`SOURCE_TABLE`

SOURCE_TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_edge_ops.py:20

`TARGET_TABLE`

TARGET_TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_edge_ops.py:21

`PGEntityEdgeOperations`

class PGEntityEdgeOperations(EntityEdgeOperations)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_edge_ops.py:31

Methods

`save`

async def save(self, executor: QueryExecutor, edge: EntityEdge, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_edge_ops.py:32

`save_bulk`

async def save_bulk(self, executor: QueryExecutor, edges: list[EntityEdge], _tx: Transaction | None=None, _batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_edge_ops.py:78

`delete`

async def delete(self, executor: QueryExecutor, edge: EntityEdge, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_edge_ops.py:89

`delete_by_uuids`

async def delete_by_uuids(self, executor: QueryExecutor, uuids: list[str], _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_edge_ops.py:109

`get_by_uuid`

async def get_by_uuid(self, executor: QueryExecutor, uuid: str) -> EntityEdge

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_edge_ops.py:123

`get_by_uuids`

async def get_by_uuids(self, executor: QueryExecutor, uuids: list[str]) -> list[EntityEdge]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_edge_ops.py:138

`get_by_group_ids`

async def get_by_group_ids(self, executor: QueryExecutor, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[EntityEdge]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_edge_ops.py:152

`get_between_nodes`

async def get_between_nodes(self, executor: QueryExecutor, source_node_uuid: str, target_node_uuid: str) -> list[EntityEdge]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_edge_ops.py:171

`get_by_node_uuid`

async def get_by_node_uuid(self, executor: QueryExecutor, node_uuid: str) -> list[EntityEdge]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_edge_ops.py:187

`load_embeddings`

async def load_embeddings(self, executor: QueryExecutor, edge: EntityEdge) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_edge_ops.py:201

`load_embeddings_bulk`

async def load_embeddings_bulk(self, executor: QueryExecutor, edges: list[EntityEdge], _batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_edge_ops.py:220

`dbx_tools.graphiti.postgraph.operations.entity_node_ops`

`logger`

logger

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_node_ops.py:15

`TABLE`

TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_node_ops.py:17

`PGEntityNodeOperations`

class PGEntityNodeOperations(EntityNodeOperations)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_node_ops.py:20

Methods

`save`

async def save(self, executor: QueryExecutor, node: Any, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_node_ops.py:21

`save_bulk`

async def save_bulk(self, executor: QueryExecutor, nodes: list[Any], _tx: Transaction | None=None, _batch_size: int=100) -> None

Accepts EntityNode objects or the dicts the bulk path supplies.

    bulk_utils flattens `attributes` into top-level keys for every provider
    except Kuzu, because the Cypher drivers SET them as map properties. This
    inverts that: anything that is not a known field is an attribute.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_node_ops.py:55

`delete`

async def delete(self, executor: QueryExecutor, node: EntityNode, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_node_ops.py:71

`delete_by_group_id`

async def delete_by_group_id(self, executor: QueryExecutor, group_id: str, _tx: Transaction | None=None, _batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_node_ops.py:124

`delete_by_uuids`

async def delete_by_uuids(self, executor: QueryExecutor, uuids: list[str], _tx: Transaction | None=None, _batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_node_ops.py:160

`get_by_uuid`

async def get_by_uuid(self, executor: QueryExecutor, uuid: str) -> EntityNode

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_node_ops.py:212

`get_by_uuids`

async def get_by_uuids(self, executor: QueryExecutor, uuids: list[str]) -> list[EntityNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_node_ops.py:232

`get_by_group_ids`

async def get_by_group_ids(self, executor: QueryExecutor, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[EntityNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_node_ops.py:253

`load_embeddings`

async def load_embeddings(self, executor: QueryExecutor, node: EntityNode) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_node_ops.py:284

`load_embeddings_bulk`

async def load_embeddings_bulk(self, executor: QueryExecutor, nodes: list[EntityNode], _batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/entity_node_ops.py:304

`dbx_tools.graphiti.postgraph.operations.episode_node_ops`

`logger`

logger

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episode_node_ops.py:19

`TABLE`

TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episode_node_ops.py:21

`PGEpisodeNodeOperations`

class PGEpisodeNodeOperations(EpisodeNodeOperations)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episode_node_ops.py:24

Methods

`save`

async def save(self, executor: QueryExecutor, node: Any, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episode_node_ops.py:25

`save_bulk`

async def save_bulk(self, executor: QueryExecutor, nodes: list[Any], _tx: Transaction | None=None, _batch_size: int=100) -> None

Accepts EpisodicNode objects or the dicts the bulk path supplies.

    bulk_utils.add_nodes_and_edges_bulk_tx converts every node with
    `dict(episode)` before calling this — the Cypher drivers UNWIND a list
    of maps — and it stringifies `source` on the way. save() expects an
    object, so the bulk path failed with "'dict' object has no attribute
    'uuid'" on the first add_episode(). The driver's own tests call save()
    directly and never see it.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episode_node_ops.py:57

`delete`

async def delete(self, executor: QueryExecutor, node: EpisodicNode, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episode_node_ops.py:76

`delete_by_group_id`

async def delete_by_group_id(self, executor: QueryExecutor, group_id: str, _tx: Transaction | None=None, _batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episode_node_ops.py:130

`delete_by_uuids`

async def delete_by_uuids(self, executor: QueryExecutor, uuids: list[str], _tx: Transaction | None=None, _batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episode_node_ops.py:175

`get_by_uuid`

async def get_by_uuid(self, executor: QueryExecutor, uuid: str) -> EpisodicNode

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episode_node_ops.py:225

`get_by_uuids`

async def get_by_uuids(self, executor: QueryExecutor, uuids: list[str]) -> list[EpisodicNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episode_node_ops.py:243

`get_by_group_ids`

async def get_by_group_ids(self, executor: QueryExecutor, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[EpisodicNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episode_node_ops.py:263

`get_by_entity_node_uuid`

async def get_by_entity_node_uuid(self, executor: QueryExecutor, entity_node_uuid: str) -> list[EpisodicNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episode_node_ops.py:293

`retrieve_episodes`

async def retrieve_episodes(self, executor: QueryExecutor, reference_time: datetime, last_n: int=3, group_ids: list[str] | None=None, source: str | None=None, saga: str | None=None) -> list[EpisodicNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episode_node_ops.py:315

`dbx_tools.graphiti.postgraph.operations.episodic_edge_ops`

`logger`

logger

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episodic_edge_ops.py:13

`TABLE`

TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episodic_edge_ops.py:15

`SOURCE_TABLE`

SOURCE_TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episodic_edge_ops.py:16

`TARGET_TABLE`

TARGET_TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episodic_edge_ops.py:17

`PGEpisodicEdgeOperations`

class PGEpisodicEdgeOperations(EpisodicEdgeOperations)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episodic_edge_ops.py:20

Methods

`save`

async def save(self, executor: QueryExecutor, edge: EpisodicEdge, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episodic_edge_ops.py:21

`save_bulk`

async def save_bulk(self, executor: QueryExecutor, edges: list[EpisodicEdge], _tx: Transaction | None=None, _batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episodic_edge_ops.py:66

`delete`

async def delete(self, executor: QueryExecutor, edge: EpisodicEdge, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episodic_edge_ops.py:77

`delete_by_uuids`

async def delete_by_uuids(self, executor: QueryExecutor, uuids: list[str], _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episodic_edge_ops.py:93

`get_by_uuid`

async def get_by_uuid(self, executor: QueryExecutor, uuid: str) -> EpisodicEdge

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episodic_edge_ops.py:109

`get_by_uuids`

async def get_by_uuids(self, executor: QueryExecutor, uuids: list[str]) -> list[EpisodicEdge]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episodic_edge_ops.py:124

`get_by_group_ids`

async def get_by_group_ids(self, executor: QueryExecutor, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[EpisodicEdge]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/episodic_edge_ops.py:141

`dbx_tools.graphiti.postgraph.operations.graph_ops`

`logger`

logger

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/graph_ops.py:16

`VERTEX_TABLES`

VERTEX_TABLES

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/graph_ops.py:18

`EDGE_DEFS`

EDGE_DEFS

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/graph_ops.py:20

`ALL_TABLES`

ALL_TABLES

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/graph_ops.py:33

`PGGraphMaintenanceOperations`

class PGGraphMaintenanceOperations(GraphMaintenanceOperations)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/graph_ops.py:72

Methods

`build_indices_and_constraints_pg`

async def build_indices_and_constraints_pg(self, client: AsyncPostGraph, embedding_dim: int) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/graph_ops.py:76

`build_indices_and_constraints_raw`

async def build_indices_and_constraints_raw(self, _conn) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/graph_ops.py:106

`delete_all_indexes_raw`

async def delete_all_indexes_raw(self, _conn) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/graph_ops.py:109

`clear_data`

async def clear_data(self, executor: QueryExecutor, group_ids: list[str] | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/graph_ops.py:112

`build_indices_and_constraints`

async def build_indices_and_constraints(self, executor: QueryExecutor, delete_existing: bool=False) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/graph_ops.py:126

`delete_all_indexes`

async def delete_all_indexes(self, executor: QueryExecutor) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/graph_ops.py:134

`get_community_clusters`

async def get_community_clusters(self, executor: QueryExecutor, group_ids: list[str] | None=None) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/graph_ops.py:145

`remove_communities`

async def remove_communities(self, executor: QueryExecutor, group_ids: list[str] | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/graph_ops.py:216

`determine_entity_community`

async def determine_entity_community(self, executor: QueryExecutor, entity: EntityNode) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/graph_ops.py:230

`get_mentioned_nodes`

async def get_mentioned_nodes(self, executor: QueryExecutor, episodes: list[EpisodicNode]) -> list[EntityNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/graph_ops.py:252

`get_communities_by_nodes`

async def get_communities_by_nodes(self, executor: QueryExecutor, nodes: list[EntityNode]) -> list[CommunityNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/graph_ops.py:284

`dbx_tools.graphiti.postgraph.operations.has_episode_edge_ops`

`logger`

logger

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/has_episode_edge_ops.py:13

`TABLE`

TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/has_episode_edge_ops.py:15

`SOURCE_TABLE`

SOURCE_TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/has_episode_edge_ops.py:16

`TARGET_TABLE`

TARGET_TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/has_episode_edge_ops.py:17

`PGHasEpisodeEdgeOperations`

class PGHasEpisodeEdgeOperations(HasEpisodeEdgeOperations)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/has_episode_edge_ops.py:20

Methods

`save`

async def save(self, executor: QueryExecutor, edge: HasEpisodeEdge, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/has_episode_edge_ops.py:21

`save_bulk`

async def save_bulk(self, executor: QueryExecutor, edges: list[HasEpisodeEdge], _tx: Transaction | None=None, _batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/has_episode_edge_ops.py:66

`delete`

async def delete(self, executor: QueryExecutor, edge: HasEpisodeEdge, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/has_episode_edge_ops.py:77

`delete_by_uuids`

async def delete_by_uuids(self, executor: QueryExecutor, uuids: list[str], _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/has_episode_edge_ops.py:93

`get_by_uuid`

async def get_by_uuid(self, executor: QueryExecutor, uuid: str) -> HasEpisodeEdge

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/has_episode_edge_ops.py:109

`get_by_uuids`

async def get_by_uuids(self, executor: QueryExecutor, uuids: list[str]) -> list[HasEpisodeEdge]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/has_episode_edge_ops.py:124

`get_by_group_ids`

async def get_by_group_ids(self, executor: QueryExecutor, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[HasEpisodeEdge]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/has_episode_edge_ops.py:141

`dbx_tools.graphiti.postgraph.operations.next_episode_edge_ops`

`logger`

logger

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/next_episode_edge_ops.py:13

`TABLE`

TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/next_episode_edge_ops.py:15

`SOURCE_TABLE`

SOURCE_TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/next_episode_edge_ops.py:16

`TARGET_TABLE`

TARGET_TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/next_episode_edge_ops.py:17

`PGNextEpisodeEdgeOperations`

class PGNextEpisodeEdgeOperations(NextEpisodeEdgeOperations)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/next_episode_edge_ops.py:20

Methods

`save`

async def save(self, executor: QueryExecutor, edge: NextEpisodeEdge, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/next_episode_edge_ops.py:21

`save_bulk`

async def save_bulk(self, executor: QueryExecutor, edges: list[NextEpisodeEdge], _tx: Transaction | None=None, _batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/next_episode_edge_ops.py:66

`delete`

async def delete(self, executor: QueryExecutor, edge: NextEpisodeEdge, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/next_episode_edge_ops.py:77

`delete_by_uuids`

async def delete_by_uuids(self, executor: QueryExecutor, uuids: list[str], _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/next_episode_edge_ops.py:93

`get_by_uuid`

async def get_by_uuid(self, executor: QueryExecutor, uuid: str) -> NextEpisodeEdge

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/next_episode_edge_ops.py:109

`get_by_uuids`

async def get_by_uuids(self, executor: QueryExecutor, uuids: list[str]) -> list[NextEpisodeEdge]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/next_episode_edge_ops.py:124

`get_by_group_ids`

async def get_by_group_ids(self, executor: QueryExecutor, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[NextEpisodeEdge]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/next_episode_edge_ops.py:141

`dbx_tools.graphiti.postgraph.operations.saga_node_ops`

`logger`

logger

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/saga_node_ops.py:14

`TABLE`

TABLE

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/saga_node_ops.py:16

`PGSagaNodeOperations`

class PGSagaNodeOperations(SagaNodeOperations)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/saga_node_ops.py:19

Methods

`save`

async def save(self, executor: QueryExecutor, node: SagaNode, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/saga_node_ops.py:20

`save_bulk`

async def save_bulk(self, executor: QueryExecutor, nodes: list[SagaNode], _tx: Transaction | None=None, _batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/saga_node_ops.py:57

`delete`

async def delete(self, executor: QueryExecutor, node: SagaNode, _tx: Transaction | None=None) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/saga_node_ops.py:67

`delete_by_group_id`

async def delete_by_group_id(self, executor: QueryExecutor, group_id: str, _tx: Transaction | None=None, _batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/saga_node_ops.py:98

`delete_by_uuids`

async def delete_by_uuids(self, executor: QueryExecutor, uuids: list[str], _tx: Transaction | None=None, _batch_size: int=100) -> None

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/saga_node_ops.py:125

`get_by_uuid`

async def get_by_uuid(self, executor: QueryExecutor, uuid: str) -> SagaNode

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/saga_node_ops.py:162

`get_by_uuids`

async def get_by_uuids(self, executor: QueryExecutor, uuids: list[str]) -> list[SagaNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/saga_node_ops.py:180

`get_by_group_ids`

async def get_by_group_ids(self, executor: QueryExecutor, group_ids: list[str], limit: int | None=None, uuid_cursor: str | None=None) -> list[SagaNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/saga_node_ops.py:200

`dbx_tools.graphiti.postgraph.operations.search_ops`

`logger`

logger

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/search_ops.py:14

`PGSearchOperations`

class PGSearchOperations(SearchOperations)

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/search_ops.py:17

Methods

`node_fulltext_search`

async def node_fulltext_search(self, executor: QueryExecutor, query: str, search_filter: SearchFilters, group_ids: list[str] | None=None, limit: int=10) -> list[EntityNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/search_ops.py:20

`node_similarity_search`

async def node_similarity_search(self, executor: QueryExecutor, search_vector: list[float], search_filter: SearchFilters, group_ids: list[str] | None=None, limit: int=10, min_score: float=0.6) -> list[EntityNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/search_ops.py:53

`node_bfs_search`

async def node_bfs_search(self, executor: QueryExecutor, origin_uuids: list[str], search_filter: SearchFilters, max_depth: int, group_ids: list[str] | None=None, limit: int=10) -> list[EntityNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/search_ops.py:88

`edge_fulltext_search`

async def edge_fulltext_search(self, executor: QueryExecutor, query: str, search_filter: SearchFilters, group_ids: list[str] | None=None, limit: int=10) -> list[EntityEdge]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/search_ops.py:147

`edge_similarity_search`

async def edge_similarity_search(self, executor: QueryExecutor, search_vector: list[float], source_node_uuid: str | None, target_node_uuid: str | None, search_filter: SearchFilters, group_ids: list[str] | None=None, limit: int=10, min_score: float=0.6) -> list[EntityEdge]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/search_ops.py:180

`edge_bfs_search`

async def edge_bfs_search(self, executor: QueryExecutor, origin_uuids: list[str], max_depth: int, search_filter: SearchFilters, group_ids: list[str] | None=None, limit: int=10) -> list[EntityEdge]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/search_ops.py:223

`episode_fulltext_search`

async def episode_fulltext_search(self, executor: QueryExecutor, query: str, _search_filter: SearchFilters, group_ids: list[str] | None=None, limit: int=10) -> list[EpisodicNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/search_ops.py:276

`community_fulltext_search`

async def community_fulltext_search(self, executor: QueryExecutor, query: str, group_ids: list[str] | None=None, limit: int=10) -> list[CommunityNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/search_ops.py:316

`community_similarity_search`

async def community_similarity_search(self, executor: QueryExecutor, search_vector: list[float], group_ids: list[str] | None=None, limit: int=10, min_score: float=0.6) -> list[CommunityNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/search_ops.py:354

`node_distance_reranker`

async def node_distance_reranker(self, executor: QueryExecutor, node_uuids: list[str], center_node_uuid: str, min_score: float=0) -> list[EntityNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/search_ops.py:388

`episode_mentions_reranker`

async def episode_mentions_reranker(self, executor: QueryExecutor, node_uuids: list[str], min_score: float=0) -> list[EntityNode]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/search_ops.py:458

`build_node_search_filters`

def build_node_search_filters(self, search_filters: SearchFilters) -> Any

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/search_ops.py:510

`build_edge_search_filters`

def build_edge_search_filters(self, search_filters: SearchFilters) -> Any

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/search_ops.py:514

`build_fulltext_query`

def build_fulltext_query(self, query: str, _group_ids: list[str] | None=None, max_query_length: int=8000) -> str

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/operations/search_ops.py:518

`dbx_tools.graphiti.postgraph.record_parsers`

Licensed under the Apache License, Version 2.0 (the “License”); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an “AS IS” BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

`entity_node_from_record`

def entity_node_from_record(record: Any) -> EntityNode

Parse an entity node from a database record.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/record_parsers.py:24

`entity_edge_from_record`

def entity_edge_from_record(record: Any) -> EntityEdge

Parse an entity edge from a database record.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/record_parsers.py:53

`episodic_node_from_record`

def episodic_node_from_record(record: Any) -> EpisodicNode

Parse an episodic node from a database record.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/record_parsers.py:88

`community_node_from_record`

def community_node_from_record(record: Any) -> CommunityNode

Parse a community node from a database record.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/record_parsers.py:121

`dbx_tools.graphiti.postgraph.search_interface`

SearchInterface adapter for the PostGraph driver.

graphiti_core/search/search_utils.py checks if driver.search_interface: and otherwise falls back to raw Cypher, which PostgreSQL rejects outright (“syntax error at or near MATCH”). The driver already implements every search in operations/search_ops.py; without this adapter none of them is ever reached, so persistence works and the first search fails.

The interface takes driver, the operations take a QueryExecutor, and the driver is one — the adapter is a signature translation, not new search logic.

`PostGraphSearchInterface`

class PostGraphSearchInterface(SearchInterface)

Routes Graphiti’s searches to the driver’s SQL implementations.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/search_interface.py:19

Methods

`edge_fulltext_search`

async def edge_fulltext_search(self, driver: Any, query: str, search_filter: Any, group_ids: list[str] | None=None, limit: int=100) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/search_interface.py:24

`edge_similarity_search`

async def edge_similarity_search(self, driver: Any, search_vector: list[float], source_node_uuid: str | None=None, target_node_uuid: str | None=None, search_filter: Any=None, group_ids: list[str] | None=None, limit: int=100, min_score: float=0.7) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/search_interface.py:30

`node_fulltext_search`

async def node_fulltext_search(self, driver: Any, query: str, search_filter: Any, group_ids: list[str] | None=None, limit: int=100) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/search_interface.py:41

`node_similarity_search`

async def node_similarity_search(self, driver: Any, search_vector: list[float], search_filter: Any=None, group_ids: list[str] | None=None, limit: int=100, min_score: float=0.7) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/search_interface.py:47

`episode_fulltext_search`

async def episode_fulltext_search(self, driver: Any, query: str, search_filter: Any, group_ids: list[str] | None=None, limit: int=100) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/search_interface.py:55

`edge_bfs_search`

async def edge_bfs_search(self, driver: Any, bfs_origin_node_uuids: list[str] | None, bfs_max_depth: int, search_filter: Any, limit: int=100) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/search_interface.py:61

`node_bfs_search`

async def node_bfs_search(self, driver: Any, bfs_origin_node_uuids: list[str] | None, search_filter: Any, bfs_max_depth: int, limit: int=100) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/search_interface.py:68

`community_fulltext_search`

async def community_fulltext_search(self, driver: Any, query: str, group_ids: list[str] | None=None, limit: int=100) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/search_interface.py:75

`community_similarity_search`

async def community_similarity_search(self, driver: Any, search_vector: list[float], group_ids: list[str] | None=None, limit: int=100, min_score: float=0.7) -> list[Any]

No source docstring is available.

Source: packages/py/graphiti/src/dbx_tools/graphiti/postgraph/search_interface.py:80

`dbx_tools.graphiti.runtime`

`RuntimeClients`

class RuntimeClients

Process-wide authentication, model, and Graphiti model clients.

Source: packages/py/graphiti/src/dbx_tools/graphiti/runtime.py:34

Fields

auth: AuthClient
model: ModelClient
llm: OpenAIGenericClient
embedder: OpenAIEmbedder
cross_encoder: OpenAIRerankerClient
http: httpx.AsyncClient
llm_model: str
embedder_model: str
embedder_dimensions: int

`GraphitiRuntime`

class GraphitiRuntime(AbstractAsyncContextManager['GraphitiRuntime'])

Start and stop a complete Graphiti runtime without a CLI or HTTP server.

Source: packages/py/graphiti/src/dbx_tools/graphiti/runtime.py:74

Methods

`from_options`

def from_options(cls, options: GraphitiOptionsInput | None=None) -> 'GraphitiRuntime'

Create a runtime from the same shared option contract used by Node and CLI.

Source: packages/py/graphiti/src/dbx_tools/graphiti/runtime.py:84

`start`

async def start(self) -> Graphiti

Start model clients and initialize PostgreSQL-backed Graphiti.

Source: packages/py/graphiti/src/dbx_tools/graphiti/runtime.py:98

`close`

async def close(self) -> None

Close Graphiti and model transports.

Source: packages/py/graphiti/src/dbx_tools/graphiti/runtime.py:134

`create_runtime_clients`

async def create_runtime_clients(options: ResolvedGraphitiOptionsResponse) -> RuntimeClients

Create authentication and routed OpenAI clients from shared options.

Source: packages/py/graphiti/src/dbx_tools/graphiti/runtime.py:154

`configure_graphiti_client`

def configure_graphiti_client(client: Graphiti, clients: RuntimeClients) -> None

Attach shared model clients to every reference held by upstream Graphiti.

Source: packages/py/graphiti/src/dbx_tools/graphiti/runtime.py:236

dbx-tools-graphiti Python API

dbx_tools.graphiti.__main__

main

dbx_tools.graphiti._generated.node._runtime

get_runtime

invoke_positioned

invoke_positioned_sync

dbx_tools.graphiti._generated.node.auth.bindings

AuthOptions

Fields

DatabricksAuthDependencies

Fields

DatabricksAuthOptions

Fields

AccessTokenResponse

Fields

TokenOptionsResponse

Fields

AuthClient

Fields

Methods

token

headers

logout

create_auth_client

dbx_tools.graphiti._generated.node.lakebase.bindings

AuthOptions

Fields

DatabricksAuthOptions

Fields

LakebaseConnectionInputsResponse

Fields

ParsedAddressResponse

Fields

ResolvedLakebaseResponse

Fields

LakebaseClient

Methods

resolve

generate_database_credential

create_lakebase_client

parse_address

dbx_tools.graphiti._generated.node.model.bindings

ModelAuthOptions

Fields

ModelClientOptions

Fields

CreateModelClientReturnListModelsReturnProfileResultResponse

Fields

CreateModelClientReturnListModelsReturnStatusResultResponse

Fields

CreateModelClientReturnListModelsReturnResultResponse

CreateModelClientReturnMetadataModelProfileResultResponse

Fields

CreateModelClientReturnMetadataModelStatusResultResponse

Fields

CreateModelClientReturnMetadataModelResultResponse

CreateModelClientReturnMetadataReturnCapabilitiesResultResponse

Fields

CreateModelClientReturnMetadataReturnRateLimitsResultResponse

Fields

CreateModelClientReturnMetadataReturnStatusResultResponse

Fields

CreateModelClientReturnMetadataReturnResultResponse

Fields

CreateModelClientReturnRouteReturnEndpointProfileResultResponse

Fields

CreateModelClientReturnRouteReturnEndpointStatusResultResponse

Fields

CreateModelClientReturnRouteReturnEndpointResultResponse

CreateModelClientReturnRouteReturnMetadataCapabilitiesResultResponse

Fields

CreateModelClientReturnRouteReturnMetadataRateLimitsResultResponse

Fields

CreateModelClientReturnRouteReturnMetadataStatusResultResponse

Fields

CreateModelClientReturnRouteReturnMetadataResultResponse

Fields

CreateModelClientReturnSearchModelsQueryResultResponse

Fields

`dbx_tools.graphiti.main`

`main`

`dbx_tools.graphiti._generated.node._runtime`

`get_runtime`

`invoke_positioned`

`invoke_positioned_sync`

`dbx_tools.graphiti._generated.node.auth.bindings`

`AuthOptions`

`DatabricksAuthDependencies`

`DatabricksAuthOptions`

`AccessTokenResponse`

`TokenOptionsResponse`

`AuthClient`

`token`

`headers`

`logout`

`create_auth_client`

`dbx_tools.graphiti._generated.node.lakebase.bindings`

`AuthOptions`

`DatabricksAuthOptions`

`LakebaseConnectionInputsResponse`

`ParsedAddressResponse`

`ResolvedLakebaseResponse`

`LakebaseClient`

`resolve`

`generate_database_credential`

`create_lakebase_client`

`parse_address`

`dbx_tools.graphiti._generated.node.model.bindings`

`ModelAuthOptions`

`ModelClientOptions`

`CreateModelClientReturnListModelsReturnProfileResultResponse`

`CreateModelClientReturnListModelsReturnStatusResultResponse`

`CreateModelClientReturnListModelsReturnResultResponse`

`CreateModelClientReturnMetadataModelProfileResultResponse`

`CreateModelClientReturnMetadataModelStatusResultResponse`

`CreateModelClientReturnMetadataModelResultResponse`

`CreateModelClientReturnMetadataReturnCapabilitiesResultResponse`

`CreateModelClientReturnMetadataReturnRateLimitsResultResponse`

`CreateModelClientReturnMetadataReturnStatusResultResponse`

`CreateModelClientReturnMetadataReturnResultResponse`

`CreateModelClientReturnRouteReturnEndpointProfileResultResponse`

`CreateModelClientReturnRouteReturnEndpointStatusResultResponse`

`CreateModelClientReturnRouteReturnEndpointResultResponse`

`CreateModelClientReturnRouteReturnMetadataCapabilitiesResultResponse`

`CreateModelClientReturnRouteReturnMetadataRateLimitsResultResponse`

`CreateModelClientReturnRouteReturnMetadataStatusResultResponse`

`CreateModelClientReturnRouteReturnMetadataResultResponse`

`CreateModelClientReturnSearchModelsQueryResultResponse`

`CreateModelClientReturnSearchModelsReturnEndpointProfileResultResponse`

`CreateModelClientReturnSearchModelsReturnEndpointStatusResultResponse`

`CreateModelClientReturnSearchModelsReturnEndpointResultResponse`

`CreateModelClientReturnSearchModelsReturnResultResponse`

`ModelClientStatusResponse`

`ModelRouteInputResponse`

`ModelRouteResponse`

`ModelClient`

`list_models`

`search_models`

`route`

`metadata`

`status`

`create_model_client`

`dbx_tools.graphiti._generated.node.postgres.bindings`

`postgres_role_statement`

`postgres_server_settings`

`quote_postgres_identifier`

`resolve_postgres_role`

`dbx_tools.graphiti._generated.node.shared_core.bindings`

`log_active_level`

`log_level_enabled`

`dbx_tools.graphiti._generated.node.shared_graphiti.options`

`GraphitiOptions`

`GraphitiOptionsResponse`

`ResolveGraphitiOptionsReturnListenResultResponse`

`ResolvedGraphitiOptionsResponse`

`graphiti_option_overrides`

`graphiti_options_environment`

`graphiti_options_from_environment`

`resolve_graphiti_options`