Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
'serverName':"",
'userCredentials': {},
'volumeId':int(volume_id[i][0]),
'CommCellId': self._commcell_object.commcell_id})
else:
request_json['volumes'].append({'volumeId':int(volume_id[i][0]),
'CommCellId': self._commcell_object.commcell_id})
flag, response = self._commcell_object._cvpysdk_object.make_request(
'POST', self._SNAP_OPS, request_json)
if flag:
if response.json():
if "jobId" in response.json():
return Job(self._commcell_object, response.json()['jobId'])
elif "errorCode" in response.json():
error_message = response.json()['errorMessage']
o_str = 'job for Snap Operation failed\nError: "{0}"'.format(error_message)
raise SDKException('Snap', '102', o_str)
else:
raise SDKException('Snap', '102')
if response is empty
if response is not success
"""
flag, response = self._commcell_object._cvpysdk_object.make_request(
'POST', self._commcell_object._services['BROWSE'], request_json
)
if flag:
response_json = response.json()
if response_json:
if "browseResponses" in response_json:
d = response_json['browseResponses'][0]["browseResult"]["advConfig"]["applicationMining"]["browseInitResp"]
try:
return Job(self._commcell_object, d["recoveryPointJobID"]), d["recoveryPointID"], d["edbPath"]
except Exception as msg:
# server code 102 response is empty or doesn't contain required parameters
raise SDKException('Instance', 102, msg)
elif "errorCode" in response.json():
error_message = response.json()['errorMessage']
o_str = 'create recovery point job failed\nError: "{0}"'.format(error_message)
raise SDKException('Instance', '102', o_str)
else:
raise SDKException('Instance', '102', 'Failed to run the restore job')
else:
raise SDKException('Response', '102')
else:
response_string = self._commcell_object._update_response_(response.text)
raise SDKException('Response', '101', response_string)
_type_="11" mediaAgentName="" />
""".format(self._storage_policy_id, self._storage_policy_name)
flag, response = self._commcell_object._cvpysdk_object.make_request(
'POST', self._commcell_object._services['EXECUTE_QCOMMAND'], request_xml
)
if flag:
if response.json():
if "jobIds" in response.json():
return Job(self._commcell_object, response.json()['jobIds'][0])
else:
raise SDKException('Storage', '102', 'Unable to get job id for CI job')
else:
raise SDKException('Response', '102', 'Empty response')
else:
raise SDKException('Response', '101')
instance of the Schedule class for the backup job if its a scheduled Job
Raises:
SDKException:
if job initialization failed
if response is empty
if response is not success
"""
if flag:
if response.json():
if "jobIds" in response.json():
if len(response.json()['jobIds']) == 1:
return Job(self._commcell_object,
response.json()['jobIds'][0])
else:
joblist = []
for jobids in response.json()['jobIds']:
joblist.append(Job(self._commcell_object, jobids))
return joblist
elif "taskId" in response.json():
return Schedules(self._commcell_object).get(task_id=response.json()['taskId'])
elif "errorCode" in response.json():
o_str = 'Initializing backup failed\nError: "{0}"'.format(
response.json()['errorMessage']
)
raise SDKException('Subclient', '102', o_str)
else:
raise SDKException('Response', '102')
else:
SDKException:
if restore job failed
if response is empty
if response is not success
"""
flag, response = self._commcell_object._cvpysdk_object.make_request(
'POST', self._commcell_object._services['RESTORE'], request_json
)
if flag:
if response.json():
if "jobIds" in response.json():
time.sleep(1)
return Job(self._commcell_object, response.json()['jobIds'][0])
elif "errorCode" in response.json():
error_message = response.json()['errorMessage']
o_str = 'Restore job failed\nError: "{0}"'.format(error_message)
raise SDKException('Instance', '102', o_str)
else:
raise SDKException('Instance', '102', 'Failed to run the restore job')
else:
raise SDKException('Response', '102')
else:
response_string = self._commcell_object._update_response_(response.text)
raise SDKException('Response', '101', response_string)
]
}
}
if schedule_pattern:
request_json = SchedulePattern().create_schedule(request_json, schedule_pattern)
flag, response = self._cvpysdk_object.make_request(
'POST', self._services['CREATE_TASK'], request_json
)
if flag:
if response.json():
if "jobIds" in response.json():
from .job import Job
return Job(self, response.json()['jobIds'][0])
elif "errorCode" in response.json():
error_message = response.json()['errorMessage']
o_str = 'Error: "{0}"'.format(error_message)
raise SDKException('Commcell', '105', o_str)
elif "taskId" in response.json():
return Schedules(self).get(task_id=response.json()['taskId'])
else:
raise SDKException('Commcell', '105')
else:
raise SDKException('Response', '102')
else:
raise SDKException('Response', '101', self._update_response_(response.text))
def run(self):
"""Runs the Monitoring Policy job"""
flag, response = self._commcell_object._cvpysdk_object.make_request(
'POST', self._RUN_MONITORING_POLICY)
if flag:
if response.json():
if "jobIds" in response.json():
return Job(self._commcell_object, response.json()['jobIds'][0])
elif "errorCode" in response.json():
o_str = 'Intializing Monitoring Policy Job failed\nError: "{0}"'\
.format(response.json()['errorMessage'])
raise SDKException('Monitoring', '102', o_str)
else:
raise SDKException('Response', '102')
else:
response_string = self._update_response_(response.text)
raise SDKException('Response', '101', response_string)
}
}
}
]
}
}
flag, response = self._cvpysdk_object.make_request('POST', self._services['RESTORE'], replicacopyjson)
if flag:
if response.json():
if "jobIds" in response.json():
return Job(self._commcell_object, response.json()['jobIds'][0])
elif "taskId" in response.json():
return Schedules(self._commcell_object).get(task_id=response.json()['taskId'])
elif "errorCode" in response.json():
error_message = response.json()['errorMessage']
o_str = 'Restore job failed\nError: "{0}"'.format(error_message)
raise SDKException('Subclient', '102', o_str)
else:
raise SDKException('Subclient', '102', 'Failed to run the restore job')
else:
raise SDKException('Response', '102')
else:
raise SDKException('Response', '101', self._update_response_(response.text))
"rebootClient": True
}
}
}
}
]
}
}
flag, response = self._cvpysdk_object.make_request(
'POST', self._services['CREATE_TASK'], request_json
)
if flag:
if response.json():
if "jobIds" in response.json():
return Job(self.commcell_object, response.json()['jobIds'][0])
else:
raise SDKException('Install', '107')
else:
raise SDKException('Response', '102')
else:
raise SDKException('Response', '101')