-
Notifications
You must be signed in to change notification settings - Fork 1
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
prototype parallel deskew implementation #33
Conversation
this is adds the skeleton to multiprocessing per position over T and C.
The implementation now should mirror recOrders new recon functions as well as the standard that we are going to follow to easily parallelize the functions, meaning simplifying the functions to process a single position and iterate over T and C. Currently , the single node will get one position and within the node we can multiprocess over T and C. One problem at the moment is a mismatch in the deskewed output, which does not match the output of |
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.
We're getting there. I think the highest priority problems are:
- running one position then another position overwrites the first position (this prevents any slurm-level parallelization)
- The
parallel
decorator isn't connected...I think this is nice to have, but not a need to have since we're mainly planning to parallelize over P with slurm.
I know that this is a work in progress, but before merging we should plan to expand the function documentation and come up with sensible function names. At this point we have functions named
P.S. We'll likely have similar issues with other analysis methods and CLI workflows. We could try to set a convention for naming the ndarray methods and the cli methods. |
This branch is now deprecated by #47. To close the loop on the comments @ieivanov brought up here:
|
Prototype parallel deskew implementation, see discussion in #6
TODO:
Dataset
object in every worker, rather than pickling the dask array from the main process--view
argument when using multiprocessing--view
argument when processing HCS datasets