Core Dagster error classes.
All errors thrown by the Dagster framework inherit from
should not subclass this base class for their own exceptions.
Dagster uses this construct to wrap user code into which it calls. User code can perform arbitrary
computations and may itself throw exceptions. The error boundary catches these user code-generated
exceptions, and then reraises them wrapped in a subclass of
The wrapped exceptions include additional context for the original exceptions, injected by the Dagster runtime.
Base class for all errors thrown by the Dagster framework.
Users should not subclass this base class for their own exceptions.
Indicates that an unexpected error occurred while executing the body of a config mapping
function defined in a
JobDefinition or ~dagster.GraphDefinition during
Raised when the event logs for a historical run are malformed or invalid.
Indicates an error occurred while executing the body of an execution step.
Thrown when the user specifies execution step keys that do not exist.
DagsterInvalidConfigError(preamble, errors, config_value, *args, **kwargs)¶
Thrown when provided config is invalid (does not type check against the relevant config schema).
DagsterInvalidConfigDefinitionError(original_root, current_value, stack, reason=None, **kwargs)¶
Indicates that you have attempted to construct a config with an invalid value
Shape. Values of the dictionary are resolved recursively
according to the same rules.
Array with list element as an argument.
An instance of
Indicates that the rules for a definition have been violated by the user.
Indicates the user has violated a well-defined invariant that can only be enforced at runtime.
Indicates an error occurred while executing the body of the
resource_fn in a
ResourceDefinition during resource initialization.
Thrown when a run cannot be found in run storage.
Indicates that previous step outputs required for an execution step to proceed are not available.
An exception has occurred in one or more of the child processes dagster manages. This error forwards the message and stack trace for all of the collected errors.
DagsterTypeCheckDidNotPass(description=None, metadata_entries=None, dagster_type=None)¶
Indicates that a type check failed.
This is raised when
True in calls to the synchronous job and
graph execution APIs (e.g. graph.execute_in_process(), job.execute_in_process() – typically
within a test), and a
DagsterType’s type check fails by returning either
False or an instance of
success member is
Indicates an error in the op type system at runtime. E.g. a op receives an unexpected input, or produces an output that does not match the type of the output definition.
DagsterUnknownResourceError(resource_name, *args, **kwargs)¶
Indicates that an unknown resource was accessed in the body of an execution step. May often happen by accessing a resource in the compute function of an op without first supplying the op with the correct required_resource_keys argument.
Indicates the resolved executor is incompatible with the state of other systems
such as the
DagsterInstance or system storage configuration.
This is the base class for any exception that is meant to wrap an
Exception thrown by user code. It wraps that existing user code.
original_exc_info argument to the constructor is meant to be a tuple of the type
sys.exc_info at the call site of the constructor.
Users should not subclass this base class for their own exceptions and should instead throw freely from user code. User exceptions will be automatically wrapped and rethrown.