_safe_spark_collect

Internal helper

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

Source code in src/fabricops_kit/drift.py

def _safe_spark_collect(df):
    if df is None:
        return []
    if hasattr(df, "collect"):
        return df.collect()
    return []