[node] Publish: fix node with new chunk notion

This commit is contained in:
Fabien Castan 2017-11-07 18:46:14 +01:00
parent 1e4f8f8a61
commit 8efa14ecda

View file

@ -29,27 +29,27 @@ class Publish(desc.Node):
), ),
] ]
def process(self, node): def processChunk(self, chunk):
print("Publish") print("Publish")
if not node.inputFiles: if not chunk.node.inputFiles:
print("Nothing to publish") print("Nothing to publish")
return return
if not node.output.value: if not chunk.node.output.value:
return return
inputFiles = [] inputFiles = []
for inputFile in node.inputFiles: for inputFile in chunk.node.inputFiles:
iFiles = glob.glob(inputFile.value) iFiles = glob.glob(inputFile.value)
inputFiles.extend(iFiles) inputFiles.extend(iFiles)
if not inputFiles: if not inputFiles:
raise RuntimeError("Publish: input files listed, but nothing to publish. Listed input files: {}".format(node.inputFiles)) raise RuntimeError("Publish: input files listed, but nothing to publish. Listed input files: {}".format(node.inputFiles))
if not os.path.exists(node.output.value): if not os.path.exists(chunk.node.output.value):
os.mkdir(node.output.value) os.mkdir(chunk.node.output.value)
for iFile in inputFiles: for iFile in inputFiles:
filename = os.path.basename(iFile) filename = os.path.basename(iFile)
oFile = os.path.join(node.output.value, filename) oFile = os.path.join(chunk.node.output.value, filename)
print('Publish file', iFile, 'into', oFile) print('Publish file', iFile, 'into', oFile)
shutil.copyfile(iFile, oFile) shutil.copyfile(iFile, oFile)
print('Publish end') print('Publish end')