Commits
252 252 | workdir = os.path.join(self.getpath(nodeid), imagename + '.workdirectory') |
253 253 | |
254 254 | if( not os.path.exists(workdir) ): |
255 255 | os.mkdir( workdir ) |
256 256 | |
257 257 | return workdir |
258 258 | |
259 259 | ############################################# |
260 260 | def getpartimagename(self, imagename, nodeid): |
261 261 | """ |
262 - | If imagename = 'imaging_subdir/foo_img', it produces something like: |
263 - | imaging_subdir/foo_img.workdirectory/calibrated_final_cont.n5.gridwt |
262 + | For imagename = 'imaging_subdir/foo_img', it produces something like: |
263 + | 'imaging_subdir/foo_img.workdirectory/foo_img.n5.gridwt' (where n5 is the node idx) |
264 + | |
265 + | :param imagename: imagename as passed to the tclean task |
266 + | :param nodeid: id of MPI node |
267 + | |
268 + | :returns: (full path) name of a part/sub-image for nodeid, produced by concatenating |
269 + | the working directory, the image basename and the node id as a string. |
264 270 | """ |
265 271 | # don't include subdirs again here - the workdir is already inside the subdir(s) |
266 272 | image_basename = os.path.basename(imagename) |
267 273 | return os.path.join(self.getworkdir(imagename,nodeid), image_basename + '.n' + |
268 274 | str(nodeid)) |
269 275 | |
270 276 | |
271 277 | ############################################# |
272 278 | |
273 279 | |