Shared toolbox for our pipelines.
- Logging conventions.
- Queue / Daemon classes.
- TransactionsDB (a generic way of persisting state through our pipelines).
- Data cleaner (a tool to periodically clean data on folders).
Add an entry in migrate.py, and then change the version number in constants.py
E.g. we want to run programmatic migration number 5 manually:
from mediaire_toolbox.transaction_db.transaction_db import migrate_scripts
from mediaire_toolbox.transaction_db.transaction_db import TransactionDB
from sqlalchemy import create_engine
engine = create_engine('sqlite:///t.db')
t_db = TransactionDB(engine)
migrate_scripts(t_db.session, engine, 4, 5)