SA threads tests

import os

def create_db_engine(db_url, **kwargs):
    return create_engine(
        url=db_url, future=True, **kwargs
    )

from sqlalchemy import create_engine

from sqlalchemy.orm import scoped_session, sessionmaker


engine = create_db_engine(os.environ.get("TEST_DATABASE_URL"), isolation_level="AUTOCOMMIT")

SessionLocal = sessionmaker(
    autocommit=False, autoflush=False, bind=engine, future=True, expire_on_commit=False
)

import concurrent.futures
from app.db import transaction


def worker():
    db = SessionLocal()
    with transaction(db):
        db.execute("select 1")
        print(db.connection().connection.connection)


with concurrent.futures.ThreadPoolExecutor() as exec:
    f1 = exec.submit(worker)
    f2 = exec.submit(worker)