Functional Flow class that acts as a manager of all flow steps. Defines all the decorators that can be used on flow functions.

Raised when a required parameter has no value and no default.

Contextual logger facade returned by ``Task.logger``. Two things make it behave like the rest of d6tflow's logging: * It pre-binds the task'

Raised when an unknown parameter is supplied to a task.

Raised when a parameter is supplied both positionally and as a keyword.

Base parameter exception.

Small result object consumed by ``d6tflow.run``.

The class is used to orchestrate tasks and define a task pipeline

dot.notation access to dictionary attributes

Copy parameters (and nothing else) from one or more task classes onto the decorated task, and add ``clone_parent``/``clone_parents`` helpers.

A Parameter whose value is a ``bool``. Has an implicit default of ``False``.

Saves to CSV gzip, loads to pandas dataframe

Saves to CSV, loads to pandas dataframe

Saves to in-memory cache, loads to python object

Local target which saves in-memory data (eg dataframes) to persistent storage (eg files) and loads from storage to memory This is an abstrac

Parameter whose value is a :py:class:`~datetime.date`, formatted ``YYYY-MM-DD``.

Parameter whose value is a ``dict``. The value is stored as-is (no freezing); it is serialized with sorted keys so that the task id stay

A parameter whose value is an :class:`~enum.Enum`. Pass the enum class via ``enum=``:: class Model(enum.Enum): Honda = 1

Saves dict of dataframes as sheets in a single Excel file, loads selectively by sheet

Saves to Excel, loads to pandas dataframe

Parameter whose value is a ``float``.

Auto generate task files to quickly share workflows with others. Args: tasks (obj): task or list of tasks to share flows (ob

Import a specific module from a directory. Args: path (str): path to the dir to import from module (str): the module name to

Parameter whose value is an ``int``.

Saves to json, loads to dict

Parameter whose value is a ``list``. The value is stored as-is (no freezing); it is serialized as JSON so that the task id stays determi

Tiny local target base. ``self.path`` is stored as-is (NOT coerced to ``str``); subclasses (``CacheTarget``/``_LocalPathTarget``) overri

Saves to markdown (.md) and HTML (.html), loads markdown string

Parameter whose value is a ``str``, and the base class for the other parameter types. Parameters are set on the Task class to parameterize t

Saves to pickle, loads to python obj