Method _execute_internal_graph

dask/dataframe/dask_expr/_expr.py:3884–3887

(internal_tasks, dependencies, outkey)

    @staticmethod
    def _execute_internal_graph(internal_tasks, dependencies, outkey):
        cache = dict(dependencies)
        res = execute_graph(internal_tasks, cache=cache, keys=[outkey])
        return res[outkey]


# Used for sorting with None