| #!/usr/bin/python -S |
| |
| """Python implementation of the experiment framework.""" |
| |
| import os |
| import subprocess |
| |
| import utils |
| |
| _EXPERIMENTS_TMP_DIR = '/tmp/experiments' |
| _EXPERIMENTS_DIR = '/config/experiments' |
| |
| _experiment_warned = set() |
| _experiment_enabled = set() |
| |
| |
| def register(name): |
| try: |
| rv = subprocess.call(['register_experiment', name]) |
| except OSError as e: |
| utils.log('register_experiment: %s', e) |
| else: |
| if rv: |
| utils.log('Failed to register experiment %s.', name) |
| |
| |
| def enabled(name): |
| """Check whether an experiment is enabled. |
| |
| Copy/pasted from waveguide/helpers.py. |
| |
| Args: |
| name: The name of the experiment to check. |
| |
| Returns: |
| Whether the experiment is enabled. |
| """ |
| if not os.path.exists(os.path.join(_EXPERIMENTS_TMP_DIR, |
| name + '.available')): |
| if name not in _experiment_warned: |
| _experiment_warned.add(name) |
| utils.log('Warning: experiment %r not registered.', name) |
| else: |
| is_enabled = os.path.exists(os.path.join(_EXPERIMENTS_DIR, |
| name + '.active')) |
| if is_enabled and name not in _experiment_enabled: |
| _experiment_enabled.add(name) |
| utils.log('Notice: using experiment %r.', name) |
| elif not is_enabled and name in _experiment_enabled: |
| _experiment_enabled.remove(name) |
| utils.log('Notice: stopping experiment %r.', name) |
| return is_enabled |