Skip to content

Errors

aio-fluid defines two error hierarchies: one for general utilities and one for the task scheduler.

Utility errors

from fluid.utils.errors import FluidError, FluidValueError, ValidationError, WorkerStartError

fluid.utils.errors.FluidError

Bases: Exception

Base class for all Fluid Trading errors.

fluid.utils.errors.FluidValueError

Bases: ValueError, FluidError

Quant Value Error

fluid.utils.errors.ValidationError 

ValidationError(
    field, msg="", field_type="string", value=None
)

Bases: FluidValueError

Validation Error

Source code in fluid/utils/errors.py 
15
16
17
18
19
20
21
def __init__(
    self, field: str, msg: str = "", field_type: str = "string", value: Any = None
):
    self.field = field
    self.field_type = field_type
    self.msg = msg or "validation error"
    self.value = value

field instance-attribute 

field = field

field_type instance-attribute 

field_type = field_type

msg instance-attribute 

msg = msg or 'validation error'

value instance-attribute 

value = value

fluid.utils.errors.WorkerStartError

Bases: FluidError

Worker start error

fluid.utils.errors.FlamegraphError

Bases: FluidError

Raised when flamegraph generation fails.

Task scheduler errors

from fluid.scheduler.errors import TaskError, UnknownTaskError, DisabledTaskError

fluid.scheduler.errors.TaskError

Bases: RuntimeError

Base class for all task scheduler errors.

fluid.scheduler.errors.UnknownTaskError

Bases: TaskError

Raised when a task name is not registered in the task registry.

fluid.scheduler.errors.DisabledTaskError

Bases: TaskError

Raised when attempting to queue or run a disabled task.

fluid.scheduler.errors.TaskRunError

Bases: TaskError

Raised when a task run fails during execution.

This is an internal error used to signal a failure during task execution, and is not intended to be raised by user code.

fluid.scheduler.errors.TaskAbortedError

Bases: TaskError

Raised when a task run is aborted before completion.

If a task needs to abort itself it can raise this error, which will be caught by the consumer and treated as a soft-failure and therefore logged as info and not trigger any retry policy if configured.

fluid.scheduler.errors.TaskDecoratorError

Bases: TaskError

Raised when a task is incorrectly decorated or configured.