Changeset View
Changeset View
Standalone View
Standalone View
swh/scheduler/cli.py
Show First 20 Lines • Show All 655 Lines • ▼ Show 20 Lines | def ghtorrent(ctx, verbose): | ||||
from swh.scheduler.updater.backend import SchedulerUpdaterBackend | from swh.scheduler.updater.backend import SchedulerUpdaterBackend | ||||
ght_config = ctx.obj['config'].get('ghtorrent', {}) | ght_config = ctx.obj['config'].get('ghtorrent', {}) | ||||
back_config = ctx.obj['config'].get('scheduler_updater', {}) | back_config = ctx.obj['config'].get('scheduler_updater', {}) | ||||
backend = SchedulerUpdaterBackend(**back_config) | backend = SchedulerUpdaterBackend(**back_config) | ||||
GHTorrentConsumer(backend, **ght_config).run() | GHTorrentConsumer(backend, **ght_config).run() | ||||
def main(): | |||||
return cli(auto_envvar_prefix='SWH_SCHEDULER') | |||||
if __name__ == '__main__': | if __name__ == '__main__': | ||||
cli() | main() |