NeoAnd/netbox
1
0
Fork 0
mirror of https://github.com/netbox-community/netbox.git synced 2025-07-31 12:56:24 -06:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

7848 Task enqueue, requeue, stop

Browse Source
This commit is contained in:
Arthur Hanson 2024-11-06 14:05:28 -08:00
parent afb18d4ea9
commit d26e2a1746
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
netbox/core/api/views.py
View File

@ -189,7 +189,7 @@ class TaskDeleteView(APIView):
@extend_schema(responses={200: OpenApiTypes.OBJECT}) @extend_schema(responses={200: OpenApiTypes.OBJECT})
def get(self, request, task_id, format=None): def get(self, request, task_id, format=None):
delete_rq_job(task_id) delete_rq_job(task_id)
return HttpResponse(status=204) return HttpResponse(status=200)
class TaskRequeueView(APIView): class TaskRequeueView(APIView):
@ -201,7 +201,7 @@ class TaskRequeueView(APIView):
@extend_schema(responses={200: OpenApiTypes.OBJECT}) @extend_schema(responses={200: OpenApiTypes.OBJECT})
def get(self, request, task_id, format=None): def get(self, request, task_id, format=None):
requeue_rq_job(task_id) requeue_rq_job(task_id)
return HttpResponse(status=204) return HttpResponse(status=200)
class TaskEnqueueView(APIView): class TaskEnqueueView(APIView):
@ -213,7 +213,7 @@ class TaskEnqueueView(APIView):
@extend_schema(responses={200: OpenApiTypes.OBJECT}) @extend_schema(responses={200: OpenApiTypes.OBJECT})
def get(self, request, task_id, format=None): def get(self, request, task_id, format=None):
enqueue_rq_job(task_id) enqueue_rq_job(task_id)
return HttpResponse(status=204) return HttpResponse(status=200)
class TaskStopView(APIView): class TaskStopView(APIView):
@ -226,11 +226,9 @@ class TaskStopView(APIView):
def get(self, request, task_id, format=None): def get(self, request, task_id, format=None):
stopped_jobs = stop_rq_job(job_id) stopped_jobs = stop_rq_job(job_id)
if len(stopped_jobs) == 1: if len(stopped_jobs) == 1:
pass return HttpResponse(status=200)
# messages.success(request, _('Job {id} has been stopped.').format(id=job_id))
else: else:
pass return HttpResponse(status=204)
# messages.error(request, _('Failed to stop job {id}').format(id=job_id))
class BaseTaskListView(APIView): class BaseTaskListView(APIView):