repro2.py

#!/usr/bin/env python3

import sqlalchemy as sa
from sqlalchemy.ext.declarative import declarative_base
import sqlalchemy.orm
from sqlalchemy_utils import create_database
from cockroachdb.sqlalchemy import run_transaction
import logging

logging.basicConfig(level=logging.DEBUG)
logging.getLogger('sqlalchemy').setLevel(level=logging.DEBUG)
logging.getLogger('sqlalchemy.orm').setLevel(level=logging.DEBUG)

_engine = sqlalchemy.create_engine('cockroachdb://root@127.0.0.1:26257/test8', echo=False)
_session_factory = sqlalchemy.orm.sessionmaker(bind=_engine)

try:
    create_database(_engine.url)
except Exception:
    pass

Base = declarative_base()

class ConfigItem(Base):

    __tablename__ = 'configs'

    id = sa.Column(sa.Integer, primary_key=True)
    key = sa.Column(sa.String, unique=True)
    value = sa.Column(sa.String)

Base.metadata.create_all(_engine)

def callback(conn):
    item=ConfigItem(key='some-key', value='some-value')
    conn.add(item)
    conn.commit()

run_transaction(_session_factory, callback)