Skip to content

Commit

Permalink
Fix WGS submission (#209)
Browse files Browse the repository at this point in the history
* Fix identifier for WGS mode in main.nf

* Update CHANGELOG

* Update version
  • Loading branch information
yashpatel6 authored May 30, 2024
1 parent 9f747d1 commit b0f5eb0
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 5 deletions.
8 changes: 7 additions & 1 deletion CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,13 @@ This project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.htm

---

## [6.0.0-rc.5] - 2024-05-23
## [6.0.0-rc.5] - 2024-05-29
### Fixed
+ Issue with identifier used in WGS mode

---

## [6.0.0-rc.5] - 2024-05-23 - YANKED
### Added
+ Call-SRC pipeline
### Changed
Expand Down
9 changes: 5 additions & 4 deletions main.nf
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ process create_config_metapipeline_DNA {
)

output:
tuple val(patient), path("pipeline_specific_params.json"), emit: metapipeline_dna_input
tuple val(patient), path("pipeline_specific_params.json"), val(identifier), emit: metapipeline_dna_input

exec:
def filtering_criteria = { k, v ->
Expand Down Expand Up @@ -105,12 +105,13 @@ process call_metapipeline_DNA {
publishDir path: "${params.log_output_dir}/process-log",
mode: "copy",
pattern: ".command.*",
saveAs: { "${task.process}/${patient}-${new StringBuilder(task.hash).insert(2, '-').toString()}/log${file(it).getName()}" }
saveAs: { "${task.process}/${identifier}-${new StringBuilder(task.hash).insert(2, '-').toString()}/log${file(it).getName()}" }

input:
tuple(
val(patient),
path(pipeline_params_json)
path(pipeline_params_json),
val(identifier)
)

output:
Expand All @@ -119,7 +120,7 @@ process call_metapipeline_DNA {

script:
submission_command = (params.uclahs_cds_wgs)
? params.global_job_submission_sbatch + "-J wgs_${task.process}_${file(input_csv).getName().replace('_metapipeline_DNA_input.csv', '')}_\${FIRST_DIR_HASH}_\${SECOND_DIR_HASH} --wrap=\""
? params.global_job_submission_sbatch + "-J wgs_${task.process}_${identifier}_\${FIRST_DIR_HASH}_\${SECOND_DIR_HASH} --wrap=\""
: ""
limiter_wrapper_pre = (params.uclahs_cds_wgs)
? params.global_job_submission_limiter + submission_command
Expand Down

0 comments on commit b0f5eb0

Please sign in to comment.