pandaharvester/harvesterworkermaker/base_worker_maker.py

0001 from pandaharvester.harvestercore.plugin_base import PluginBase
0002
0003
0004 # base worker maker
0005 class BaseWorkerMaker(PluginBase):
0006     # constructor
0007     def __init__(self, **kwarg):
0008         PluginBase.__init__(self, **kwarg)
0009
0010     def get_num_jobs_per_worker(self, n_workers):
0011         try:
0012             return self.nJobsPerWorker
0013         except Exception:
0014             return 1
0015
0016     # get number of workers per job which can run concurrently
0017     def get_num_workers_per_job(self, n_workers):
0018         try:
0019             return self.nWorkersPerJob
0020         except Exception:
0021             return 1
0022
0023     # check number of ready resources
0024     def num_ready_resources(self):
0025         try:
0026             return self.nReadyResources
0027         except Exception:
0028             return 1
0029
0030     # get upper limit on the cumulative total of workers per job
0031     def get_max_workers_per_job_in_total(self):
0032         try:
0033             return self.maxWorkersPerJobInTotal
0034         except Exception:
0035             return 10
0036
0037     # get upper limit on the number of new workers per job in a cycle
0038     def get_max_workers_per_job_per_cycle(self):
0039         try:
0040             return self.maxWorkersPerJobPerCycle
0041         except Exception:
0042             return None