From 95681b70e05b362d89781eb85ed1ee6ea229dfbc Mon Sep 17 00:00:00 2001 From: Aevann1 Date: Mon, 20 Sep 2021 21:43:50 +0200 Subject: [PATCH] fsdfs --- files/__main__.py | 31 ++----------------------------- 1 file changed, 2 insertions(+), 29 deletions(-) diff --git a/files/__main__.py b/files/__main__.py index 50d14d934..ba60b4f3f 100644 --- a/files/__main__.py +++ b/files/__main__.py @@ -9,7 +9,7 @@ from flask_compress import Compress from flask_limiter.util import get_ipaddr from flaskext.markdown import Markdown from sqlalchemy.ext.declarative import declarative_base -from sqlalchemy.orm import sessionmaker, scoped_session, Query as _Query +from sqlalchemy.orm import sessionmaker, scoped_session from sqlalchemy import * from sqlalchemy.pool import QueuePool import gevent @@ -83,37 +83,10 @@ _engine=create_engine( pool_use_lifo=True ) -def retry(f): - - def wrapper(self, *args, **kwargs): - try: - return f(self, *args, **kwargs) - except: - self.session.rollback() - return f(self, *args, **kwargs) - - wrapper.__name__=f.__name__ - return wrapper - - -class RetryingQuery(_Query): - - @retry - def all(self): - return super().all() - - @retry - def count(self): - return super().count() - - @retry - def first(self): - return super().first() - Base = declarative_base() -db_session = scoped_session(sessionmaker(bind=_engine, query_cls=RetryingQuery)) +db_session = scoped_session(sessionmaker(engine)) @app.before_request