Resets a particular function. Use with `params` to reset function with the given parameters. If `params` is not used, `reset(func)` will reset

Resets all functions that are attached to the workflow object that have run at least once.

Invalidate all downstream tasks in a flow. For example, you have 3 dependant tasks. Normally you run Task3 but you've changed parame

Run tasks locally. Runs the DAG sequentially in dependency order. Args: tasks (obj, list): task or list of tasks forced (lis

Set default task for the workflow. The default task is set for all the experiments Args: task(obj) The task to be set as

Return a canonical, deterministic string identifying a task. The id is ``{family}_{param_summary}_{md5(sorted_json)[:10]}`` so that ``ta

The normalized default value. Raises if no default is set.

Get all downstream outputs for a task Args: task (obj): task task_downstream (obj): downstream target task

Get metadata path for a given task and format

Run ``tasks`` and their dependencies sequentially, in dependency order. All state is local to this call, so a task's ``run()`` may itself ca

Common decorator that all decorators use.

Flattened list of required tasks.

Silence d6tflow's internal logging again.

Initialize google cloud storage, for reference see https://cloud.google.com/storage/docs/listing-objects Uses https://gcsfs.readthedocs.io/en

Turn on d6tflow's internal logging. With the default ``sink=sys.stderr`` this gives one clean d6tflow log stream: loguru's pristine default h

Return the set of all tasks on all paths between ``task`` and ``upstream_task_family``.

Get flow by name Args: flow (string): The name of the experiment for which the flow is to be run. If nothing is passed,

Invalidate all tasks by deleting all files in data directory Args: confirm (bool): confirm operation

Invalidate all unused task outputs Args: confirm (bool): confirm operation

Load from in-memory cache Returns: python object

Load from csv to pandas dataframe Args: cached (bool): keep data cached in memory **kwargs: arguments to pas

Load from Excel to pandas dataframe Args: cached (bool): keep data cached in memory **kwargs: arguments to p

Load sheets from Excel file Args: keys (str/list): sheet name(s) to load. None loads all sheets cached (bool

Load from parquet to pandas dataframe Args: cached (bool): keep data cached in memory **kwargs: arguments to

Load from json to dict Args: cached (bool): keep data cached in memory **kwargs: arguments to pass to json.l

Load from markdown file to string Args: cached (bool): keep data cached in memory **kwargs: arguments to pas

Load from pickle to obj Args: cached (bool): keep data cached in memory **kwargs: arguments to pass to pickl

Load saved model Args: cached (bool): keep data cached in memory **kwargs: arguments to pass to pd.read_parq

Contextual logger for task authors; auto-tagged with task identity. Lives in the ``d6tflow`` namespace, so it is silent until ``d6tfl