Method enforce_runtime_divisions

dask/dataframe/dask_expr/_collection.py:1632–1640

Enforce the current divisions at runtime. Injects a layer into the Task Graph that checks that the current divisions match the expected divisions at runtime.

(self)

        return result

    def enforce_runtime_divisions(self):
        """Enforce the current divisions at runtime.

        Injects a layer into the Task Graph that checks that the current divisions
        match the expected divisions at runtime.
        """
        if not self.known_divisions:
            raise ValueError("No known divisions to enforce!")
        return new_collection(expr.EnforceRuntimeDivisions(self))

    @derived_from(pd.DataFrame)
    def skew(