Source code for api.views.runmanager_schedule

import json
from rest_framework.response import Response
from rest_framework.views import APIView
import coreapi

[docs]class RunManagerSchedule(APIView): # TODO:add document sample for swagger (need to update) coreapi_fields = ( coreapi.Field( name='interval', required=True, type='time', ), coreapi.Field( name='start', required=True, type='date', ), coreapi.Field( name='end', required=True, type='date', ), coreapi.Field( name='repeat', required=True, type='int', ), )
[docs] def post(self, request, nnid): """ Training Job schedule management We have predefined set of graph flow.. on Scheduler you can set a schedule this graph flow run on exact time. (everyday 1pm, every 5hours ... somting like this) So that we can feed new data and update model automatically --- # Class Name : RunManagerSchedule # Description: create schedule params sets """ try: return_data = "" return Response(json.dumps(return_data)) except Exception as e: return_data = {"status": "404", "result": str(e)} return Response(json.dumps(return_data))
[docs] def get(self, request, nnid): """ Training Job schedule management We have predefined set of graph flow.. on Scheduler you can set a schedule this graph flow run on exact time. (everyday 1pm, every 5hours ... somting like this) So that we can feed new data and update model automatically --- # Class Name : RunManagerSchedule # Description: get schedule params for selected nn_id """ try: return_data = "" return Response(json.dumps(return_data)) except Exception as e: return_data = {"status": "404", "result": str(e)} return Response(json.dumps(return_data))
[docs] def put(self, request, nnid): """ Training Job schedule management We have predefined set of graph flow.. on Scheduler you can set a schedule this graph flow run on exact time. (everyday 1pm, every 5hours ... somting like this) So that we can feed new data and update model automatically --- # Class Name : RunManagerSchedule # Description: modify schedule params for selected nn_id """ try: return_data = "" return Response(json.dumps(return_data)) except Exception as e: return_data = {"status": "404", "result": str(e)} return Response(json.dumps(return_data))
[docs] def delete(self, request, nnid): """ Training Job schedule management We have predefined set of graph flow.. on Scheduler you can set a schedule this graph flow run on exact time. (everyday 1pm, every 5hours ... somting like this) So that we can feed new data and update model automatically --- # Class Name : RunManagerSchedule # Description: delete schedule params for selected nn_id """ try: return_data = "" return Response(json.dumps(return_data)) except Exception as e: return_data = {"status": "404", "result": str(e)} return Response(json.dumps(return_data))