Merge pull request #14 from jludwig/fix-update-sqlalchemy-support
Update: SQLAlchemy and PostgreSQL Compatibility Enhancements
This commit is contained in:
commit
e69f5c182a
|
|
@ -5,3 +5,4 @@ aiohttp_jinja2
|
||||||
aiohttp
|
aiohttp
|
||||||
sqlalchemy
|
sqlalchemy
|
||||||
logbook
|
logbook
|
||||||
|
psycopg2-binary
|
||||||
|
|
|
||||||
|
|
@ -60,7 +60,7 @@ class Consumer:
|
||||||
await asyncio.gather(*fetches)
|
await asyncio.gather(*fetches)
|
||||||
session.commit()
|
session.commit()
|
||||||
|
|
||||||
jobs = [self.process_job(job, session) for job in session.query(Job).options(joinedload('user'))]
|
jobs = [self.process_job(job, session) for job in session.query(Job).options(joinedload(Job.user))]
|
||||||
await asyncio.gather(*jobs)
|
await asyncio.gather(*jobs)
|
||||||
session.commit()
|
session.commit()
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -28,8 +28,8 @@ class Job(Base):
|
||||||
id = Column(Integer, primary_key=True, autoincrement=True)
|
id = Column(Integer, primary_key=True, autoincrement=True)
|
||||||
article = Column(Integer)
|
article = Column(Integer)
|
||||||
title = Column(String)
|
title = Column(String)
|
||||||
user_name = Column(Integer, ForeignKey("user.name"))
|
user_name = Column(String, ForeignKey("user.name"))
|
||||||
format = Column(Enum('pdf', 'mobi', 'epub'))
|
format = Column(Enum('pdf', 'mobi', 'epub', name='format_enum'))
|
||||||
|
|
||||||
|
|
||||||
class ContextSession:
|
class ContextSession:
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue