supervisor.py 文件源码

def main(cli_config, raw, by_queue, queues, **options):
    """RQ command-line monitor."""
    try:
        with Connection(redis_conn):
            refresh(0.1, show_prism_info, queues, raw, by_queue,
                    cli_config.queue_class, cli_config.worker_class)
    except ConnectionError as e:
        click.echo(e)
        sys.exit(1)
    except KeyboardInterrupt:
        click.echo()
        sys.exit(0)