snakemake.scheduler.JobScheduler

class snakemake.scheduler.JobScheduler(workflow, executor_plugin)[source]
__init__(workflow, executor_plugin)[source]

Create a new instance of KnapsackJobScheduler.

Methods

__init__(workflow, executor_plugin)

Create a new instance of KnapsackJobScheduler.

calc_resource(name, value)

error_callback(job)

executor_error_callback(exception)

exit_gracefully(*args)

get_executor(job)

job_reward(job)

job_selector_greedy(jobs)

Using the greedy heuristic from "A Greedy Algorithm for the General Multidimensional Knapsack Problem", Akcay, Li, Xu, Annals of Operations Research, 2012

job_selector_ilp(jobs)

Job scheduling by optimization of resource usage by solving ILP using pulp

job_weight(job)

progress()

Display the progress.

required_by_job(temp_file, job)

rule_weight(rule)

run(jobs[, executor])

schedule()

Schedule jobs that are ready, maximizing cpu usage.

update_queue_input_jobs()

Attributes

open_jobs

Return open jobs.

remaining_jobs

Return jobs to be scheduled including not yet ready ones.

stats