bec/bec_atlas
0
0
Fork 0
mirror of https://github.com/bec-project/bec_atlas.git synced 2025-07-13 22:51:49 +02:00
Code Issues Packages Projects Releases Wiki Activity

refactor: cleanup

Browse Source
This commit is contained in:
wakonig_k
2025-02-10 09:26:43 +01:00
parent 9f36a5fca6
commit 61b72953b6
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
backend/bec_atlas/router/deployments_router.py
View File

@ -1,6 +1,7 @@
import json import json
from typing import TYPE_CHECKING from typing import TYPE_CHECKING
from bson import ObjectId
from fastapi import APIRouter, Depends from fastapi import APIRouter, Depends
from bec_atlas.authentication import get_current_user from bec_atlas.authentication import get_current_user
@ -57,7 +58,7 @@ class DeploymentsRouter(BaseRouter):
scan_id (str): The scan id scan_id (str): The scan id
""" """
return self.db.find_one( return self.db.find_one(
"deployments", {"_id": deployment_id}, Deployments, user=current_user "deployments", {"_id": ObjectId(deployment_id)}, Deployments, user=current_user
) )
def update_available_deployments(self): def update_available_deployments(self):
@ -70,6 +71,5 @@ class DeploymentsRouter(BaseRouter):
redis: RedisDatasource = self.datasources.datasources.get("redis") redis: RedisDatasource = self.datasources.datasources.get("redis")
msg = json.dumps([msg.model_dump() for msg in self.available_deployments]) msg = json.dumps([msg.model_dump() for msg in self.available_deployments])
redis.connector.set_and_publish("deployments", msg) redis.connector.set_and_publish("deployments", msg)
if redis.reconfigured_acls: for deployment in credentials:
for deployment in credentials: redis.add_deployment_acl(deployment)
redis.add_deployment_acl(deployment)