Loading transfer_service/import_executor.py +3 −3 Original line number Diff line number Diff line Loading @@ -101,7 +101,7 @@ class ImportExecutor(TaskExecutor): nodeList.append([ now, dir, vospacePath, "container", "DONE" ]) else: now = dt.now() nodeList.append([ now, dir, vospacePath, "container", "SKIP" ]) nodeList.append([ now, dir, vospacePath, "container", "SKIPPED" ]) for flist in files: for file in flist: Loading Loading @@ -141,7 +141,7 @@ class ImportExecutor(TaskExecutor): nodeList.append([ now, file, vospacePath, "data", "DONE" ]) else: now = dt.now() nodeList.append([ now, file, vospacePath, "data", "SKIP" ]) nodeList.append([ now, file, vospacePath, "data", "SKIPPED" ]) #out.close() nlfp.write(tabulate(nodeList, Loading Loading @@ -169,7 +169,7 @@ class ImportExecutor(TaskExecutor): End time: {end} Processed nodes: {len(nodeList)} Imported nodes: {sum(res[-1] == 'DONE' for res in nodeList)} Skipped nodes: {sum(res[-1] == 'SKIP' for res in nodeList)} Skipped nodes: {sum(res[-1] == 'SKIPPED' for res in nodeList)} """ m.setMessageWithAttachment("VOSpace import notification", msg, nodeListFile) Loading Loading
transfer_service/import_executor.py +3 −3 Original line number Diff line number Diff line Loading @@ -101,7 +101,7 @@ class ImportExecutor(TaskExecutor): nodeList.append([ now, dir, vospacePath, "container", "DONE" ]) else: now = dt.now() nodeList.append([ now, dir, vospacePath, "container", "SKIP" ]) nodeList.append([ now, dir, vospacePath, "container", "SKIPPED" ]) for flist in files: for file in flist: Loading Loading @@ -141,7 +141,7 @@ class ImportExecutor(TaskExecutor): nodeList.append([ now, file, vospacePath, "data", "DONE" ]) else: now = dt.now() nodeList.append([ now, file, vospacePath, "data", "SKIP" ]) nodeList.append([ now, file, vospacePath, "data", "SKIPPED" ]) #out.close() nlfp.write(tabulate(nodeList, Loading Loading @@ -169,7 +169,7 @@ class ImportExecutor(TaskExecutor): End time: {end} Processed nodes: {len(nodeList)} Imported nodes: {sum(res[-1] == 'DONE' for res in nodeList)} Skipped nodes: {sum(res[-1] == 'SKIP' for res in nodeList)} Skipped nodes: {sum(res[-1] == 'SKIPPED' for res in nodeList)} """ m.setMessageWithAttachment("VOSpace import notification", msg, nodeListFile) Loading