Infra
/
lemur
5
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

consistency

This commit is contained in:
Hossein Shafagh 2019-08-13 11:58:58 -07:00
parent 3b9b94623f
commit a3dfc3ef0a
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lemur/common/celery.py
View File

@ -503,18 +503,18 @@ def check_revoked():
This celery task attempts to check if any certs are expired This celery task attempts to check if any certs are expired
:return: :return:
""" """
function = f"{__name__}.{sys._getframe().f_code.co_name}"
task_id = None task_id = None
if celery.current_task: if celery.current_task:
task_id = celery.current_task.request.id task_id = celery.current_task.request.id
function = f"{__name__}.{sys._getframe().f_code.co_name}"
log_data = { log_data = {
"function": function, "function": function,
"message": "check if any certificates are revoked revoked", "message": "check if any certificates are revoked revoked",
"task_id": task_id,
} }
if task_id and is_task_active(function, task_id, (id,)): if task_id and is_task_active(function, task_id, None):
log_data["message"] = "Skipping task: Task is already active" log_data["message"] = "Skipping task: Task is already active"
current_app.logger.debug(log_data) current_app.logger.debug(log_data)
return return