Skip to content

Commit 690b326

Browse files
Import results directory too (#474)
1 parent 8d4f1a4 commit 690b326

File tree

3 files changed

+6
-3
lines changed

3 files changed

+6
-3
lines changed

nextflow/src/org/labkey/nextflow/pipeline/NextFlowPipelineJob.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,9 +70,12 @@ private static Path createConfig(Path configTemplate, Path parentDir, Path jobDi
7070

7171
String webdavUrl = FileContentService.get().getWebDavUrl(parentDir, container, FileContentService.PathType.full);
7272
webdavUrl = StringUtils.stripEnd(webdavUrl, "/");
73-
7473
String substitutedContent = template.replace("${quant_spectra_dir}", "quant_spectra_dir = '" + webdavUrl + "'");
7574

75+
String uploadUrl = FileContentService.get().getWebDavUrl(jobDir, container, FileContentService.PathType.full);
76+
uploadUrl = StringUtils.stripEnd(uploadUrl, "/");
77+
substitutedContent = substitutedContent.replace("${panorama.upload_url}", "panorama.upload_url = '" + uploadUrl + "'");
78+
7679
Path substitutedFile = jobDir.resolve(configTemplate.getFileName());
7780
try (BufferedWriter writer = Files.newBufferedWriter(substitutedFile))
7881
{
@@ -116,5 +119,4 @@ public File findOutputFile(String name)
116119
{
117120
return null;
118121
}
119-
120122
}

nextflow/src/org/labkey/nextflow/pipeline/NextFlowProtocol.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
public class NextFlowProtocol extends AbstractFileAnalysisProtocol<NextFlowPipelineJob>
1717
{
1818
public static final List<FileType> INPUT_TYPES = List.of(
19-
new FileType(".RAW"),
19+
new FileType(".raw"),
2020
new FileType(".mzML"));
2121

2222
public NextFlowProtocol()

nextflow/src/org/labkey/nextflow/pipeline/NextFlowRunTask.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -80,6 +80,7 @@ public NextFlowRunTask(Factory factory, PipelineJob job)
8080
action.addInput(inputFile.toFile(), SPECTRA_INPUT_ROLE);
8181
}
8282
addOutputs(action, getJob().getLogFilePath().getParent().resolve("reports"));
83+
addOutputs(action, getJob().getLogFilePath().getParent().resolve("results"));
8384
return new RecordedActionSet(action);
8485
}
8586
catch (IOException e)

0 commit comments

Comments
 (0)