@@ -282,37 +282,6 @@ def createFarmTask(self, meshroomFile: str, orderedTask: OrderedTask, createdTas
282282
283283 return task
284284
285- def buildDependencies (self , job : Job , nodeUidToTask : Dict [str , CreatedTask ], edges ):
286- """ Gather and create dependencies.
287- First we get all parents and all children for each task.
288- Then for each task:
289- - we add the dependency to their parent and children
290- - if the task is a chunked task (which means multi iteration tasks) the we create the
291- chunk tasks and add dependencies from chunk tasks to children tasks
292-
293- # TODO: there is a lot of confusion between nodes and tasks here
294- """
295- # Gather dependencies
296- tasksParentsUids = defaultdict (set )
297- tasksChildrenUids = defaultdict (set )
298- for u , v in edges :
299- # tasksParentsUids[v._uid].add(u._uid)
300- # tasksChildrenUids[u._uid].add(v._uid)
301- tasksParentsUids [u ._uid ].add (v ._uid )
302- tasksChildrenUids [v ._uid ].add (u ._uid )
303- # Create dependencies
304- for taskUid , createdTask in nodeUidToTask .items ():
305- parentsTasks = [nodeUidToTask [tuid ].task for tuid in tasksParentsUids .get (taskUid , set ())]
306- childrenTasks = [nodeUidToTask [tuid ].task for tuid in tasksChildrenUids .get (taskUid , set ())]
307- # Create regular dependencies
308- for parentTask in parentsTasks :
309- job .addTaskDependency (createdTask .task , parentTask )
310- for childTask in childrenTasks :
311- job .addTaskDependency (childTask , createdTask .task )
312- # Create chunk tasks if necessary
313- if createdTask .chunkParams :
314- self .__createChunkTasks (job , createdTask .task , childrenTasks , createdTask .chunkParams )
315-
316285 def createJob (self , orderedTasks , filepath , submitLabel = "{projectName}" ) -> LocalFarmJob :
317286 projectName = os .path .splitext (os .path .basename (filepath ))[0 ]
318287 name = submitLabel .format (projectName = projectName )
0 commit comments