Hertfordshire Senior Challenge Cup stats & predictions

Saturday's Highlight: Watford FC vs. St Albans City

This weekend's clash between Watford FC and St Albans City is set to be one of the most anticipated matches of the season. Watford FC enters the game as favorites, but St Albans City will be looking to prove their critics wrong.

Watford FC's Strengths

• Tactical Discipline: Watford's coach has implemented a rigorous training regime focused on tactical discipline.
• Squad Depth: With a deep bench, Watford can rotate players without compromising on quality.
• Past Performance: Watford has won several key matches this season, building confidence within the team.

St Albans City's Key Players

• Midfield Maestro: Known for his exceptional vision and passing ability.
• Bright Young Striker: A promising forward who has scored crucial goals this season.
• Veteran Defender: Brings experience and leadership to the backline.

Potential Game-Changing Factors

• Injuries: Both teams have key players nursing injuries; their availability could impact the match outcome.
• Crowd Support: The atmosphere at Vicarage Road Stadium is electric, potentially giving Watford an edge.
• Weath<|repo_name|>MarekMalinowski/cluster_management<|file_sep|>/cluster_management.py #!/usr/bin/env python import os import sys import time import datetime import subprocess import signal from cluster_util import * from cluster_log import * from cluster_database import * class Cluster: def __init__(self): self.db = ClusterDatabase() self.logger = ClusterLog(self.db) self.ssh = SSHUtil(self.logger) self.pbs = PBSUtil(self.logger) self.qsub = QsubUtil(self.logger) def setup(self): # Setup logging directory try: os.makedirs(LOG_DIR) self.logger.info('Created logging directory %s' % LOG_DIR) except OSError as e: if e.errno != errno.EEXIST: raise # Setup log file log_file = LOG_DIR + '/' + LOG_FILE_NAME try: with open(log_file,'w'): pass except IOError as e: if e.errno == errno.EEXIST: self.logger.info('Log file already exists') else: raise # Setup log rotation script try: shutil.copy(LOG_ROTATE_SCRIPT_PATH,self.logger.log_dir+LOG_ROTATE_SCRIPT_NAME) os.chmod(self.logger.log_dir+LOG_ROTATE_SCRIPT_NAME,0755) self.logger.info('Created log rotation script %s' % LOG_ROTATE_SCRIPT_NAME) except IOError as e: if e.errno == errno.EEXIST: self.logger.info('Log rotation script already exists') else: raise def start_cluster(self): # Check if cluster is running if not is_cluster_running(): # Start PBS daemons print 'Starting PBS daemons' subprocess.check_call(['start-pbs', '-n', '-u']) # Start database daemon print 'Starting database daemon' db_pid = subprocess.Popen(['postgres','-D',DB_DATA_DIR],close_fds=True).pid # Start log rotation daemon print 'Starting log rotation daemon' logrotate_pid = subprocess.Popen(['bash','-c','bash '+self.logger.log_dir+LOG_ROTATE_SCRIPT_NAME],close_fds=True).pid # Wait for daemons to start up properly before continuing time.sleep(10) # Store daemon pids so we can kill them later if necessary self.db.set_daemon_pids(db_pid=logrotate_pid) else: print 'Cluster already running' def stop_cluster(self): # Kill PBS daemons first because they depend on database daemon which depends on log rotation daemon. # If we don't kill them in this order then we get errors from PBS complaining that its jobs were killed by SIGTERM. pbs_pid = get_pbs_pid() if pbs_pid != None: print 'Stopping PBS daemons' os.kill(pbs_pid,sigterm) db_pid = get_db_pid() if db_pid != None: print 'Stopping database daemon' os.kill(db_pid,sigterm) logrotate_pid = get_logrotate_pid() if logrotate_pid != None: print 'Stopping log rotation daemon' os.kill(logrotate_pid,sigterm) def restart_cluster(self): self.stop_cluster() time.sleep(10) self.start_cluster() class JobManager: def __init__(self): self.cluster = Cluster() def setup_cluster(self): self.cluster.setup() def start_cluster(self): self.cluster.start_cluster() def stop_cluster(self): self.cluster.stop_cluster() def restart_cluster(self): self.cluster.restart_cluster() def run_job_on_node(self,node_name): if __name__ == '__main__': <|file_sep|>#include "node.h" Node::Node(string node_name,string ip_address,int cores,int ram,int disk_space){ this->node_name=node_name; this->ip_address=ip_address; this->cores=cores; this->ram=ram; this->disk_space=disk_space; } Node::~Node(){ } string Node::get_node_name(){ return this->node_name; } string Node::get_ip_address(){ return this->ip_address; } int Node::get_cores(){ return this->cores; } int Node::get_ram(){ return this->ram; } int Node::get_disk_space(){ return this->disk_space; } <|file_sep|>#ifndef NODE_H_ #define NODE_H_ #include using namespace std; class Node{ private: string node_name; string ip_address; int cores; int ram; // Measured in MB int disk_space; // Measured in MB public: Node(string node_name,string ip_address,int cores,int ram,int disk_space); ~Node(); string get_node_name(); string get_ip_address(); int get_cores(); int get_ram(); int get_disk_space(); }; #endif /* NODE_H_ */ <|file_sep|>#include "node_manager.h" using namespace std; NodeManager::NodeManager(){ } NodeManager::~NodeManager(){ } void NodeManager::add_node(Node node){ this->nodes.push_back(node); } void NodeManager::remove_node(string node_name){ for(int i=0;inodes.size();i++){ if(this->nodes[i].get_node_name()==node_name){ this->nodes.erase(this->nodes.begin()+i); break; } } } Node* NodeManager::get_node(string node_name){ for(int i=0;inodes.size();i++){ if(this->nodes[i].get_node_name()==node_name){ return &this->nodes[i]; break; } } return NULL; } vector NodeManager::get_all_nodes(){ vector nodes_vector; for(int i=0;inodes.size();i++){ nodes_vector.push_back(&this->nodes[i]); } return nodes_vector; } <|file_sep|>#include "job_manager.h" using namespace std; JobManager::JobManager(NodeManager& node_manager):node_manager(node_manager){ } JobManager::~JobManager(){ } void JobManager::submit_job(Job job){ vector available_nodes=node_manager.get_all_nodes(); for(int i=0;iget_cores() && job.get_ram()<=available_nodes[i]->get_ram() && job.get_disk_space()<=available_nodes[i]->get_disk_space()){ job.set_node(*available_nodes[i]); break; } } this->jobs.push_back(job); cout<<"Submitted job "< JobManager::get_all_jobs(){ vector jobs_vector; for(int i=0;ijobs.size();i++){ jobs_vector.push_back(&this->jobs[i]); } return jobs_vector; } Job* JobManager::get_job(string job_id){ for(int i=0;ijobs.size();i++){ if(this->jobs[i].get_job_id()==job_id){ return &this->jobs[i]; break; } } return NULL; } void JobManager::print_status(){ cout<<"Jobs currently running:"< running_jobs=get_all_running_jobs(); for(int i=0;iget_job_id()<get_status()<get_cores()<get_ram()<get_disk_space()<get_command_line()<get_start_time().c_str()<get_end_time().c_str()< JobManager::get_all_running_jobs(){ vector running_jobs_vector; for(int i=0;ijobs.size();i++){ if(this->jobs[i].is_running()){ vector::iterator it; for(it=this->jobs[i].checkpoints.begin();it!=this->jobs[i].checkpoints.end();it++){ it=this->jobs[i].checkpoints.erase(it); it--; } if(this->jobs[i].checkpoints.empty()){ this->jobs.erase(this->jobs.begin()+i); i--; continue; } while(!this->jobs[i].checkpoints.empty()){ it=this->jobs[i].checkpoints.begin(); if(*it==1){ this->jobs.erase(this->jobs.begin()+i); i--; continue; this->jobs[i].set_status("Waiting"); this->jobs.erase(this->jobs.begin()+i); i--; continue; this->jobs[i].set_status("Running"); break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; break; continue; continue; continue; continue; continue; continue; continue; continue; continue; continue; continue; continue; continue; continue; continue; continue; continue; continue; continue; continue(); continue; }}}}return running_jobs_vector;} void JobManager::kill_job(string job_id){ for(int i=0;ijobs.size();i++){ if(this->jobs[i].get_job_id()==job_id){ this.jobs.erase(this.jobs.begin()+i); cout<<"Killed job "<