Import

Load Fabric pipeline JSON and Git item folders into typed models.

fabric_data_pipelines.Pipeline.from_dict classmethod

from_dict(data: dict[str, Any], *, name: str) -> Pipeline

Parse Fabric pipeline-content JSON into a typed pipeline.

The pipeline name is required because Fabric content JSON does not include it (it lives on the item folder / .platform display name).

Unknown activity types become :class:~fabric_data_pipelines.RawActivity.

fabric_data_pipelines.Pipeline.from_json classmethod

from_json(text: str, *, name: str) -> Pipeline

Parse Fabric pipeline JSON text into a typed pipeline.

See :meth:from_dict for naming and typing rules.

fabric_data_pipelines.Pipeline.load_item classmethod

load_item(directory: str | Path) -> Pipeline

Load a Fabric *.DataPipeline Git item folder.

Reads pipeline-content.json, optional .schedules, and logicalId from .platform when present.

fabric_data_pipelines.load_item

load_item(directory: str | Path) -> Pipeline

Load a Fabric *.DataPipeline item folder into a typed :class:Pipeline.

Reads pipeline-content.json, optional .schedules, and logicalId from .platform when present.

fabric_data_pipelines.load_workspace

load_workspace(
    directory: str | Path, *, recursive: bool = True
) -> list[Pipeline]

Load *.DataPipeline item folders under a workspace directory.

Parameters:

Name	Type	Description	Default
directory	str | Path	Workspace root (or any folder that may contain item folders).	required
recursive	bool	When True (default), discover all *.DataPipeline directories under directory via a recursive walk. When False, only immediate children of directory are considered.	True

fabric_data_pipelines.parse_activity

parse_activity(raw: dict[str, Any]) -> Activity

Parse one Fabric activity envelope into a typed model or RawActivity.