diff --git a/iceprod/credentials/server.py b/iceprod/credentials/server.py index 1f1ed174..3017e03a 100644 --- a/iceprod/credentials/server.py +++ b/iceprod/credentials/server.py @@ -470,7 +470,7 @@ def __init__(self): db_url, db_name = config['DB_URL'].rsplit('/', 1) db = motor.motor_asyncio.AsyncIOMotorClient( db_url, - timeoutMS=config['DB_TIMEOUT'], + timeoutMS=config['DB_TIMEOUT']*1000, w=config['DB_WRITE_CONCERN'], ) logging.info(f'DB name: {db_name}') diff --git a/iceprod/materialization/server.py b/iceprod/materialization/server.py index b69cad45..6694c935 100644 --- a/iceprod/materialization/server.py +++ b/iceprod/materialization/server.py @@ -322,7 +322,7 @@ def __init__(self): db_url, db_name = config['DB_URL'].rsplit('/', 1) db = motor.motor_asyncio.AsyncIOMotorClient( db_url, - timeoutMS=config['DB_TIMEOUT'], + timeoutMS=config['DB_TIMEOUT']*1000, w=config['DB_WRITE_CONCERN'], ) logging.info(f'DB name: {db_name}') diff --git a/iceprod/rest/server.py b/iceprod/rest/server.py index 61a4201d..1a18e5b3 100644 --- a/iceprod/rest/server.py +++ b/iceprod/rest/server.py @@ -105,7 +105,7 @@ def __init__(self, s3_override=None): db_url, db_name = config['DB_URL'].rsplit('/', 1) self.db = motor.motor_asyncio.AsyncIOMotorClient( db_url, - timeoutMS=config['DB_TIMEOUT'], + timeoutMS=config['DB_TIMEOUT']*1000, w=config['DB_WRITE_CONCERN'], ) logging.info(f'DB name: {db_name}')