github
/
jumpserver
mirror of https://github.com/jumpserver/jumpserver
1
0
Fork 0
Code Issues Releases Wiki Activity

perf: 修复发布机任务执行失败的问题

pull/11305/head
Eric 2023-08-16 18:17:32 +08:00
parent 8f10b84e94
commit 45e1723aa9
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/terminal/api/applet/host.py
View File

@ -1,3 +1,4 @@
from django.db import transaction
from rest_framework import status from rest_framework import status
from rest_framework import viewsets from rest_framework import viewsets
from rest_framework.decorators import action from rest_framework.decorators import action
@ -58,7 +59,8 @@ class AppletHostDeploymentViewSet(viewsets.ModelViewSet):
def create(self, request, *args, **kwargs): def create(self, request, *args, **kwargs):
serializer = self.get_serializer(data=request.data) serializer = self.get_serializer(data=request.data)
serializer.is_valid(raise_exception=True) serializer.is_valid(raise_exception=True)
instance = serializer.save() with transaction.atomic():
instance = serializer.save()
task = run_applet_host_deployment.delay(instance.id) task = run_applet_host_deployment.delay(instance.id)
instance.save_task(task.id) instance.save_task(task.id)
return Response({'task': str(task.id)}, status=201) return Response({'task': str(task.id)}, status=201)