Page MenuHomeSoftware Heritage
Files F7124231

D1026.diff
No OneTemporary
Actions

D1026.diff
View Options

diff --git a/swh/scheduler/celery_backend/listener.py b/swh/scheduler/celery_backend/listener.py
--- a/swh/scheduler/celery_backend/listener.py
+++ b/swh/scheduler/celery_backend/listener.py
@@ -15,8 +15,7 @@
from kombu import Queue
from celery.events import EventReceiver
-from swh.scheduler import get_scheduler
-from .config import setup_log_handler, app as main_app
+from .config import app as main_app
class ReliableEventReceiver(EventReceiver):
@@ -197,35 +196,11 @@
@click.command()
-@click.option('--cls', '-c', default='local',
- help="Scheduler's class, default to 'local'")
-@click.option(
- '--database', '-d', help='Scheduling database DSN')
-@click.option('--url', '-u',
- help="(Optional) Scheduler's url access")
-@click.option('--log-level', '-l', default='INFO',
- type=click.Choice(logging._nameToLevel.keys()),
- help='Log level (default to INFO)')
-def main(cls, database, url, log_level):
- setup_log_handler(loglevel=log_level, colorize=False,
- format='[%(levelname)s] %(name)s -- %(message)s')
- # logging.basicConfig(level=level)
-
- scheduler = None
- override_config = {}
- if cls == 'local':
- if database:
- override_config = {'scheduling_db': database}
- scheduler = get_scheduler(cls, args=override_config)
- elif cls == 'remote':
- if url:
- override_config = {'url': url}
- scheduler = get_scheduler(cls, args=override_config)
-
- if not scheduler:
- raise ValueError('Scheduler class (local/remote) must be instantiated')
-
- event_monitor(main_app, backend=scheduler)
+@click.pass_context
+def main(ctx):
+ click.echo("Deprecated! Use 'swh-scheduler listener' instead.",
+ err=True)
+ ctx.exit(1)
if __name__ == '__main__':

File Metadata

Mime Type
text/plain
Expires
Dec 21 2024, 2:12 AM (11 w, 4 d ago)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
3226047

Event Timeline

About · Developer information · Legal