Skip to content

Commit 21f9252

Browse files
committed
change default to finish and other minor changes
1 parent 6dc0975 commit 21f9252

8 files changed

Lines changed: 12 additions & 25 deletions

File tree

process/score_download.nf

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ process scoreDownload {
2626
maxRetries params.max_retries
2727
errorStrategy {
2828
sleep(Math.pow(2, task.attempt) * params.first_retry_wait_time * 1000 as long); // backoff time increases exponentially before each retry
29-
return params.max_retries ? 'retry' : 'terminate'
29+
return params.max_retries ? 'retry' : 'finish'
3030
}
3131

3232
pod = [secret: workflow.runName + "-secret", mountPath: "/tmp/rdpc_secret"]

process/song_get_analysis.nf

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ process songGetAnalysis {
2424
maxRetries params.max_retries
2525
errorStrategy {
2626
sleep(Math.pow(2, task.attempt) * params.first_retry_wait_time * 1000 as long); // backoff time increases exponentially before each retry
27-
return params.max_retries ? 'retry' : 'terminate'
27+
return params.max_retries ? 'retry' : 'finish'
2828
}
2929

3030
pod = [secret: workflow.runName + "-secret", mountPath: "/tmp/rdpc_secret"]
File renamed without changes.

song-score-download/local_modules/song_get_analysis.nf renamed to song-score-download/local_modules/song-get-analysis.nf

File renamed without changes.

song-score-download/main.nf

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -24,8 +24,6 @@ nextflow.enable.dsl = 2
2424
version = '2.6.0' // package version
2525

2626
// universal params go here, change default value as needed
27-
params.container = ""
28-
params.container_registry = ""
2927
params.publish_dir = "" // set to empty string will disable publishDir
3028

3129
params.max_retries = 5 // set to 0 will disable retry
@@ -73,8 +71,8 @@ score_params = [
7371
]
7472

7573

76-
include { songGetAnalysis } from './local_modules/song_get_analysis' params(song_params)
77-
include { scoreDownload } from './local_modules/score_download' params(score_params)
74+
include { songGetAnalysis } from './local_modules/song-get-analysis' params(song_params)
75+
include { scoreDownload } from './local_modules/score-download' params(score_params)
7876

7977

8078
// please update workflow code as needed

song-score-download/tests/checker.nf

Lines changed: 0 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -50,24 +50,6 @@ params.score_transport_mem = 1 // GB
5050
params.score_url = "https://score.rdpc-qa.cancercollaboratory.org"
5151
params.score_api_token = ""
5252

53-
song_params = [
54-
*:params,
55-
'cpus': params.song_cpus,
56-
'mem': params.song_mem,
57-
'song_url': params.song_url,
58-
'api_token': params.song_api_token ?: params.api_token,
59-
'publish_dir': ''
60-
]
61-
62-
score_params = [
63-
*:params,
64-
'cpus': params.score_cpus,
65-
'mem': params.score_mem,
66-
'transport_mem': params.score_transport_mem,
67-
'song_url': params.song_url,
68-
'score_url': params.score_url,
69-
'api_token': params.score_api_token ?: params.api_token
70-
]
7153

7254
include { SongScoreDownload } from '../main'
7355

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,6 @@
11
{
22
"study_id": "TEST-PR",
3-
"analysis_id": "9940db0f-c100-496a-80db-0fc100d96ac1"
3+
"analysis_id": "9940db0f-c100-496a-80db-0fc100d96ac1",
4+
"max_retries": 3,
5+
"first_retry_wait_time": 5
46
}
Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
{
2+
"study_id": "TEST-PR",
3+
"analysis_id": "9940db0f-c100-496a-80db-0fc100d96ac1",
4+
"max_retries": 0
5+
}

0 commit comments

Comments
 (0)