def get_jobs_from_queue(self, queue: str, max_jobs: int) -> List[Job]:
        """Get jobs from a queue."""
        jobs_json_string = self._run_script(
            self._get_jobs_from_queue,
            self._to_namespaced(queue),
            self._to_namespaced(RUNNING_JOBS_KEY.format(self._id)),
            JobStatus.RUNNING.value,
            max_jobs
        )

        jobs = json.loads(jobs_json_string.decode())
        jobs = [Job.deserialize(job) for job in jobs]

        return jobs
def get_jobs_from_queue ( self , queue : str , max_jobs : int ) -> List [ Job ] : jobs_json_string = self . _run_script ( self . _get_jobs_from_queue , self . _to_namespaced ( queue ) , self . _to_namespaced ( RUNNING_JOBS_KEY . format ( self . _id ) ) , JobStatus . RUNNING . value , max_jobs ) jobs = json . loads ( jobs_json_string . decode ( ) ) jobs = [ Job . deserialize ( job ) for job in jobs ] return jobs
Get jobs from a queue.