diff --git a/server/src/common/mongodb.ts b/server/src/common/mongodb.ts
index c93be625b..f4afebc3d 100644
--- a/server/src/common/mongodb.ts
+++ b/server/src/common/mongodb.ts
@@ -14,7 +14,10 @@ const ensureInitialization = (client: MongoClient | null): MongoClient => {
   return client;
 };
 
-export const getMongodbUri = (dbName = config.mongodb.dbName) => {
+export const getMongodbUri = (dbName: string = config.mongodb.dbName, withMainDbAuthent: boolean = false) => {
+  if (withMainDbAuthent) {
+    return `${config.mongodb.uri}${dbName}?${config.mongodb.options}&authSource=${config.mongodb.dbName}`;
+  }
   return `${config.mongodb.uri}${dbName}?${config.mongodb.options}`;
 };
 /**
diff --git a/server/src/jobs/hydrate/deca/hydrate-deca-raw.ts b/server/src/jobs/hydrate/deca/hydrate-deca-raw.ts
index 8abc2990f..b56a0c69d 100644
--- a/server/src/jobs/hydrate/deca/hydrate-deca-raw.ts
+++ b/server/src/jobs/hydrate/deca/hydrate-deca-raw.ts
@@ -21,7 +21,7 @@ import { __dirname } from "@/common/utils/esmUtils";
 
 const logger = parentLogger.child({ module: "job:hydrate:contrats-deca-raw" });
 
-const client = new MongoClient(getMongodbUri("airbyte") ?? "");
+const client = new MongoClient(getMongodbUri("airbyte", true));
 
 export async function hydrateDecaRaw() {
   let count = 0;