tdfs4ds.attached_registry¶

tdfs4ds.attached_registry ¶

Which views and tables are attached to the feature store (0.3.5.2): the marker's reads and its end (detach); no documentation is written here.

The marker is the reserved business-dictionary section ATTACHED written by genai.attached_objects.attach_objects. This module only reads it, so the lineage rebuild, the removal guard and the workflow assessment can use it without importing the documentation (LLM) package.

ATTACHED_SECTION `module-attribute` ¶

ATTACHED_SECTION = 'ATTACHED'

KIND_VIEW `module-attribute` ¶

KIND_VIEW = 'V'

KIND_TABLE `module-attribute` ¶

KIND_TABLE = 'T'

logger_safe ¶

logger_safe(level, message, *args, **kwargs)

Wrapper around the global logger that only emits logs when tdfs4ds.DISPLAY_LOGS is True. level is a string like "info", "error", etc.

sql_literal ¶

sql_literal(value)

Escape value for use inside a single-quoted SQL string literal.

For the DBC probes and catalog predicates that compare a name as data (WHERE DatabaseName = '…'). The caller supplies the surrounding quotes.

_rows ¶

_rows(sql: str)

_bd ¶

_bd(name: str) -> str

_where_obj ¶

_where_obj(db_col, obj_col, db, obj) -> str

parse_marker ¶

parse_marker(text) -> Optional[dict]

read_marker ¶

read_marker(db: str, obj: str) -> Optional[dict]

_markers ¶

_markers() -> List[Tuple[str, str, dict]]

attached_objects ¶

attached_objects(data_domain: Optional[str] = None) -> pd.DataFrame

The attached objects: DATABASE_NAME, OBJECT_NAME, KIND ('V' / 'T'), DATA_DOMAIN, DOCUMENTED_AT (optionally of one data domain).

attached_view_names ¶

attached_view_names() -> List[Tuple[str, str]]

[(db, view)] of the attached views (the lineage rebuild seeds them).

attached_readers ¶

attached_readers(objects) -> Dict[str, List[str]]

{'DB.VIEW': ['DB.DATASET', ...]}: the attached views reading any of objects ('db.name' strings), from the sources recorded at their last pass. One read.

attached_index ¶

attached_index() -> Dict[Tuple[str, str], str]

{(DB, OBJ): 'V' | 'T'} of the attached objects (the agent's scope). Fail-open: {}.

_exec ¶

_exec(sql: str)

_resolve ¶

_resolve(objects) -> List[Tuple[str, str]]

_end_marker ¶

_end_marker(db, obj)

detach_objects ¶

detach_objects(objects, *, dry_run: bool = False) -> List[dict]

End the ATTACHED marker. The documentation stays; the lineage edges of a view are closed by the next full rebuild_lineage_graph (it is no longer seeded).

tdfs4ds.attached_registry¶