Skip to content

Commit 861f31d

Browse files
committed
[desc] Add process function on node desc so that we can skip the chunks on plugins
1 parent 26f62b6 commit 861f31d

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

meshroom/core/desc/node.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -148,8 +148,14 @@ def postprocess(self, node):
148148
"""
149149
pass
150150

151+
def process(self, node):
152+
raise NotImplementedError(f'No process implementation on node: "{node.name}"')
153+
151154
def processChunk(self, chunk):
152-
raise NotImplementedError(f'No processChunk implementation on node: "{chunk.node.name}"')
155+
if self.parallelization is None:
156+
self.process(chunk.node)
157+
else:
158+
raise NotImplementedError(f'No process implementation on node: "{chunk.node.name}"')
153159

154160
def executeChunkCommandLine(self, chunk, cmd, env=None):
155161
try:

0 commit comments

Comments
 (0)