diff --git a/setup.py b/setup.py --- a/setup.py +++ b/setup.py @@ -56,6 +56,7 @@ entry_points=""" [swh.cli.subcommands] scheduler=swh.scheduler.cli + scheduler-journal=swh.scheduler.cli.journal """, classifiers=[ "Programming Language :: Python :: 3", diff --git a/swh/scheduler/cli/journal.py b/swh/scheduler/cli/journal.py --- a/swh/scheduler/cli/journal.py +++ b/swh/scheduler/cli/journal.py @@ -6,10 +6,10 @@ import click -from . import cli +from . import cli as cli_scheduler_group -@cli.command("journal-client") +@cli_scheduler_group.command("journal-client") @click.pass_context @click.option( "--stop-after-objects", @@ -19,6 +19,8 @@ help="Maximum number of objects to replay. Default is to run forever.", ) def visit_stats_journal_client(ctx, stop_after_objects): + """Keep the the origin visits stats table up to date from a swh kafka journal + """ from functools import partial from swh.journal.client import get_journal_client