Skip to content

Commit 542c03b

Browse files
authored
fix(connectors) - pass parentId in upsertDataSourceRemoteTable (#9686)
* enforce the presence of a parentID in upsertDataSourceRemoteTable * pass parentId in snowflake
1 parent 5c7b131 commit 542c03b

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

connectors/src/connectors/snowflake/temporal/activities.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -170,6 +170,7 @@ export async function syncSnowflakeConnection(connectorId: ModelId) {
170170
`${table.databaseName}.${table.schemaName}`,
171171
table.databaseName,
172172
],
173+
parentId: `${table.databaseName}.${table.schemaName}`,
173174
title: table.name,
174175
mimeType: "application/vnd.snowflake.table",
175176
});

connectors/src/lib/data_sources.ts

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -631,6 +631,7 @@ export async function upsertDataSourceRemoteTable({
631631
remoteDatabaseSecretId,
632632
loggerArgs,
633633
parents,
634+
parentId,
634635
title,
635636
mimeType,
636637
}: {
@@ -642,6 +643,7 @@ export async function upsertDataSourceRemoteTable({
642643
remoteDatabaseSecretId: string | null;
643644
loggerArgs?: Record<string, string | number>;
644645
parents: string[];
646+
parentId: string | null;
645647
title: string;
646648
mimeType: string;
647649
}) {
@@ -666,6 +668,7 @@ export async function upsertDataSourceRemoteTable({
666668
const dustRequestPayload: UpsertDatabaseTableRequestType = {
667669
name: tableName,
668670
parents,
671+
parent_id: parentId,
669672
description: tableDescription,
670673
table_id: tableId,
671674
remote_database_table_id: remoteDatabaseTableId,

0 commit comments

Comments
 (0)