ores.scoring_systems package

Submodules

ores.scoring_systems.celery_queue module

class ores.scoring_systems.celery_queue.CeleryQueue(*args, application, queue_maxsize=None, task_tracker=None, **kwargs)[source]

Bases: ores.scoring_systems.scoring_system.ScoringSystem

classmethod from_config(config, name, section_key='scoring_systems')[source]
ores.scoring_systems.celery_queue.PASS_HOST_PORT = re.compile('(:(?P<password>[^@]+)@)?(?P<host>[^:]+)?(:(?P<port>[0-9]+))?')

Matches <password>@<host>:<port>

ores.scoring_systems.celery_queue.redis_from_url(url)[source]

Converts a redis URL used by celery into a redis.Redis object.

ores.scoring_systems.process_pool module

class ores.scoring_systems.process_pool.ProcessPool(*args, workers=None, **kwargs)[source]

Bases: ores.scoring_systems.scoring_system.ScoringSystem

classmethod from_config(config, name, section_key='scoring_systems')[source]

ores.scoring_systems.scoring_system module

class ores.scoring_systems.scoring_system.ScoringSystem(context_map, score_cache=None, metrics_collector=None, timeout=None, lock_manager=None, connections_per_ip=4, connections_per_ip_hard=7, whitelisted_ips=[])[source]

Bases: dict

check_context_models(request)[source]
classmethod from_config(config, name, section_key='scoring_systems')[source]
score(request)[source]

ores.scoring_systems.single_thread module

class ores.scoring_systems.single_thread.SingleThread(context_map, score_cache=None, metrics_collector=None, timeout=None, lock_manager=None, connections_per_ip=4, connections_per_ip_hard=7, whitelisted_ips=[])[source]

Bases: ores.scoring_systems.scoring_system.ScoringSystem

classmethod from_config(config, name, section_key='scoring_systems')[source]

Module contents

class ores.scoring_systems.ScoringSystem(context_map, score_cache=None, metrics_collector=None, timeout=None, lock_manager=None, connections_per_ip=4, connections_per_ip_hard=7, whitelisted_ips=[])[source]

Bases: dict

check_context_models(request)[source]
classmethod from_config(config, name, section_key='scoring_systems')[source]
score(request)[source]
class ores.scoring_systems.SingleThread(context_map, score_cache=None, metrics_collector=None, timeout=None, lock_manager=None, connections_per_ip=4, connections_per_ip_hard=7, whitelisted_ips=[])[source]

Bases: ores.scoring_systems.scoring_system.ScoringSystem

classmethod from_config(config, name, section_key='scoring_systems')[source]
class ores.scoring_systems.ProcessPool(*args, workers=None, **kwargs)[source]

Bases: ores.scoring_systems.scoring_system.ScoringSystem

classmethod from_config(config, name, section_key='scoring_systems')[source]
class ores.scoring_systems.CeleryQueue(*args, application, queue_maxsize=None, task_tracker=None, **kwargs)[source]

Bases: ores.scoring_systems.scoring_system.ScoringSystem

classmethod from_config(config, name, section_key='scoring_systems')[source]