diff --git a/photoapp/daemon.py b/photoapp/daemon.py index 99cd5a5..7b98532 100644 --- a/photoapp/daemon.py +++ b/photoapp/daemon.py @@ -18,7 +18,7 @@ from photoapp.dbutils import SAEnginePlugin, SATool, db, get_db_engine, date_for from photoapp.utils import auth, require_auth, photoset_auth_filter, slugify, cherryparam, number_format from photoapp.storage import uri_to_storage from photoapp.webutils import validate_password, serve_thumbnail_placeholder -from photoapp.jobs import JobsClient, JobSubscriber +from photoapp.jobs import JobsClient, JobSubscriber, ThreadJobServer from jinja2 import Environment, FileSystemLoader, select_autoescape from sqlalchemy import desc, asc, func, and_, or_ @@ -719,6 +719,13 @@ def main(): library_manager = LibraryManager(library_storage) cache_manager = uri_to_storage(args.cache) + # set up jobs system - this is temporary, this will be something pluggable later + jobs_db_engine = get_db_engine(args.database, debug=args.db_debug) + jobs_server = ThreadJobServer(jobs_db_engine) + jobs_server.run_background() + jobs_client = JobsClient(jobs_db_engine, notifier=jobs_server.queue_notify) + JobSubscriber(jobs_client) + # set up webapp setup_webapp( get_db_engine(args.database, debug=args.db_debug),