Skip to content

Commit f6c1dd0

Browse files
committed
db name fixes (no more suffix)
1 parent aa27742 commit f6c1dd0

File tree

4 files changed

+6
-5
lines changed

4 files changed

+6
-5
lines changed

backend/app/core/providers.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ class DatabaseProvider(Provider):
9090
async def get_database_connection(self, settings: Settings) -> AsyncIterator[AsyncDatabaseConnection]:
9191
db_config = DatabaseConfig(
9292
mongodb_url=settings.MONGODB_URL,
93-
db_name=settings.PROJECT_NAME + "_test" if settings.TESTING else settings.PROJECT_NAME,
93+
db_name=settings.PROJECT_NAME,
9494
server_selection_timeout_ms=5000,
9595
connect_timeout_ms=5000,
9696
max_pool_size=50,

backend/app/services/coordinator/coordinator.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -554,7 +554,7 @@ async def run_coordinator() -> None:
554554
tz_aware=True,
555555
serverSelectionTimeoutMS=5000
556556
)
557-
db_name = settings.PROJECT_NAME + "_test" if settings.TESTING else settings.PROJECT_NAME
557+
db_name = settings.PROJECT_NAME
558558
database = db_client[db_name]
559559

560560
await SchemaManager(database).apply_all()

backend/app/services/k8s_worker/worker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -561,7 +561,7 @@ async def run_kubernetes_worker() -> None:
561561
tz_aware=True,
562562
serverSelectionTimeoutMS=5000
563563
)
564-
db_name = settings.PROJECT_NAME + "_test" if settings.TESTING else settings.PROJECT_NAME
564+
db_name = settings.PROJECT_NAME
565565
database = db_client[db_name]
566566
await db_client.admin.command("ping")
567567
logger.info(f"Connected to database: {db_name}")

backend/scripts/seed_users.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -64,10 +64,11 @@ async def upsert_user(
6464

6565
async def seed_users() -> None:
6666
mongodb_url = os.getenv("MONGODB_URL", "mongodb://mongo:27017/integr8scode")
67-
print("Connecting to MongoDB...")
67+
db_name = os.getenv("PROJECT_NAME", "integr8scode")
68+
69+
print(f"Connecting to MongoDB (database: {db_name})...")
6870

6971
client: AsyncIOMotorClient = AsyncIOMotorClient(mongodb_url)
70-
db_name = mongodb_url.rstrip("/").split("/")[-1].split("?")[0] or "integr8scode"
7172
db = client[db_name]
7273

7374
# Default user

0 commit comments

Comments
 (0)