mirror of
https://github.com/jumpserver/jumpserver.git
synced 2025-09-01 23:47:40 +00:00
Merge pull request #11305 from jumpserver/pr@dev@perf_task_err
perf: 修复发布机任务执行失败的问题
This commit is contained in:
@@ -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)
|
||||||
|
Reference in New Issue
Block a user