qcfractal/queue/handlers.py
def put(self):
        """Modifies tasks in the task queue
        """

        body_model, response_model = rest_model("task_queue", "put")
        body = self.parse_bodymodel(body_model)

        if (body.data.id is None) and (body.data.base_result is None):
            raise tornado.web.HTTPError(status_code=400, reason="Id or ResultId must be specified.")

        if body.meta.operation == "restart":
            tasks_updated = self.storage.queue_reset_status(**body.data.dict(), reset_error=True)
            data = {"n_updated": tasks_updated}
        else:
            raise tornado.web.HTTPError(status_code=400, reason=f"Operation '{operation}' is not valid.")

        response = response_model(data=data, meta={"errors": [], "success": True, "error_description": False})

        self.logger.info(f"PUT: TaskQueue - Operation: {body.meta.operation} - {tasks_updated}.")
        self.write(response)
Modifies tasks in the task queue
        
Modifies tasks in the task queue
Modifies tasks in the task queue
def put(self):
        body_model, response_model = rest_model("task_queue", "put")
        body = self.parse_bodymodel(body_model)
        if (body.data.id is None) and (body.data.base_result is None):
            raise tornado.web.HTTPError(status_code=400, reason="Id or ResultId must be specified.")
        if body.meta.operation == "restart":
            tasks_updated = self.storage.queue_reset_status(**body.data.dict(), reset_error=True)
            data = {"n_updated": tasks_updated}
        else:
            raise tornado.web.HTTPError(status_code=400, reason=f"Operation '{operation}' is not valid.")
        response = response_model(data=data, meta={"errors": [], "success": True, "error_description": False})
        self.logger.info(f"PUT: TaskQueue - Operation: {body.meta.operation} - {tasks_updated}.")
        self.write(response)
def put ( self ) : body_model , response_model = rest_model ( "task_queue" , "put" ) body = self . parse_bodymodel ( body_model ) if ( body . data . id is None ) and ( body . data . base_result is None ) : raise tornado . web . HTTPError ( status_code = 400 , reason = "Id or ResultId must be specified." ) if body . meta . operation == "restart" : tasks_updated = self . storage . queue_reset_status ( ** body . data . dict ( ) , reset_error = True ) data = { "n_updated" : tasks_updated } else : raise tornado . web . HTTPError ( status_code = 400 , reason = f"Operation '{operation}' is not valid." ) response = response_model ( data = data , meta = { "errors" : [ ] , "success" : True , "error_description" : False } ) self . logger . info ( f"PUT: TaskQueue - Operation: {body.meta.operation} - {tasks_updated}." ) self . write ( response )
Modifies tasks in the task queue
Modifies tasks in the task queue
"""Modifies tasks in the task queue
        """
self