-
-
Notifications
You must be signed in to change notification settings - Fork 74
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add a nonblocking addprocs_sge (and others) #80
Comments
if your SGE cluster supports qrsh, you might try |
Thanks @bjarthur, this works for me. Unfortunately I should add that since EDIT: Added pull request #82 to include |
Actually, upon trying this with more workers, it still does not submit the jobs asynchronously. Each processor must be added before the next job can be queued in the gist I linked. You can test it by running the script with, say 10 jobs, and executing id = addprocs_qrsh(1) by qrsh = QRSHManager(1, "");
Distributed.cluster_mgmt_from_master_check()
id = Distributed.addprocs_locked(qrsh; qsub_env="") In this case, all jobs will be queued at the same time. For some reason |
@cako it is a nice feature to have a non-blocking |
Has a non-blocking |
Currently the use of
addprocs_sge
(and the others) is blocking. It must obtain the node before it returns. For example, applying@async
to a command which callsaddprocs_sge
is useless.I would like to know if is it possible to add a non-blocking version of
addprocs_sge
. I am happy to help with the coding but am not overly familiar with theaddprocs
structure.I suggested a workaround in a question on StackOverflow but am not sure my approach to the issue is recommended.
The text was updated successfully, but these errors were encountered: