def process_queue()

in azure-slurm/slurmcc/cost.py [0:0]

• 12 lines of code
• 5 McCabe index (conditional complexity)

    def process_queue(self) -> dict:
        running_jobs = {}
        queue_rec = self.get_queue_records()
        with open(queue_rec, 'r') as fp:
            data = json.load(fp)

        for job in data['jobs']:
            if job['job_state'] != 'RUNNING' and job['job_state'] != 'CONFIGURING':
                continue
            job_id = job['job_id']
            if job['admin_comment']:
                running_jobs[job_id] = job['admin_comment']
        return running_jobs