Core

dask_expr/_core.py

@@ -12,6 +12,7 @@
 from dask.dataframe.core import is_dataframe_like, is_index_like, is_series_like
 from dask.utils import funcname, import_required, is_arraylike
 
+from dask_expr._diagnostics import explain
 from dask_expr._util import _BackendData, _tokenize_deterministic
 
 
@@ -111,6 +112,21 @@ def _tree_repr_lines(self, indent=0, recursive=True):
     def tree_repr(self):
         return os.linesep.join(self._tree_repr_lines())
 
+    def _explain_label(self):
+        return "".join(
+            [
+                "<{<b>",
+                funcname(type(self)),
+                "</b> | ",
+                "npartitions: ",
+                str(self.npartitions),
+                "}>",
+            ]
+        )
+
+    def explain(self, fuse: bool = True) -> None:
+        explain(self, fuse)
+
     def pprint(self):
         for line in self._tree_repr_lines():
             print(line)