V
Size: a a a
V
T
T
T
app = create_celery_app()
register_tasks(app)
@worker_init.connect()
def worker_init_config(**kwargs):
if hasattr(current_app, "Session"):
return # workaround for threaded workers sharing single app
current_app.Session = create_session_factory()
AA
T
T
AA
T
T
T
J(
BR
T
J(
QL
J(
QL
A