Changeset View
Changeset View
Standalone View
Standalone View
swh/scheduler/backend.py
Show First 20 Lines • Show All 55 Lines • ▼ Show 20 Lines | def __init__(self, db, min_pool_conns=1, max_pool_conns=10): | ||||
) | ) | ||||
self._db = None | self._db = None | ||||
def get_db(self): | def get_db(self): | ||||
if self._db: | if self._db: | ||||
return self._db | return self._db | ||||
return BaseDb.from_pool(self._pool) | return BaseDb.from_pool(self._pool) | ||||
def put_db(self, db): | |||||
if db is not self._db: | |||||
db.put_conn() | |||||
task_type_keys = [ | task_type_keys = [ | ||||
'type', 'description', 'backend_name', 'default_interval', | 'type', 'description', 'backend_name', 'default_interval', | ||||
'min_interval', 'max_interval', 'backoff_factor', 'max_queue_length', | 'min_interval', 'max_interval', 'backoff_factor', 'max_queue_length', | ||||
'num_retries', 'retry_delay', | 'num_retries', 'retry_delay', | ||||
] | ] | ||||
@db_transaction() | @db_transaction() | ||||
def create_task_type(self, task_type, db=None, cur=None): | def create_task_type(self, task_type, db=None, cur=None): | ||||
▲ Show 20 Lines • Show All 413 Lines • Show Last 20 Lines |