ScriptRun.as_dask

ScriptRun.as_dask(overwrite=False, overwrite_dependencies=False, catch=False)[source]

Schedules this script and its dependencies on dask

Parameters
  • overwrite – whether to submit the script even if output already exists

  • overwrite_dependencies – whether to submit dependencies even if their output already exists

  • catch – if True catches any error

Returns

dask Delayed job object