Skip to content

Commit 197c694

Browse files
Merge pull request #61 from chkp-shirango/master
Support objects crud tasks
2 parents 45d1c28 + e80de34 commit 197c694

File tree

1 file changed

+11
-2
lines changed

1 file changed

+11
-2
lines changed

plugins/module_utils/checkpoint.py

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -169,7 +169,7 @@ def wait_for_task(module, version, connection, task_id):
169169
completed_tasks += 1
170170

171171
# Are we done? check if all tasks are completed
172-
if completed_tasks == len(response["tasks"]):
172+
if completed_tasks == len(response["tasks"]) and completed_tasks != 0:
173173
task_complete = True
174174
else:
175175
time.sleep(2) # Wait for two seconds
@@ -239,7 +239,16 @@ def handle_call(connection, version, call, payload, module, to_publish, to_disca
239239
discard_and_fail(module, code, response, connection, version)
240240
else:
241241
module.fail_json(msg=parse_fail_message(code, response))
242-
242+
else:
243+
if module.params['wait_for_task']:
244+
if 'task-id' in response:
245+
response = wait_for_task(module, version, connection, response['task-id'])
246+
elif 'tasks' in response:
247+
for task in response['tasks']:
248+
if 'task-id' in task:
249+
task_id = task['task-id']
250+
response[task_id] = wait_for_task(module, version, connection, task['task-id'])
251+
del response['tasks']
243252
if to_publish:
244253
handle_publish(module, connection, version)
245254
return response

0 commit comments

Comments
 (0)