|
|
|
@ -12,12 +12,9 @@
|
|
|
|
|
#
|
|
|
|
|
# You should have received a copy of the GNU General Public License along
|
|
|
|
|
# with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
|
import logging
|
|
|
|
|
import os
|
|
|
|
|
|
|
|
|
|
import structlog
|
|
|
|
|
from celery import Celery
|
|
|
|
|
from celery.signals import setup_logging
|
|
|
|
|
from django_structlog.celery.steps import DjangoStructLogInitStep
|
|
|
|
|
|
|
|
|
|
# set the default Django settings module for the 'celery' program.
|
|
|
|
@ -35,59 +32,6 @@ app.config_from_object("repoapi.conf:settings", namespace="CELERY")
|
|
|
|
|
app.autodiscover_tasks()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@setup_logging.connect
|
|
|
|
|
def receiver_setup_logging(loglevel, logfile, format, colorize, **kwargs):
|
|
|
|
|
logging.config.dictConfig(
|
|
|
|
|
{
|
|
|
|
|
"version": 1,
|
|
|
|
|
"disable_existing_loggers": False,
|
|
|
|
|
"formatters": {
|
|
|
|
|
"plain_console": {
|
|
|
|
|
"()": structlog.stdlib.ProcessorFormatter,
|
|
|
|
|
"processor": structlog.dev.ConsoleRenderer(),
|
|
|
|
|
},
|
|
|
|
|
},
|
|
|
|
|
"handlers": {
|
|
|
|
|
"console": {
|
|
|
|
|
"class": "logging.StreamHandler",
|
|
|
|
|
"formatter": "plain_console",
|
|
|
|
|
}
|
|
|
|
|
},
|
|
|
|
|
"loggers": {
|
|
|
|
|
"django_structlog": {
|
|
|
|
|
"handlers": ["console"],
|
|
|
|
|
"level": "INFO",
|
|
|
|
|
},
|
|
|
|
|
"celery": {
|
|
|
|
|
"handlers": ["console"],
|
|
|
|
|
"level": "INFO",
|
|
|
|
|
},
|
|
|
|
|
"repoapi": {
|
|
|
|
|
"handlers": ["console"],
|
|
|
|
|
"level": os.getenv("DJANGO_LOG_LEVEL", "INFO"),
|
|
|
|
|
},
|
|
|
|
|
},
|
|
|
|
|
}
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
structlog.configure(
|
|
|
|
|
processors=[
|
|
|
|
|
structlog.contextvars.merge_contextvars,
|
|
|
|
|
structlog.stdlib.filter_by_level,
|
|
|
|
|
structlog.stdlib.add_logger_name,
|
|
|
|
|
structlog.stdlib.add_log_level,
|
|
|
|
|
structlog.stdlib.PositionalArgumentsFormatter(),
|
|
|
|
|
structlog.processors.StackInfoRenderer(),
|
|
|
|
|
structlog.processors.format_exc_info,
|
|
|
|
|
structlog.processors.UnicodeDecoder(),
|
|
|
|
|
structlog.processors.ExceptionPrettyPrinter(),
|
|
|
|
|
structlog.stdlib.ProcessorFormatter.wrap_for_formatter,
|
|
|
|
|
],
|
|
|
|
|
logger_factory=structlog.stdlib.LoggerFactory(),
|
|
|
|
|
cache_logger_on_first_use=True,
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@app.task()
|
|
|
|
|
def jbi_parse_hotfix(jbi_id: str, path: str):
|
|
|
|
|
app.send_task("hotfix.tasks.hotfix_released", args=[jbi_id, path])
|
|
|
|
|