in repos/features_ingestion_pipeline/pipelines/parse_flow.py [0:0]
def __init__(self, file_path: Union[str, Path]) -> None:
if not isinstance(file_path, Path):
file_path = Path(file_path)
with file_path.open("r") as data:
self._flow = json.load(data)