_write_metadata_rows

Internal helper

This page documents an internal implementation helper, not a primary public API.

Source code in src/fabricops_kit/drift.py

def _write_metadata_rows(spark, metadata_table: str, records: list[dict], mode: str = "append") -> bool:
    if not records:
        return False
    metadata_df = spark.createDataFrame(records)
    metadata_df.write.mode(mode).saveAsTable(metadata_table)
    return True