code: def dask_xarray_pipeline(
      glyph,
      xr_ds,
      schema,
      canvas,
      summary,
      *,
      antialias=False,
      cuda=False,
  ):
      dsk, name = dask_glyph_dispatch(
          glyph,
          xr_ds,
          schema,
          canvas,
          summary,
          antialias=antialias,
          cuda=cuda,
      )
  
      # Get user configured scheduler (if any), or fall back to default
      # scheduler for dask DataFrame
      scheduler = dask.base.get_scheduler() or xr_ds.__dask_scheduler__
      keys = xr_ds.__dask_keys__()
      optimize = xr_ds.__dask_optimize__
      graph = xr_ds.__dask_graph__()
  
      dsk.update(optimize(graph, keys))
  
      return scheduler(dsk, name)
  
file_path: datashader/datashader/data_libraries/dask_xarray.py
imports: from datashader.compiler import compile_components
  from datashader.utils import Dispatcher
  from datashader.glyphs.line import LinesXarrayCommonX
  from datashader.glyphs.quadmesh import QuadMeshRaster, QuadMeshRectilinear, QuadMeshCurvilinear, build_scale_translate
  from datashader.utils import apply
  import dask
  import numpy
  import xarray
  from dask.base import tokenize, compute
  from dask.array.overlap import overlap
label_desc: Use image node_id 1 for calling a global function with example usage: dask_xarray_pipeline(glyph, xr_ds, schema, canvas, summary) and returns: scheduler