diff --git a/tools/marvin/marvin/asyncJobMgr.py b/tools/marvin/marvin/asyncJobMgr.py index 00e8c19b3ce..42fabad382f 100644 --- a/tools/marvin/marvin/asyncJobMgr.py +++ b/tools/marvin/marvin/asyncJobMgr.py @@ -127,9 +127,6 @@ class workThread(threading.Thread): self.output.put(jobstatus) self.inqueue.task_done() - '''release the resource''' - self.connection.close() - class jobThread(threading.Thread): @@ -143,8 +140,6 @@ class jobThread(threading.Thread): job = self.inqueue.get() try: job.run() - '''release the api connection''' - job.apiClient.connection.close() except: pass diff --git a/tools/marvin/marvin/cloudstackConnection.py b/tools/marvin/marvin/cloudstackConnection.py index a8c35f67b4e..aa7b18ff6c7 100644 --- a/tools/marvin/marvin/cloudstackConnection.py +++ b/tools/marvin/marvin/cloudstackConnection.py @@ -340,8 +340,7 @@ class CSConnection(object): ''' 1. Verify the Inputs Provided ''' - if (cmd is None or cmd == '')or \ - (response_type is None or response_type == ''): + if (cmd is None or cmd == ''): self.logger.exception("marvinRequest : Invalid Command Input") raise InvalidParameterException("Invalid Parameter")