oscar.krause/fastapi-dls
2
3
Fork 1
Code Issues 5 Pull Requests Releases Activity

fixed updates

Browse Source
This commit is contained in:
Oscar Krause 2022-12-23 08:16:58 +01:00
parent d1db441df4
commit e7102c4de6
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
app/orm.py
View File

@ -55,7 +55,13 @@ class Origin(Base):
if entity is None: if entity is None:
session.add(origin) session.add(origin)
else: else:
session.execute(update(Origin).where(Origin.origin_ref == origin.origin_ref).values(**origin.values())) values = dict(
hostname=origin.hostname,
guest_driver_version=origin.guest_driver_version,
os_platform=origin.os_platform,
os_version=origin.os_version,
)
session.execute(update(Origin).where(Origin.origin_ref == origin.origin_ref).values(values))
session.flush() session.flush()
session.close() session.close()
@ -104,7 +110,8 @@ class Lease(Base):
if entity is None: if entity is None:
session.add(lease) session.add(lease)
else: else:
session.execute(update(Lease).where(and_(Lease.origin_ref == lease.origin_ref, Lease.lease_ref == lease.lease_ref)).values(**lease.values())) values = dict(lease_expires=lease.lease_expires, lease_updated=lease.lease_updated)
session.execute(update(Lease).where(and_(Lease.origin_ref == lease.origin_ref, Lease.lease_ref == lease.lease_ref)).values(values))
session.flush() session.flush()
session.close() session.close()
@ -125,9 +132,8 @@ class Lease(Base):
@staticmethod @staticmethod
def renew(engine: Engine, lease: "Lease", lease_expires: datetime.datetime, lease_updated: datetime.datetime): def renew(engine: Engine, lease: "Lease", lease_expires: datetime.datetime, lease_updated: datetime.datetime):
session = sessionmaker(autocommit=True, autoflush=True, bind=engine)() session = sessionmaker(autocommit=True, autoflush=True, bind=engine)()
lease.lease_expires = lease_expires values = dict(lease_expires=lease.lease_expires, lease_updated=lease.lease_updated)
lease.lease_updated = lease_updated session.execute(update(Lease).where(and_(Lease.origin_ref == lease.origin_ref, Lease.lease_ref == lease.lease_ref)).values(values))
session.execute(update(Lease).where(and_(Lease.origin_ref == lease.origin_ref, Lease.lease_ref == lease.lease_ref)).values(**lease.values()))
session.close() session.close()
@staticmethod @staticmethod