Now with working check if all actors of an app is gone, not just some.
@@ -122,13 +122,18 @@ def delete_app(request_handler, runtime, app_id, check_actor_ids=None, retries=1
return True
def verify_actors_gone(request_handler, runtime, actor_ids):
+ responses = []
for actor_id in actor_ids:
- request_handler.async_get_actor(runtime, actor_id)
+ responses.append(request_handler.async_get_actor(runtime, actor_id))
+ gone = True
+ for r in responses:
try:
- request_handler.async_barrier() # make sure all responses are back
- return False
+ response = request_handler.async_response(r)
+ if response is not None:
+ gone = False
except:
- return True
+ pass
+ return gone
try:
request_handler.delete_application(runtime, app_id)
