Skip to content
Snippets Groups Projects
Commit 3e90a522 authored by Thomas Kluyver's avatar Thomas Kluyver
Browse files

Merge branch 'feat/db-dir' into 'master'

[Webservice] Put jobs database in separate database directory

See merge request !1073
parents 1d626d33 ac7673bd
No related branches found
No related tags found
1 merge request!1073[Webservice] Put jobs database in separate database directory
...@@ -26,5 +26,5 @@ server-config: ...@@ -26,5 +26,5 @@ server-config:
n-calib: 10 n-calib: 10
web-service: web-service:
job-db: "@format {this.webservice_dir}/webservice_jobs.sqlite" job-db: "@format {this.webservice_dir}/db/webservice_jobs.sqlite"
cal-config: "@format {env[HOME]}/calibration_config/default.yaml" cal-config: "@format {env[HOME]}/calibration_config/default.yaml"
...@@ -7,7 +7,7 @@ web-service: ...@@ -7,7 +7,7 @@ web-service:
port: 5555 port: 5555
bind-to: tcp://* bind-to: tcp://*
allowed-ips: allowed-ips:
job-db: "@format {this.webservice_dir}/webservice_jobs.sqlite" job-db: "@format {this.webservice_dir}/db/webservice_jobs.sqlite"
job-update-interval: 60 job-update-interval: 60
job-timeout: 3600 job-timeout: 3600
......
...@@ -6,7 +6,7 @@ import sys ...@@ -6,7 +6,7 @@ import sys
parser = argparse.ArgumentParser( parser = argparse.ArgumentParser(
description='Check jobs for a given proposal & run number') description='Check jobs for a given proposal & run number')
parser.add_argument('--sqlite-fpath', type=str, help='Path to sqlite file path', parser.add_argument('--sqlite-fpath', type=str, help='Path to sqlite file path',
default='webservice_jobs.sqlite') default='db/webservice_jobs.sqlite')
parser.add_argument('--proposal', type=str, required=True, help='Proposal number') parser.add_argument('--proposal', type=str, required=True, help='Proposal number')
parser.add_argument('--run', type=int, required=True, help='Run number') parser.add_argument('--run', type=int, required=True, help='Run number')
......
...@@ -63,7 +63,9 @@ def init_job_db(config): ...@@ -63,7 +63,9 @@ def init_job_db(config):
:return: a sqlite3 connection instance to the database :return: a sqlite3 connection instance to the database
""" """
logging.info("Initializing database") logging.info("Initializing database")
conn = sqlite3.connect(config['web-service']['job-db']) db_path = Path(config['web-service']['job-db'])
db_path.parent.mkdir(parents=True, exist_ok=True)
conn = sqlite3.connect(db_path)
conn.execute("PRAGMA foreign_keys = ON") conn.execute("PRAGMA foreign_keys = ON")
conn.executescript(""" conn.executescript("""
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment