Update celery.py
This commit is contained in:
parent
f38e5b0879
commit
c445297357
|
@ -238,7 +238,7 @@ def sync_source(source):
|
||||||
:return:
|
:return:
|
||||||
"""
|
"""
|
||||||
|
|
||||||
function = f"{__name__}.{sys._getframe().f_code.co_name}"
|
function = "{}.{}".format(__name__, sys._getframe().f_code.co_name)
|
||||||
task_id = celery.current_task.request.id
|
task_id = celery.current_task.request.id
|
||||||
log_data = {
|
log_data = {
|
||||||
"function": function,
|
"function": function,
|
||||||
|
|
Loading…
Reference in New Issue