-
Notifications
You must be signed in to change notification settings - Fork 8
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Update anonlink to v0.12.5 #423
Conversation
Looks like a few changes are required... |
82380cd
to
d071ae7
Compare
3d1a9b2
to
a34c657
Compare
logger.info("Setting up entityservice worker") | ||
logger.debug("Debug logging enabled") | ||
|
||
|
||
@worker_process_init.connect() | ||
def init_worker(**kwargs): | ||
db_min_connections = Config.CELERY_DB_MIN_CONNECTIONS | ||
db_max_connections = Config.CELERY_DB_MAX_CONNECTIONS | ||
init_db_pool(db_min_connections, db_max_connections) | ||
logger.info("Setting up worker process") | ||
logger.debug("Debug logging enabled") | ||
|
||
|
||
@worker_process_shutdown.connect() | ||
def shutdown_worker(**kwargs): | ||
close_db_pool() | ||
logger.info("Shutting down a worker process") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Unrelated change: I moved these logs into the worker signal handlers as I saw the flask application was also logging them at import time.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
👍
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
All good to go.
logger.info("Setting up entityservice worker") | ||
logger.debug("Debug logging enabled") | ||
|
||
|
||
@worker_process_init.connect() | ||
def init_worker(**kwargs): | ||
db_min_connections = Config.CELERY_DB_MIN_CONNECTIONS | ||
db_max_connections = Config.CELERY_DB_MAX_CONNECTIONS | ||
init_db_pool(db_min_connections, db_max_connections) | ||
logger.info("Setting up worker process") | ||
logger.debug("Debug logging enabled") | ||
|
||
|
||
@worker_process_shutdown.connect() | ||
def shutdown_worker(**kwargs): | ||
close_db_pool() | ||
logger.info("Shutting down a worker process") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
👍
No description provided.