File tree Expand file tree Collapse file tree 3 files changed +8
-5
lines changed
Expand file tree Collapse file tree 3 files changed +8
-5
lines changed Original file line number Diff line number Diff line change 11[book ]
22authors = [" Torc Contributors" ]
33language = " en"
4- multilingual = false
54src = " src"
65title = " Torc Documentation"
76description = " Distributed workflow orchestration for complex computational pipelines"
Original file line number Diff line number Diff line change @@ -672,7 +672,7 @@ pub fn schedule_slurm_nodes(
672672
673673 std:: fs:: create_dir_all ( output) ?;
674674
675- for job_num in 0 ..num_hpc_jobs {
675+ for job_num in 1 ..num_hpc_jobs + 1 {
676676 let job_name = format ! ( "{}_{}" , job_prefix, job_num) ;
677677 let script_path = format ! ( "{}/{}.sh" , output, job_name) ;
678678
@@ -700,7 +700,10 @@ pub fn schedule_slurm_nodes(
700700 let job_id_int = job_id
701701 . parse ( )
702702 . expect ( & format ! ( "Failed to parse Slurm job ID {}" , job_id) ) ;
703- info ! ( "running Slurm job {} with ID: {}" , job_name, job_id_int) ;
703+ info ! (
704+ "Submitted Slurm job name={} with ID={}" ,
705+ job_name, job_id_int
706+ ) ;
704707
705708 let event_data = serde_json:: json!( {
706709 "category" : "scheduler" ,
@@ -710,6 +713,7 @@ pub fn schedule_slurm_nodes(
710713 "num_nodes" : scheduler. nodes,
711714 } ) ;
712715
716+ // TODO: move this before submission and set the Slurm name to this ID.
713717 let scheduled_compute_node = models:: ScheduledComputeNodesModel :: new (
714718 workflow_id,
715719 job_id_int,
Original file line number Diff line number Diff line change @@ -224,8 +224,8 @@ impl WorkflowManager {
224224 ) {
225225 Ok ( ( ) ) => {
226226 info ! (
227- "Successfully scheduled {} Slurm job (s) for action {} " ,
228- num_allocations, action_id
227+ "Successfully scheduled {} Slurm allocation (s) for on_workflow_start " ,
228+ num_allocations
229229 ) ;
230230 }
231231 Err ( err) => {
You can’t perform that action at this time.
0 commit comments