mirror of
https://github.com/jumpserver/jumpserver.git
synced 2025-12-15 08:32:48 +00:00
Compare commits
21 Commits
dev-fce
...
v3.10.8-lt
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
23874460da | ||
|
|
913c0d140d | ||
|
|
60d9db7707 | ||
|
|
f20b9e01ab | ||
|
|
8cf8a3701b | ||
|
|
7ba24293d1 | ||
|
|
f10114c9ed | ||
|
|
cf31cbfb07 | ||
|
|
0edad24d5d | ||
|
|
1f1c1a9157 | ||
|
|
6c9d271ae1 | ||
|
|
6ff852e225 | ||
|
|
baa75dc735 | ||
|
|
8a9f0436b8 | ||
|
|
a9620a3cbe | ||
|
|
769e7dc8a0 | ||
|
|
2a70449411 | ||
|
|
8df720f19e | ||
|
|
dabbb45f6e | ||
|
|
ce24c1c3fd | ||
|
|
3c54c82ce9 |
@@ -134,9 +134,10 @@ def task_sent_handler(headers=None, body=None, **kwargs):
|
||||
args, kwargs, __ = body
|
||||
|
||||
try:
|
||||
args = list(args)
|
||||
args = json.loads(json.dumps(list(args), cls=JSONEncoder))
|
||||
kwargs = json.loads(json.dumps(kwargs, cls=JSONEncoder))
|
||||
except Exception as e:
|
||||
logger.error('Parse task args or kwargs error (Need handle): {}'.format(e))
|
||||
args = []
|
||||
kwargs = {}
|
||||
|
||||
@@ -151,11 +152,13 @@ def task_sent_handler(headers=None, body=None, **kwargs):
|
||||
request = get_current_request()
|
||||
if request and request.user.is_authenticated:
|
||||
data['creator'] = request.user
|
||||
try:
|
||||
CeleryTaskExecution.objects.create(**data)
|
||||
except Exception as e:
|
||||
logger.error(e)
|
||||
CeleryTask.objects.filter(name=task).update(date_last_publish=timezone.now())
|
||||
|
||||
with transaction.atomic():
|
||||
try:
|
||||
CeleryTaskExecution.objects.create(**data)
|
||||
except Exception as e:
|
||||
logger.error('Create celery task execution error: {}'.format(e))
|
||||
CeleryTask.objects.filter(name=task).update(date_last_publish=timezone.now())
|
||||
|
||||
|
||||
@receiver(django_ready)
|
||||
|
||||
Reference in New Issue
Block a user