Skip to content
This repository has been archived by the owner on Jul 2, 2024. It is now read-only.

Commit

Permalink
Merge pull request #2 from ewhauser/rename-sqlcdriver
Browse files Browse the repository at this point in the history
fix: rename sqlcdriver to sqlalchemy driver
  • Loading branch information
ewhauser authored Jun 10, 2024
2 parents 333f681 + 3120d3c commit 144ade0
Show file tree
Hide file tree
Showing 8 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
from . import river_job, pg_misc


class SqlcDriver(Driver):
class SqlAlchemyDriver(Driver):
def __init__(self, session):
self.session = session
self.pg_misc_querier = pg_misc.Querier(session)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

from riverqueue.client import Client
from riverqueue.models import InsertOpts, UniqueOpts
from riverqueue.drivers.sqlcdb.sqlc_driver import SqlcDriver
from riverqueue.drivers.sqlalchemy.sqlalchemy_driver import SqlAlchemyDriver
from client_test import SimpleArgs
from sqlalchemy import text

Expand All @@ -14,7 +14,7 @@
def driver(engine):
with engine.begin() as conn:
conn.execute(text("SET search_path TO public"))
yield SqlcDriver(conn)
yield SqlAlchemyDriver(conn)


@pytest.fixture
Expand Down

0 comments on commit 144ade0

Please sign in to comment.