Run worker from funkwhale-network

funkwhale_network/cli.py

@@ -2,11 +2,13 @@ import asyncio
 import functools
 import ssl
 import sys
+import arq
 
 import aiohttp
 import click
 
 from funkwhale_network.db import DB
+from funkwhale_network.worker import WorkerSettings
 
 from . import output
 
@@ -295,6 +297,7 @@ def aggregate_crawl_results(domains_info):
 @click.option("-v", "--verbose", is_flag=True)
 @click.option("--check", is_flag=True)
 def start(*, check, verbose):
+    arq.worker.run_worker(WorkerSettings)
     # TODO launch runner
     # worker = arq.worker.import_string("funkwhale_network.worker", "Worker")
     # logging.config.dictConfig(worker.logging_config(verbose))