Changeset View
Changeset View
Standalone View
Standalone View
swh/scheduler/cli.py
Show First 20 Lines • Show All 492 Lines • ▼ Show 20 Lines | def runner(ctx, period): | ||||
from swh.scheduler.celery_backend.runner import run_ready_tasks | from swh.scheduler.celery_backend.runner import run_ready_tasks | ||||
from swh.scheduler.celery_backend.config import app | from swh.scheduler.celery_backend.config import app | ||||
logger = logging.getLogger(__name__ + '.runner') | logger = logging.getLogger(__name__ + '.runner') | ||||
scheduler = ctx.obj['scheduler'] | scheduler = ctx.obj['scheduler'] | ||||
logger.debug('Scheduler %s' % scheduler) | logger.debug('Scheduler %s' % scheduler) | ||||
try: | try: | ||||
while True: | while True: | ||||
logger.info('Run ready tasks') | logger.debug('Run ready tasks') | ||||
try: | try: | ||||
run_ready_tasks(scheduler, app) | ntasks = len(run_ready_tasks(scheduler, app)) | ||||
if ntasks: | |||||
logger.info('Scheduled %s tasks', ntasks) | |||||
except Exception: | except Exception: | ||||
scheduler.rollback() | scheduler.rollback() | ||||
logger.exception('Unexpected error in run_ready_tasks()') | logger.exception('Unexpected error in run_ready_tasks()') | ||||
if not period: | if not period: | ||||
break | break | ||||
time.sleep(period) | time.sleep(period) | ||||
except KeyboardInterrupt: | except KeyboardInterrupt: | ||||
ctx.exit(0) | ctx.exit(0) | ||||
▲ Show 20 Lines • Show All 122 Lines • Show Last 20 Lines |