class_docstr: Dask implementation of a `GraphRunner`.
docstr: Initializes a `DaskGraphRunner`.
  
  Args:
      graph_schema: The graph schema that will be run.
      model_storage: Storage which graph components can use to persist and load
          themselves.
      execution_context: Information about the current graph run to be passed to
          each node.
      hooks: These are called before and after the execution of each node.
docstr_tok: ["Initializes","a","`","DaskGraphRunner","`",".","Args",":","graph_schema",":","The","graph","schema","that","will","be","run",".","model_storage",":","Storage","which","graph","components","can","use","to","persist","and","load","themselves",".","execution_context",":","Information","about","the","current","graph","run","to","be","passed","to","each","node",".","hooks",":","These","are","called","before","and","after","the","execution","of","each","node","."]
code: def __init__(
      self,
      graph_schema: GraphSchema,
      model_storage: ModelStorage,
      execution_context: ExecutionContext,
      hooks: Optional[List[GraphNodeHook]] = None,
  ) -> None:
      """Initializes a `DaskGraphRunner`.
  
      Args:
          graph_schema: The graph schema that will be run.
          model_storage: Storage which graph components can use to persist and load
              themselves.
          execution_context: Information about the current graph run to be passed to
              each node.
          hooks: These are called before and after the execution of each node.
      """
      self._graph_schema = graph_schema
      self._instantiated_nodes: Dict[
          Text, GraphNode
      ] = self._instantiate_nodes(
          graph_schema, model_storage, execution_context, hooks
      )
      self._execution_context: ExecutionContext = execution_context
  
file_path: rasa/rasa/engine/runner/dask.py
imports: from __future__ import annotations
  import logging
  from typing import Any, Dict, List, Optional, Text
  import dask
  from rasa.engine.exceptions import GraphRunError
  from rasa.engine.graph import ExecutionContext, GraphNode, GraphNodeHook, GraphSchema
  from rasa.engine.runner.interface import GraphRunner
  from rasa.engine.storage.storage import ModelStorage
label_desc: Use image node_id 1 to create a new DaskGraphRunner object from inherited base classes: GraphRunner with example: obj = DaskGraphRunner(graph_schema, model_storage, execution_context, hooks)