-
Notifications
You must be signed in to change notification settings - Fork 125
Fix ntasks job option,work_dir job option and slurmdb_jobs db connection #141
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
Conversation
|
It seems that the master branch already failed in the same steps. |
| cwd = os.getcwd().encode("UTF-8", "replace") | ||
| desc.work_dir = cwd | ||
|
|
||
| if job_opts.get("work_dir"): |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
👍
| dict J_dict = {} | ||
| slurm.List JOBSList | ||
| slurm.ListIterator iters = NULL | ||
| void* db_conn = slurm.slurmdb_connection_get() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
👍 I can't remember if this got taken out or was missing to begin with.
| # TODO: ntasks_set, cpus_set | ||
|
|
||
| if job_opts.get("ntasks"): | ||
| desc.min_cpus = job_opts.get("ntasks") * job_opts.get("cpus_per_task") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Is this right? I think there's some conditions to calculating min_cpus.
|
The Python 2.6 tests need to get fixed. 😞 |
|
Can you rebase please? |
|
No response. Please rebase. Closing for now. |
We have edited pyslurm.pyx file to fix the ntasks job option which was commented out, fix the work_dir job option which was not implemented and to fix slurmdb_jobs_get() database connection issue. There was no statement to close the database connection after fetching data, and as a result, the function was unable to fetch changes to the database running on flask server.