Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- @ray.remote
- def issue_request(user_id):
- r = requests.post(url , json, headers)
- ray.get([issue_request.remote(id_token[user_id], 1) for _ in range(500)])
- def issue_request(user_id):
- r = requests.post(url , json, headers)
- jobs = []
- for i in range(500):
- process = multiprocessing.Process(target=issue_request,
- args=(admin_id))
- jobs.append(process)
- for j in jobs:
- j.start()
- # Ensure all of the processes have finished
- for j in jobs:
- j.join()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement