darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-09-09 17:45:41 -04:00
Code Issues Packages Projects Releases Wiki Activity

remove result_expires

Browse Source
This commit is contained in:
Kenneth Kehl
2024-12-19 14:11:08 -08:00
parent cfe9b11cf6 7c7f96d144
commit 6134530719
3 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
app/__init__.py
View File

@@ -1,3 +1,4 @@
import logging as real_logging
import os import os
import secrets import secrets
import string import string
@@ -36,6 +37,9 @@ class NotifyCelery(Celery):
# Configure Celery app with options from the main app config. # Configure Celery app with options from the main app config.
self.config_from_object(app.config["CELERY"]) self.config_from_object(app.config["CELERY"])
self.conf.worker_hijack_root_logger = False
logger = real_logging.getLogger("celery")
logger.propagate = False
def send_task(self, name, args=None, kwargs=None, **other_kwargs): def send_task(self, name, args=None, kwargs=None, **other_kwargs):
other_kwargs["headers"] = other_kwargs.get("headers") or {} other_kwargs["headers"] = other_kwargs.get("headers") or {}

1
app/config.py
View File

@@ -169,7 +169,6 @@ class Config(object):
CELERY = { CELERY = {
"worker_max_tasks_per_child": 500, "worker_max_tasks_per_child": 500,
"task_ignore_result": True, "task_ignore_result": True,
"result_expires": 0,
"result_persistent": False, "result_persistent": False,
"broker_url": REDIS_URL, "broker_url": REDIS_URL,
"broker_transport_options": { "broker_transport_options": {

2
notifications_utils/logging.py
View File

@@ -70,10 +70,12 @@ def init_app(app):
for logger_instance, handler in product(loggers, handlers): for logger_instance, handler in product(loggers, handlers):
logger_instance.addHandler(handler) logger_instance.addHandler(handler)
logger_instance.setLevel(loglevel) logger_instance.setLevel(loglevel)
logger_instance.propagate = False
warning_loggers = [logging.getLogger("boto3"), logging.getLogger("s3transfer")] warning_loggers = [logging.getLogger("boto3"), logging.getLogger("s3transfer")]
for logger_instance, handler in product(warning_loggers, handlers): for logger_instance, handler in product(warning_loggers, handlers):
logger_instance.addHandler(handler) logger_instance.addHandler(handler)
logger_instance.setLevel(logging.WARNING) logger_instance.setLevel(logging.WARNING)
logger_instance.propagate = False
# Suppress specific loggers to prevent leaking sensitive info # Suppress specific loggers to prevent leaking sensitive info
logging.getLogger("boto3").setLevel(logging.ERROR) logging.getLogger("boto3").setLevel(logging.ERROR)