fxreader.online/freelance-project-34-marketing-blog
2
0
Fork 0
Code Issues 2 Pull Requests Actions Packages Projects Releases Wiki Activity

[~] Refactor

Browse Source
This commit is contained in:
Siarhei Siniak 2024-07-07 00:56:49 +03:00
parent 94e3d90df2
commit e3557ff8fd
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
python/tasks/tiktok/utils.py
View File

@ -85,6 +85,7 @@ class Backend(celery.backends.redis.RedisBackend):
*args, *args,
task_id: Optional[str]=None, task_id: Optional[str]=None,
state: Optional[str]=None, state: Optional[str]=None,
request: Optional[Any]=None,
**kwargs **kwargs
): ):
current_meta = None current_meta = None
@ -92,7 +93,13 @@ class Backend(celery.backends.redis.RedisBackend):
if not task_id is None: if not task_id is None:
current_meta = self._get_task_meta_for(task_id) current_meta = self._get_task_meta_for(task_id)
res = super()._get_result_meta(*args, state=state, **kwargs) res = super()._get_result_meta(*args, state=state, request=request, **kwargs)
if not request is None:
import pprint
print(request)
if not '_task_name' in res:
res['_task_name'] = request.task
if state == celery.states.STARTED: if state == celery.states.STARTED:
if not 'date_started' in res: if not 'date_started' in res:
@ -102,7 +109,7 @@ class Backend(celery.backends.redis.RedisBackend):
if not '_date_done' in res: if not '_date_done' in res:
res['_date_done'] = datetime.datetime.now() res['_date_done'] = datetime.datetime.now()
for k in ['date_started', '_date_done',]: for k in ['date_started', '_date_done', '_task_name']:
if k in current_meta: if k in current_meta:
res[k] = current_meta[k] res[k] = current_meta[k]