in llm_swarm/__init__.py [0:0]
def is_job_running(job_id: str):
"""Given job id, check if the job is in eunning state (needed to retrieve hostname from logs)"""
command = "squeue --me --states=R | awk '{print $1}' | tail -n +2"
my_running_jobs = subprocess.run(command, shell=True, text=True, capture_output=True).stdout.splitlines()
return job_id in my_running_jobs