Source code for sqltrack.engines

from .engine import Engine
from .postgres import PostgresEngine
from .sqlite import SQLiteEngine


[docs]def create_engine(config: dict) -> Engine:
    engine = config["engine"]
    if engine == "postgres":
        return PostgresEngine(config)
    elif engine == "sqlite":
        return SQLiteEngine(config)
    else:
        raise ValueError(f"unknown engine type {engine!r}")