job_distributors

Bindings for protocols::jd3::job_distributors namespace

class pyrosetta.rosetta.protocols.jd3.job_distributors.JobExtractor

Bases: pybind11_object

assign(self: pyrosetta.rosetta.protocols.jd3.job_distributors.JobExtractor, : pyrosetta.rosetta.protocols.jd3.job_distributors.JobExtractor) → pyrosetta.rosetta.protocols.jd3.job_distributors.JobExtractor

C++: protocols::jd3::job_distributors::JobExtractor::operator=(const class protocols::jd3::job_distributors::JobExtractor &) –> class protocols::jd3::job_distributors::JobExtractor &

complete(self: pyrosetta.rosetta.protocols.jd3.job_distributors.JobExtractor) → bool

C++: protocols::jd3::job_distributors::JobExtractor::complete() const –> bool

get_initial_job_dag_and_queue(self: pyrosetta.rosetta.protocols.jd3.job_distributors.JobExtractor) → pyrosetta.rosetta.protocols.jd3.JobDigraph

C++: protocols::jd3::job_distributors::JobExtractor::get_initial_job_dag_and_queue() –> class std::shared_ptr<class protocols::jd3::JobDigraph>

job_queue_empty(self: pyrosetta.rosetta.protocols.jd3.job_distributors.JobExtractor) → bool

C++: protocols::jd3::job_distributors::JobExtractor::job_queue_empty() const –> bool

jobs_remain(self: pyrosetta.rosetta.protocols.jd3.job_distributors.JobExtractor) → bool

C++: protocols::jd3::job_distributors::JobExtractor::jobs_remain() –> bool

not_done(self: pyrosetta.rosetta.protocols.jd3.job_distributors.JobExtractor) → bool

Should the JobDistributor keep going based on there being jobs in the job queue,

or outstanding jobs that have not completed, or nodes that have not yet been marked as completed, or the JobQueen providing new nodes in the JobDAG

C++: protocols::jd3::job_distributors::JobExtractor::not_done() –> bool

note_job_no_longer_running(self: pyrosetta.rosetta.protocols.jd3.job_distributors.JobExtractor, job_id: int) → None

C++: protocols::jd3::job_distributors::JobExtractor::note_job_no_longer_running(unsigned long) –> void

pop_job_from_queue(self: pyrosetta.rosetta.protocols.jd3.job_distributors.JobExtractor) → pyrosetta.rosetta.protocols.jd3.LarvalJob

C++: protocols::jd3::job_distributors::JobExtractor::pop_job_from_queue() –> class std::shared_ptr<class protocols::jd3::LarvalJob>

push_job_to_front_of_queue(self: pyrosetta.rosetta.protocols.jd3.job_distributors.JobExtractor, job: pyrosetta.rosetta.protocols.jd3.LarvalJob) → None

The JD is allowed to pull jobs out of the queue and then

to reinsert them back into the queue, e.g., as it might do when it has recovered from a checkpoint and needs to re-launch jobs.

C++: protocols::jd3::job_distributors::JobExtractor::push_job_to_front_of_queue(class std::shared_ptr<class protocols::jd3::LarvalJob>) –> void

retrieve_and_reset_node_recently_completed(self: pyrosetta.rosetta.protocols.jd3.job_distributors.JobExtractor) → bool

Did we just declare a node complete? Returns true if so, and

sets the internal tracking variable to false.

C++: protocols::jd3::job_distributors::JobExtractor::retrieve_and_reset_node_recently_completed() –> bool

running_job(self: pyrosetta.rosetta.protocols.jd3.job_distributors.JobExtractor, job_index: int) → pyrosetta.rosetta.protocols.jd3.LarvalJob

C++: protocols::jd3::job_distributors::JobExtractor::running_job(unsigned long) const –> class std::shared_ptr<class protocols::jd3::LarvalJob>

set_job_queen(self: pyrosetta.rosetta.protocols.jd3.job_distributors.JobExtractor, queen: pyrosetta.rosetta.protocols.jd3.JobQueen) → None

dummy for master/slave version

C++: protocols::jd3::job_distributors::JobExtractor::set_job_queen(class std::shared_ptr<class protocols::jd3::JobQueen>) –> void

set_maximum_jobs_to_hold_in_memory(self: pyrosetta.rosetta.protocols.jd3.job_distributors.JobExtractor, max_njobs_at_once: int) → None

C++: protocols::jd3::job_distributors::JobExtractor::set_maximum_jobs_to_hold_in_memory(unsigned long) –> void

class pyrosetta.rosetta.protocols.jd3.job_distributors.VanillaJobDistributor

Bases: JobDistributor

The VanillaJobDistributor is a single process running by itself, running a single thread.

assign(self: pyrosetta.rosetta.protocols.jd3.job_distributors.VanillaJobDistributor, : pyrosetta.rosetta.protocols.jd3.job_distributors.VanillaJobDistributor) → pyrosetta.rosetta.protocols.jd3.job_distributors.VanillaJobDistributor

C++: protocols::jd3::job_distributors::VanillaJobDistributor::operator=(const class protocols::jd3::job_distributors::VanillaJobDistributor &) –> class protocols::jd3::job_distributors::VanillaJobDistributor &

go(self: pyrosetta.rosetta.protocols.jd3.job_distributors.VanillaJobDistributor, queen: pyrosetta.rosetta.protocols.jd3.JobQueen) → None

The main method for executing a protocol.

C++: protocols::jd3::job_distributors::VanillaJobDistributor::go(class std::shared_ptr<class protocols::jd3::JobQueen>) –> void