Skip to content

_resolve_write_target

Internal helper
This page documents an internal implementation helper, not a primary public API.
Source code in src/fabricops_kit/lineage.py
39
40
41
42
43
44
45
46
def _resolve_write_target(cname: str, call: ast.Call) -> str:
    if cname == "lakehouse_table_write":
        return _literal(call.args[2]) if len(call.args) >= 3 else "unknown_lakehouse_table"
    if cname == "warehouse_write":
        if len(call.args) >= 5:
            return f"{_literal(call.args[3]) or 'schema'}.{_literal(call.args[4]) or 'table'}"
        return "unknown_warehouse_table"
    return "unknown_target"