upgrade_targets

etl_craft.services.upgrade_targets

Add nullable pipeline and task-run identities to configured SQL and ingestion targets.

UpgradeResult dataclass

One existing target, with its additions or already-upgraded outcome.

upgrade_targets

upgrade_targets(engine: Engine, config: ConnectorConfig, *, action: str | None = None, target: str | None = None, dry_run: bool = False) -> list[UpgradeResult]

Upgrade configured targets under their mutation locks; preserve historical rows.