diff --git a/packages/server/src/api/controllers/table/utils.ts b/packages/server/src/api/controllers/table/utils.ts index 7e2d1060eb..e2036c8115 100644 --- a/packages/server/src/api/controllers/table/utils.ts +++ b/packages/server/src/api/controllers/table/utils.ts @@ -324,7 +324,7 @@ class TableSaveFunctions { importRows: this.importRows, user: this.user, }) - if (db.isSqsEnabledForTenant()) { + if (dbCore.isSqsEnabledForTenant()) { await sdk.tables.sqs.addTable(table) } return table diff --git a/packages/server/src/sdk/app/rows/search.ts b/packages/server/src/sdk/app/rows/search.ts index 6ead244601..b7d7889c94 100644 --- a/packages/server/src/sdk/app/rows/search.ts +++ b/packages/server/src/sdk/app/rows/search.ts @@ -16,7 +16,7 @@ import { ExportRowsParams, ExportRowsResult } from "./search/types" import { dataFilters } from "@budibase/shared-core" import sdk from "../../index" import { searchInputMapping } from "./search/utils" -import { db } from "@budibase/backend-core" +import { db as dbCore } from "@budibase/backend-core" export { isValidFilter } from "../../../integrations/utils" @@ -115,7 +115,7 @@ export async function search( if (isExternalTable) { return external.search(options, table) - } else if (db.isSqsEnabledForTenant()) { + } else if (dbCore.isSqsEnabledForTenant()) { return sqs.search(options, table) } else { return internal.search(options, table) diff --git a/packages/server/src/sdk/app/tables/getters.ts b/packages/server/src/sdk/app/tables/getters.ts index a775a6d37e..725c4e5cd2 100644 --- a/packages/server/src/sdk/app/tables/getters.ts +++ b/packages/server/src/sdk/app/tables/getters.ts @@ -1,4 +1,4 @@ -import { context, db, env } from "@budibase/backend-core" +import { context, db as dbCore, env } from "@budibase/backend-core" import { getTableParams } from "../../../db/utils" import { breakExternalTableId, @@ -33,7 +33,7 @@ export function processTable(table: Table): Table { sourceId: table.sourceId || INTERNAL_TABLE_SOURCE_ID, sourceType: TableSourceType.INTERNAL, } - if (db.isSqsEnabledForTenant()) { + if (dbCore.isSqsEnabledForTenant()) { processed.sql = !!env.SQS_SEARCH_ENABLE } return processed