Job Array

If you haven't done yet, download Samples by:

svn co file:///home/fuji/repos/workshop ./workshop

Checkout Sample files onto local machine, (linux shell)

svn co svn+ssh://USERID@cypress1.tulane.edu/home/fuji/repos/workshop ./workshop

---

If you are running a large number of serial jobs, it is recommended to submit them as a job array to make the best use of your allocated resources.

Use Array Task ID as a Parameter to the code

Get into JobArray1 directory under workshop,

[fuji@cypress1 ~]$ cd workshop
[fuji@cypress1 workshop]$ cd JobArray1/
[fuji@cypress1 JobArray1]$ ls
hello2.py  slurmscript

There is a python script that is

[fuji@cypress1 JobArray1]$ cat hello2.py
# HELLO PYTHON
import sys
import datetime
import socket

if (len(sys.argv) < 2):
	print '%s [taskID]' % (sys.argv[0])
        sys.exit()
#
taskID = int(sys.argv[1])
now = datetime.datetime.now()
print 'Hello, world!'
print now.isoformat()
print socket.gethostname()
print 'My Task ID = %d' % taskID

This python script takes a number from the command-line and prints it. You can run it on the login node as,

[fuji@cypress1 JobArray1]$ python ./hello2.py 123
Hello, world!
2018-08-22T13:47:28.572176
cypress1
My Task ID = 123

Look at slurmscript,

[fuji@cypress1 JobArray1]$ cat slurmscript
#!/bin/bash
#SBATCH --qos=workshop            # Quality of Service
#SBATCH --partition=workshop      # partition
#SBATCH --job-name=python       # Job Name
#SBATCH --time=00:01:00         # WallTime
#SBATCH --nodes=1               # Number of Nodes
#SBATCH --ntasks-per-node=1     # Number of tasks (MPI processes)
#SBATCH --cpus-per-task=1       # Number of threads per task (OMP threads)
#SBATCH --array=0-9             # Array of IDs=0,1,2,3,4,5,6,7,8,9

module load anaconda
python hello2.py $SLURM_ARRAY_TASK_ID

array

This

#SBATCH --array=0-9             # Array of IDs=0,1,2,3,4,5,6,7,8,9

The argument can be specific array index values, a range of index values, and an optional step size. For example,

#SBATCH --array=0-31  # Submit a job array with index values between 0 and 31

#SBATCH --array=1,3,5,7 # Submit a job array with index values of 1, 3, 5 and 7

#SBATCH --array=1-7:2 # Submit a job array with index values between 1 and 7 with a step size of 2 (i.e. 1, 3, 5 and 7)

Note that the minimum index value is zero.

Job ID and Environment Variables

Job arrays will have two additional environment variable set. SLURM_ARRAY_JOB_ID will be set to the first job ID of the array. SLURM_ARRAY_TASK_ID will be set to the job array index value. SLURM_ARRAY_TASK_COUNT will be set to the number of tasks in the job array. SLURM_ARRAY_TASK_MAX will be set to the highest job array index value. SLURM_ARRAY_TASK_MIN will be set to the lowest job array index value.

In slurmscript above, SLURM_ARRAY_TASK_ID is given to the python code as,

python hello2.py $SLURM_ARRAY_TASK_ID

so that the hello2.py prints the task ID.

Submit a Job

[fuji@cypress1 JobArray1]$ sbatch slurmscript
Submitted batch job 773958

After the job completed, you will see 10 new files as (it may take a while)

[fuji@cypress1 JobArray1]$ ls
hello2.py           slurm-773958_1.out  slurm-773958_3.out  slurm-773958_5.out  slurm-773958_7.out  slurm-773958_9.out
slurm-773958_0.out  slurm-773958_2.out  slurm-773958_4.out  slurm-773958_6.out  slurm-773958_8.out  slurmscript

The default log file name is slurm-[Job ID]_[Task_ID].out.

[fuji@cypress1 JobArray1]$ cat slurm-773958_9.out
Hello, world!
2018-08-22T14:01:44.492109
cypress01-117
My Task ID = 9

Use Array Task ID to define the script file name

Get into JobArray2 directory under workshop,

[fuji@cypress1 ~]$ cd workshop/JobArray2/
[fuji@cypress1 JobArray2]$ ls
hello2.py    script01.sh  script03.sh  script05.sh  script07.sh  script09.sh   slurmscript2
script00.sh  script02.sh  script04.sh  script06.sh  script08.sh  slurmscript1
[fuji@cypress1 JobArray2]$

Look at slurmscript1

