mirror of https://github.com/apache/cloudstack.git
CLOUDSTACK-7224: Fixed marvin code for async jobs
Signed-off-by: Santhosh Edukulla <santhosh.edukulla@gmail.com>
This commit is contained in:
parent
ffeca8bbd2
commit
93c64cd7f2
|
|
@ -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
|
||||
|
||||
|
|
|
|||
|
|
@ -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")
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue