Skip to content

Instantly share code, notes, and snippets.

@deanwampler
Last active January 29, 2020 01:55
Show Gist options
  • Save deanwampler/bc5fe3985329e7bc8761e95e4e13e181 to your computer and use it in GitHub Desktop.
Save deanwampler/bc5fe3985329e7bc8761e95e4e13e181 to your computer and use it in GitHub Desktop.
ids = [busy.remote(i) for i in times] # New set of ids
for i in range(1,40):
ready, not_ready = ray.wait(ids, num_returns = 2)
print('iteration:', i)
print('Ready length, values: ', len(ready), ray.get(ready))
print('Not Ready length:', len(not_ready))
ids = not_ready
if not ids:
break
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment