if response.status_code == 200:
return job_id
- if response.json:
- msg = response.json.get('message', '')
+ resp_json = response.json()
+ if resp_json:
+ msg = resp_json.get('message', '')
else:
msg = response.text
uri += "?fields=" + ','.join(fields)
response = requests.get(uri)
response.raise_for_status()
- return response.json
+ return response.json()
def delete_job(self, run_name, job_id):
"""
def successful_ops(out):
"""
Extract successful operations
- :param out: list
+ :param out: list
"""
summary = out['summary']
if len(summary) == 0:
def rgwadmin(ctx, client, cmd):
"""
Perform rgw admin command
-
+
:param client: client
:param cmd: command to execute.
:return: command exit status, json result.
log.info(' text result: %s' % result.txt)
return result.status_code, result.txt
else:
- log.info(' json result: %s' % result.json)
- return result.status_code, result.json
+ log.info(' json result: %s' % result.json())
+ return result.status_code, result.json()
def task(ctx, config):