This repository trains an LSTM model using global event logs from the OSPool to make inferences on whether held jobs should be released or removed.
In addition, distributed learning workflow via DAGMan is used for training with Weight & Biases integration for model tracking and hyperparemeters sweeping.
The goal is to parse job event logs into tensors that incorporates temporal information. Imagine a single tensor as a 3D data object. The orange shaded slice (call this primary job) represents the historical record of a job that has gone on a hold state, but eventually finished its execution. The remaining slices behind are records of other jobs that co-exists during the timeframe of the primary job (defined as when it was submitted to when it goes to history). This part is what gives information on the current state of the environment by sampling how the other jobs are behaving while the primary job exists.
The actual shape of the tensor is e * m * j
e: the events that Condor records (official docs).
m: the number of time frames where the length of each frame in seconds is by timeframe_len in /distributed/config.yaml.
j: number of jobs sampled in which the first job is the primary job and j-1 other jobs exists in the timeframe of the primary job.
The e * m slices (historical records) are a series of one-hot encoding of the event logs. Think of each historical records as a finite-state machine and its transitions across time. For the sake of an example, let's have five categorical events, so 0=job submitted, 1=input file transfer, 2=job execute, 3=job on hold, 4=ouput file transfer, 5=terminated, so e=6. The primary job has the sequence of events in its event log:
0 (time=00:01:00)
1 (time=00:03:00)
2 (time=00:04:00)
3 (time=00:05:00)
4 (time=00:07:00)
2 (time=00:10:00)
5 (time=00:13:00)
Let m=14, timeframe_len=60, j=2. These means that the state of the job is checked every 60 seconds, with a maximum of 14 samples, and imputation is used to fill in the blanks. After parsing, the tensor of the primary job looks like:
| 0 | 1 | 2 | 3 | 4 | 5 |
| - | - | - | - | - | - |
| 1 | 0 | 0 | 0 | 0 | 0 |
| 1 | 0 | 0 | 0 | 0 | 0 |
| 0 | 1 | 0 | 0 | 0 | 0 |
| 0 | 0 | 1 | 0 | 0 | 0 |
| 0 | 0 | 0 | 1 | 0 | 0 |
| 0 | 0 | 0 | 1 | 0 | 0 |
| 0 | 0 | 0 | 0 | 1 | 0 |
| 0 | 0 | 0 | 0 | 1 | 0 |
| 0 | 0 | 0 | 0 | 1 | 0 |
| 0 | 0 | 1 | 0 | 0 | 0 |
| 0 | 0 | 1 | 0 | 0 | 0 |
| 0 | 0 | 1 | 0 | 0 | 0 |
| 0 | 0 | 0 | 0 | 0 | 1 |
| 0 | 0 | 0 | 0 | 0 | 1 |
This process is repeated for j-1 jobs. As mentioned, the first historical record is the job that had gone on hold.
Tensors are parsed from global event logs. In CHTC or the OSPool, gather the global event logs using condor_config_val EVENT_LOG to find the path
Most likely, there are multiple global event logs which Condor keeps, simply concatenate them together into a single catenated global event log (CGEL).
geldparse.py takes two arguments: pproc.sub <input_CGEL_pathname> <output_CGEL_pathname>
Edit the pproc.sub's arguments, transfer_input_files, and transfer_output_files accordingly, as it is the submit description for geldparse.py
Run condor_submit pproc.sub in the pproc/ directory, and the output are the tensors for training.
The distributed training workflow integrates Weight & Biases (wandb) for model tracking. To configure, see config.yaml.
Configure the the fields under wandb in the yaml file to set up your wandb experiments.
Do not touch sweep_id nor run_id as they are helper runtime variables.
See wandb documentation for more details.
See preprocessing and training in config.yaml to define sweep parameters.
Configure the hyperparameters search space in /distributed/config.yaml
** Have the cwd in distributed/ **
- Set the number of runs and epochs per run in
distributed/config.yaml. - Run
daggen.pyto generate the submit descriptionpipeline.dag condor_submit_dag pipeline.dagto submit on Condor- After the workflow is complete,
distributed/cleanup.pywill organize the output files - Look for
bestmodel.infofile to see best performing model according to f-measure. If desired, it is possible to change the metric to evaluate for indistributed/config.yaml
Training has early stopping in which the run is terminated after a certain number of epochs in which the model performance does not improve. See earlystop_threshold in distributed/config.yaml.
The LSTM neural network model is not unique to the workflow. To change the model architecture, visit distributed/run/model_init.py, and change the class construction of the neural network to what is desired.
Thanks to Tim Cartwright's initial job-event-log-to-csv script for the motivation behind converting text files into tensors. In addition, Igor Sfiligoi and his student Immanuel Bareket (repo) for the idea behind representing jobs as a finite-state machine, and this inspired our tensor design.