Registry

dataphy.sources.registry

Functions

fetch_dataset(provider: str, source: Dict[str, Any], output_dir: str, include: str, runner: str = 'DirectRunner')

Source code in src/dataphy/sources/registry.py

def fetch_dataset(provider: str, source: Dict[str, Any], output_dir: str, include: str, runner: str = "DirectRunner"):
    if provider not in _REG:
        raise ValueError(f"Unknown provider: {provider}")
    return _REG[provider](source=source, output_dir=output_dir, include=include, runner=runner)