a simple version using ``multiprocessing.Process``, but this idea
should be adapted to the style of forking in use::
- eng = create_engine("...")
+ engine = create_engine("...")
def run_in_process():
- eng.dispose()
+ engine.dispose()
- with eng.connect() as conn:
+ with engine.connect() as conn:
conn.execute("...")
p = Process(target=run_in_process)
from sqlalchemy import exc
import os
- eng = create_engine("...")
+ engine = create_engine("...")
@event.listens_for(engine, "connect")
def connect(dbapi_connection, connection_record):