Skip to content

Commit

Permalink
lint
Browse files Browse the repository at this point in the history
  • Loading branch information
michalkrzem committed Feb 20, 2025
1 parent 5362cbd commit 98b2092
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 4 deletions.
3 changes: 1 addition & 2 deletions src/app.py
Original file line number Diff line number Diff line change
Expand Up @@ -617,8 +617,7 @@ def add_files_to_queue(
)
def get_queue_status(ursadb_id: str):
queue_status = db.get_queue_info(ursadb_id)
logging.error(queue_status)
logging.error(type(queue_status))

return QueueStatusSchema(
ursadb_id=ursadb_id,
size=queue_status.size,
Expand Down
6 changes: 4 additions & 2 deletions src/db.py
Original file line number Diff line number Diff line change
Expand Up @@ -510,14 +510,16 @@ def get_queue_info(self, ursadb_id: str) -> QueueStatusDatabaseSchema:
func.min(QueuedFile.created_at),
func.max(QueuedFile.created_at),
).where(QueuedFile.ursadb_id == ursadb_id)
queue_info = session.exec(query).one()
queue_info = session.exec(query).first()

return QueueStatusDatabaseSchema(
queue_status = QueueStatusDatabaseSchema(
size=queue_info[0],
oldest_file=queue_info[1],
newest_file=queue_info[2],
)

return queue_status

def delete_queued_files(self, ursadb_id: str) -> None:
with self.session() as session:
session.query(QueuedFile).filter_by(ursadb_id=ursadb_id).delete()
Expand Down

0 comments on commit 98b2092

Please sign in to comment.