[fuji@cypress1 JobArray2]$ cat slurmscript1
#!/bin/bash
#SBATCH --qos=workshop            # Quality of Service
#SBATCH --partition=workshop      # partition
#SBATCH --job-name=python       # Job Name
#SBATCH --time=00:01:00         # WallTime
#SBATCH --nodes=1               # Number of Nodes
#SBATCH --ntasks-per-node=1     # Number of tasks (MPI processes)
#SBATCH --cpus-per-task=1       # Number of threads per task (OMP threads)
#SBATCH --array=0-9             # Array of IDs=0,1,2,3,4,5,6,7,8,9

sh ./script$(printf "%02d" $SLURM_ARRAY_TASK_ID).sh

The last line, script$(printf "%02d" $SLURM_ARRAY_TASK_ID).sh makes the files name using $SLURM_ARRAY_TASK_ID, so it will run script00.sh, script01.sh, script00.sh, … and script09.sh.

Submit job,

[fuji@cypress1 JobArray2]$ sbatch slurmscript1
Submitted batch job 773970

Cancel Jobs in Job Array

Look at slurmscript12

[fuji@cypress1 JobArray2]$ cat slurmscript2
#!/bin/bash
#SBATCH --qos=workshop            # Quality of Service
#SBATCH --partition=workshop      # partition
#SBATCH --job-name=python       # Job Name
#SBATCH --time=00:01:00         # WallTime
#SBATCH --nodes=1               # Number of Nodes
#SBATCH --ntasks-per-node=1     # Number of tasks (MPI processes)
#SBATCH --cpus-per-task=1       # Number of threads per task (OMP threads)
#SBATCH --array=0-9             # Array of IDs=0,1,2,3,4,5,6,7,8,9

sh ./script$(printf "%02d" $SLURM_ARRAY_TASK_ID).sh

sleep 60

There is sleep 60 so each task runs 60 seconds. Submit job and look at the jobs running/queued.

[fuji@cypress1 JobArray2]$ sbatch slurmscript2
Submitted batch job 773980
[fuji@cypress1 JobArray2]$ squeue -u fuji
     JOBID    QOS               NAME     USER ST       TIME NO NODELIST(REASON)
  773980_0 worksh             python     fuji  R       0:04  1 cypress01-117
  773980_1 worksh             python     fuji  R       0:04  1 cypress01-117
  773980_2 worksh             python     fuji  R       0:04  1 cypress01-117
  773980_3 worksh             python     fuji  R       0:04  1 cypress01-117
  773980_4 worksh             python     fuji  R       0:04  1 cypress01-117
  773980_5 worksh             python     fuji  R       0:04  1 cypress01-117
  773980_6 worksh             python     fuji  R       0:04  1 cypress01-117
  773980_7 worksh             python     fuji  R       0:04  1 cypress01-117
  773980_8 worksh             python     fuji  R       0:04  1 cypress01-117
  773980_9 worksh             python     fuji  R       0:04  1 cypress01-117

To cancel 773980_1 only,

[fuji@cypress1 JobArray2]$ scancel 773980_1
[fuji@cypress1 JobArray2]$ squeue -u fuji
     JOBID    QOS               NAME     USER ST       TIME NO NODELIST(REASON)
  773980_0 worksh             python     fuji  R       0:18  1 cypress01-117
  773980_2 worksh             python     fuji  R       0:18  1 cypress01-117
  773980_3 worksh             python     fuji  R       0:18  1 cypress01-117
  773980_4 worksh             python     fuji  R       0:18  1 cypress01-117
  773980_5 worksh             python     fuji  R       0:18  1 cypress01-117
  773980_6 worksh             python     fuji  R       0:18  1 cypress01-117
  773980_7 worksh             python     fuji  R       0:18  1 cypress01-117
  773980_8 worksh             python     fuji  R       0:18  1 cypress01-117
  773980_9 worksh             python     fuji  R       0:18  1 cypress01-117

To cancel tasks 5-8,

[fuji@cypress1 JobArray2]$ scancel 773980_[5-8]
[fuji@cypress1 JobArray2]$ squeue -u fuji
     JOBID    QOS               NAME     USER ST       TIME NO NODELIST(REASON)
  773980_0 worksh             python     fuji  R       0:30  1 cypress01-117
  773980_2 worksh             python     fuji  R       0:30  1 cypress01-117
  773980_3 worksh             python     fuji  R       0:30  1 cypress01-117
  773980_4 worksh             python     fuji  R       0:30  1 cypress01-117
  773980_9 worksh             python     fuji  R       0:30  1 cypress01-117

To cancel all tasks,

[fuji@cypress1 JobArray2]$ scancel 773980
[fuji@cypress1 JobArray2]$ squeue -u fuji
     JOBID    QOS               NAME     USER ST       TIME NO NODELIST(REASON)