dlt._workspace.helpers.dashboard.utils.pipeline
Pipeline info, config resolution, destination details, and misc pipeline helpers.
get_dashboard_config_sections
def get_dashboard_config_sections(
p: Optional[dlt.Pipeline]) -> Tuple[str, ...]
Find dashboard config section layout for a particular pipeline or for active run context type.
resolve_dashboard_config
def resolve_dashboard_config(
p: Optional[dlt.Pipeline]) -> DashboardConfiguration
Resolve the dashboard configuration
get_pipeline
def get_pipeline(pipeline_name: str, pipelines_dir: str) -> dlt.Pipeline
Get a pipeline by name. Attach exceptions must be handled by the caller.
get_destination_config
def get_destination_config(
pipeline: dlt.Pipeline) -> DestinationClientConfiguration
Get the destination config of a pipeline.
pipeline_details
def pipeline_details(c: DashboardConfiguration, pipeline: dlt.Pipeline,
pipelines_dir: str) -> List[TNameValueItem]
Get the details of a pipeline as name/value table items.
remote_state_details
def remote_state_details(pipeline: dlt.Pipeline) -> List[TNameValueItem]
Get the remote state details of a pipeline.
get_local_data_path
def get_local_data_path(pipeline: dlt.Pipeline) -> str
Get the local data path of a pipeline
open_local_folder
def open_local_folder(folder: str) -> None
Open a folder in the file explorer
pipeline_link_list
def pipeline_link_list(config: DashboardConfiguration,
pipelines: List[TPipelineListItem]) -> str
Build a markdown list of links to pipelines.
exception_section
def exception_section(p: dlt.Pipeline) -> List[mo.Html]
Build an exception section for a pipeline
sanitize_trace_for_display
def sanitize_trace_for_display(trace: PipelineTrace) -> Dict[str, Any]
Sanitize a trace for display by cleaning up non-primitive keys.