Replaced db.flush with db.commit
To try fix some odd cases of greenlet whining
This commit is contained in:
@@ -49,7 +49,7 @@ async def create(
|
|||||||
color_hex=color_hex,
|
color_hex=color_hex,
|
||||||
)
|
)
|
||||||
db.add(db_item)
|
db.add(db_item)
|
||||||
await db.flush()
|
await db.commit()
|
||||||
return db_item
|
return db_item
|
||||||
|
|
||||||
|
|
||||||
@@ -111,7 +111,7 @@ async def update(
|
|||||||
filament.vendor = await vendor.get_by_id(db, v)
|
filament.vendor = await vendor.get_by_id(db, v)
|
||||||
else:
|
else:
|
||||||
setattr(filament, k, v)
|
setattr(filament, k, v)
|
||||||
await db.flush()
|
await db.commit()
|
||||||
return filament
|
return filament
|
||||||
|
|
||||||
|
|
||||||
@@ -120,7 +120,7 @@ async def delete(db: AsyncSession, filament_id: int) -> None:
|
|||||||
filament = await get_by_id(db, filament_id)
|
filament = await get_by_id(db, filament_id)
|
||||||
await db.delete(filament)
|
await db.delete(filament)
|
||||||
try:
|
try:
|
||||||
await db.flush() # Flush immediately so any errors are propagated in this request.
|
await db.commit() # Flush immediately so any errors are propagated in this request.
|
||||||
except IntegrityError as exc:
|
except IntegrityError as exc:
|
||||||
await db.rollback()
|
await db.rollback()
|
||||||
raise ItemDeleteError("Failed to delete filament.") from exc
|
raise ItemDeleteError("Failed to delete filament.") from exc
|
||||||
|
|||||||
@@ -59,7 +59,7 @@ async def create(
|
|||||||
archived=archived,
|
archived=archived,
|
||||||
)
|
)
|
||||||
db.add(db_item)
|
db.add(db_item)
|
||||||
await db.flush()
|
await db.commit()
|
||||||
return db_item
|
return db_item
|
||||||
|
|
||||||
|
|
||||||
@@ -140,7 +140,7 @@ async def update(
|
|||||||
setattr(spool, k, utc_timezone_naive(v))
|
setattr(spool, k, utc_timezone_naive(v))
|
||||||
else:
|
else:
|
||||||
setattr(spool, k, v)
|
setattr(spool, k, v)
|
||||||
await db.flush()
|
await db.commit()
|
||||||
return spool
|
return spool
|
||||||
|
|
||||||
|
|
||||||
@@ -192,7 +192,7 @@ async def use_weight(db: AsyncSession, spool_id: int, weight: float) -> models.S
|
|||||||
spool.first_used = datetime.utcnow()
|
spool.first_used = datetime.utcnow()
|
||||||
spool.last_used = datetime.utcnow()
|
spool.last_used = datetime.utcnow()
|
||||||
|
|
||||||
await db.flush()
|
await db.commit()
|
||||||
return spool
|
return spool
|
||||||
|
|
||||||
|
|
||||||
@@ -236,5 +236,5 @@ async def use_length(db: AsyncSession, spool_id: int, length: float) -> models.S
|
|||||||
spool.first_used = datetime.utcnow()
|
spool.first_used = datetime.utcnow()
|
||||||
spool.last_used = datetime.utcnow()
|
spool.last_used = datetime.utcnow()
|
||||||
|
|
||||||
await db.flush()
|
await db.commit()
|
||||||
return spool
|
return spool
|
||||||
|
|||||||
@@ -21,7 +21,7 @@ async def create(
|
|||||||
comment=comment,
|
comment=comment,
|
||||||
)
|
)
|
||||||
db.add(db_item)
|
db.add(db_item)
|
||||||
await db.flush()
|
await db.commit()
|
||||||
return db_item
|
return db_item
|
||||||
|
|
||||||
|
|
||||||
@@ -57,7 +57,7 @@ async def update(
|
|||||||
vendor = await get_by_id(db, vendor_id)
|
vendor = await get_by_id(db, vendor_id)
|
||||||
for k, v in data.items():
|
for k, v in data.items():
|
||||||
setattr(vendor, k, v)
|
setattr(vendor, k, v)
|
||||||
await db.flush()
|
await db.commit()
|
||||||
return vendor
|
return vendor
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user