Skip to main content

datasource

Datasource helper utilities for steps.

Module​

Functions​

resolve_output_path​

def resolve_output_path(    datasource: BaseSource,) ‑> str:

Resolve the output directory for reports.

Looks for datasource.out_path (the datasource's configured output_path kwarg, or settings.paths.cache_dir by default). Falls back to <cwd>/prefect_reports if unavailable.

use_default_rename_columns​

def use_default_rename_columns(    datasource: Any, rename_columns: collections.abc.Mapping[str, str] | None = None,) ‑> collections.abc.Mapping[str, str] | None:

Sets the default columns to include based on the datasource.