ensure there is no space in the client name

Author: sanderegg

services/autoscaling/src/simcore_service_autoscaling/modules/redis.py

@@ -5,6 +5,8 @@
 from servicelib.redis import RedisClientSDK
 from settings_library.redis import RedisDatabase, RedisSettings
 
+from .._meta import APP_NAME
+
 logger = logging.getLogger(__name__)
 
 
@@ -14,7 +16,7 @@ async def on_startup() -> None:
         settings: RedisSettings = app.state.settings.AUTOSCALING_REDIS
         redis_locks_dsn = settings.build_redis_dsn(RedisDatabase.LOCKS)
         app.state.redis_client_sdk = client = RedisClientSDK(
-            redis_locks_dsn, client_name=app.title
+            redis_locks_dsn, client_name=APP_NAME
         )
         await client.setup()
 

services/clusters-keeper/src/simcore_service_clusters_keeper/modules/clusters_management_task.py

@@ -6,6 +6,7 @@
 from servicelib.background_task import start_periodic_task, stop_periodic_task
 from servicelib.redis_utils import exclusive
 
+from .._meta import APP_NAME
 from ..core.settings import ApplicationSettings
 from ..modules.redis import get_redis_client
 from .clusters_management_core import check_clusters
@@ -19,7 +20,7 @@ def on_app_startup(app: FastAPI) -> Callable[[], Awaitable[None]]:
     async def _startup() -> None:
         app_settings: ApplicationSettings = app.state.settings
 
-        lock_key = f"{app.title}:clusters-management_lock"
+        lock_key = f"{APP_NAME}:clusters-management_lock"
         lock_value = json.dumps({})
         app.state.clusters_cleaning_task = start_periodic_task(
             exclusive(get_redis_client(app), lock_key=lock_key, lock_value=lock_value)(

services/clusters-keeper/src/simcore_service_clusters_keeper/modules/redis.py

@@ -5,6 +5,7 @@
 from servicelib.redis import RedisClientSDK
 from settings_library.redis import RedisDatabase, RedisSettings
 
+from .._meta import APP_NAME
 from ..core.settings import get_application_settings
 
 logger = logging.getLogger(__name__)
@@ -16,7 +17,7 @@ async def on_startup() -> None:
         settings: RedisSettings = get_application_settings(app).CLUSTERS_KEEPER_REDIS
         redis_locks_dsn = settings.build_redis_dsn(RedisDatabase.LOCKS)
         app.state.redis_client_sdk = client = RedisClientSDK(
-            redis_locks_dsn, client_name=app.title
+            redis_locks_dsn, client_name=APP_NAME
         )
         await client.setup()
 

services/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/_task.py

@@ -10,6 +10,7 @@
 from servicelib.redis_utils import exclusive
 from settings_library.redis import RedisDatabase
 
+from ..._meta import APP_NAME
 from . import _scheduler_factory
 
 _logger = logging.getLogger(__name__)
@@ -26,7 +27,7 @@ async def start_scheduler() -> None:
             _logger, level=logging.INFO, msg="starting computational scheduler"
         ):
             redis_clients_manager: RedisClientsManager = app.state.redis_clients_manager
-            lock_key = f"{app.title}:computational_scheduler"
+            lock_key = f"{APP_NAME}:computational_scheduler"
             app.state.scheduler = scheduler = await _scheduler_factory.create_from_db(
                 app
             )

services/director-v2/src/simcore_service_director_v2/modules/redis.py

@@ -2,6 +2,7 @@
 from servicelib.redis import RedisClientsManager, RedisManagerDBConfig
 from settings_library.redis import RedisDatabase
 
+from .._meta import APP_NAME
 from ..core.settings import AppSettings
 
 
@@ -18,7 +19,7 @@ async def on_startup() -> None:
                 )
             },
             settings=settings.REDIS,
-            client_name=app.title,
+            client_name=APP_NAME,
         )
         await redis_clients_manager.setup()
 

services/dynamic-scheduler/src/simcore_service_dynamic_scheduler/services/redis.py

@@ -4,6 +4,8 @@
 from servicelib.redis import RedisClientSDK, RedisClientsManager, RedisManagerDBConfig
 from settings_library.redis import RedisDatabase, RedisSettings
 
+from .._meta import APP_NAME
+
 _DECODE_DBS: Final[set[RedisDatabase]] = {
     RedisDatabase.LOCKS,
 }
@@ -24,7 +26,7 @@ async def on_startup() -> None:
             {RedisManagerDBConfig(x, decode_responses=False) for x in _BINARY_DBS}
             | {RedisManagerDBConfig(x, decode_responses=True) for x in _DECODE_DBS},
             settings,
-            client_name=app.title,
+            client_name=APP_NAME,
         )
         await manager.setup()
 

services/efs-guardian/src/simcore_service_efs_guardian/services/modules/redis.py

@@ -5,6 +5,8 @@
 from servicelib.redis import RedisClientSDK
 from settings_library.redis import RedisDatabase, RedisSettings
 
+from ..._meta import APP_NAME
+
 logger = logging.getLogger(__name__)
 
 
@@ -14,7 +16,7 @@ async def on_startup() -> None:
         settings: RedisSettings = app.state.settings.EFS_GUARDIAN_REDIS
         redis_locks_dsn = settings.build_redis_dsn(RedisDatabase.LOCKS)
         app.state.redis_lock_client_sdk = lock_client = RedisClientSDK(
-            redis_locks_dsn, client_name=app.title
+            redis_locks_dsn, client_name=APP_NAME
         )
         await lock_client.setup()
 

services/resource-usage-tracker/src/simcore_service_resource_usage_tracker/_meta.py

@@ -19,7 +19,7 @@
 API_VERSION: Final[VersionStr] = info.__version__
 API_VTAG: Final[VersionTag] = parse_obj_as(VersionTag, info.api_prefix_path_tag)
 SUMMARY: Final[str] = info.get_summary()
-
+APP_NAME: Final[str] = PROJECT_NAME
 
 # NOTE: https://texteditor.com/ascii-frames/
 APP_STARTED_BANNER_MSG = r"""

services/resource-usage-tracker/src/simcore_service_resource_usage_tracker/services/modules/redis.py

@@ -5,6 +5,8 @@
 from servicelib.redis import RedisClientSDK
 from settings_library.redis import RedisDatabase, RedisSettings
 
+from ..._meta import APP_NAME
+
 logger = logging.getLogger(__name__)
 
 
@@ -14,7 +16,7 @@ async def on_startup() -> None:
         settings: RedisSettings = app.state.settings.RESOURCE_USAGE_TRACKER_REDIS
         redis_locks_dsn = settings.build_redis_dsn(RedisDatabase.LOCKS)
         app.state.redis_client_sdk = client = RedisClientSDK(
-            redis_locks_dsn, client_name=app.title
+            redis_locks_dsn, client_name=APP_NAME
         )
         await client.setup()