graflo.hq

High-level orchestration modules for graflo.

This package provides high-level orchestration classes that coordinate multiple components for graph database operations.

The façade is lazy (PEP 562): importing graflo.hq is cheap; orchestration classes (and their DB/data-source dependencies) load on first attribute access.

Modules:

Name	Description
auto_join	Auto-JOIN generation for edge resources.
bulk_session	Backend-agnostic coordinator for optional native bulk ingestion.
cast_pool	Worker-process casting for the ingestion hot path.
caster	Data casting and ingestion system for graph databases.
concurrency_gate	Decide how many batches of one data source may be in flight concurrently.
db_writer	Database writer for pushing graph data to the target database.
doc_error_sink	Pluggable sinks for persisting per-document cast failures.
document_caster	Stateless document-to-graph casting (no I/O).
endpoint_resolve	Resolve edge endpoints declared by a secondary identity.
graph_engine	Graph engine for orchestrating schema inference, connector creation, and ingestion.
ingestion_parameters	Ingestion parameters and per-document cast-failure models for the caster.
rdf_inferencer	RDF / OWL ontology inference manager.
registry_builder	Build a :class:DataSourceRegistry from :class:Bindings and schema models.
resource_mapper	Resource mapper for creating Bindings from different data sources.
sampler	Connector-driven resource sampling.
sanitizer	Sanitization entry point for schema and ingestion contracts.
sql_inferencer	PostgreSQL schema inference and resource mapping (high level).

Attributes

__all__ = ['CastBatchResult', 'Caster', 'DBWriter', 'DocCastFailure', 'DocErrorBudgetExceeded', 'DocErrorSink', 'GraphEngine', 'IngestionParams', 'JsonlGzDocErrorSink', 'RegistryBuilder', 'ResourceMapper', 'SQLInferenceManager', 'Sanitizer', 'failure_sinks_from_ingestion_params'] module-attribute

Functions:

__dir__()

Source code in graflo/hq/__init__.py

def __dir__() -> list[str]:
    return sorted(__all__)

__getattr__(name)

Source code in graflo/hq/__init__.py

def __getattr__(name: str) -> Any:
    if name in _EXPORTS:
        import importlib

        value = getattr(importlib.import_module(_EXPORTS[name]), name)
        globals()[name] = value
        return value
    raise AttributeError(f"module {__name__!r} has no attribute {name!r}")