class_docstr: Utility class for inspecting the state of a cluster dump
  
  .. code-block:: python
  
      dump = DumpArtefact.from_url("dump.msgpack.gz")
      memory_tasks = dump.scheduler_tasks("memory")
      executing_tasks = dump.worker_tasks("executing")
class_docstr_tok: ["Utility","class","for","inspecting","the","state","of","a","cluster","dump","..","code-block",":",":","python","dump","=","DumpArtefact.from_url","(","``","dump.msgpack.gz","''",")","memory_tasks","=","dump.scheduler_tasks","(","``","memory","''",")","executing_tasks","=","dump.worker_tasks","(","``","executing","''",")"]
docstr: Loads a cluster dump from a disk artefact
  
  Parameters
  ----------
  url : str
      Name of the disk artefact. This should have either a
      ``.msgpack.gz`` or ``yaml`` suffix, depending on the dump format.
  **kwargs :
      Extra arguments passed to :func:`fsspec.open`.
  
  Returns
  -------
  state : dict
      The cluster state at the time of the dump.
docstr_tok: ["Loads","a","cluster","dump","from","a","disk","artefact","Parameters","--","--","--","--","--","url",":","str","Name","of","the","disk","artefact",".","This","should","have","either","a","``",".msgpack.gz","``","or","``","yaml","``","suffix",",","depending","on","the","dump","format",".","*","*","kwargs",":","Extra","arguments","passed","to",":","func",":","`","fsspec.open","`",".","Returns","--","--","--","-","state",":","dict","The","cluster","state","at","the","time","of","the","dump","."]
code: def from_url(cls, url: str, **kwargs: Any) -> DumpArtefact:
      """Loads a cluster dump from a disk artefact
  
      Parameters
      ----------
      url : str
          Name of the disk artefact. This should have either a
          ``.msgpack.gz`` or ``yaml`` suffix, depending on the dump format.
      **kwargs :
          Extra arguments passed to :func:`fsspec.open`.
  
      Returns
      -------
      state : dict
          The cluster state at the time of the dump.
      """
      return DumpArtefact(load_cluster_dump(url, **kwargs))
  
imports: from __future__ import annotations
  import asyncio
  from collections import defaultdict
  from collections.abc import Awaitable, Callable, Collection, Mapping
  from pathlib import Path
  from typing import IO, Any, Literal
  import msgpack
  from dask.typing import Key
  from distributed._stories import scheduler_story
  from distributed._stories import worker_story
label_desc: Use image node_id 2 for calling the DumpArtefact obj's underlying member method code with example usage: obj.from_url(cls, url) and returns: DumpArtefact