Ling0925
/
buster
mirror of https://github.com/buster-so/buster.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

introspection fix

This commit is contained in:
dal 2025-10-06 13:21:24 -06:00
parent 9c1466a1ad
commit c6c5b3c12e
No known key found for this signature in database
GPG Key ID: 16F4B0E1E9F61122
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/trigger/src/tasks/introspect-data/get-table-statistics-task.ts
View File

@ -354,7 +354,8 @@ export const getTableStatisticsTask: ReturnType<
dataSourceId: payload.dataSourceId, dataSourceId: payload.dataSourceId,
databaseIdentifier: payload.table.database, databaseIdentifier: payload.table.database,
schema: payload.table.schema, schema: payload.table.schema,
databaseName: payload.table.name, databaseName: payload.table.database,
name: payload.table.name,
metadata, metadata,
}); });

4
packages/database/src/queries/datasets/update-dataset-metadata.ts
View File

@ -9,6 +9,7 @@ const InputSchema = z.object({
databaseIdentifier: z.string().min(1, 'Database identifier is required'), databaseIdentifier: z.string().min(1, 'Database identifier is required'),
schema: z.string().min(1, 'Schema is required'), schema: z.string().min(1, 'Schema is required'),
databaseName: z.string().min(1, 'Database name is required'), databaseName: z.string().min(1, 'Database name is required'),
name: z.string().min(1, 'Dataset/table name is required'),
metadata: DatasetMetadataSchema, metadata: DatasetMetadataSchema,
}); });
@ -34,6 +35,7 @@ export async function updateDatasetMetadata(input: UpdateDatasetMetadataInput) {
eq(datasets.databaseIdentifier, validated.databaseIdentifier), eq(datasets.databaseIdentifier, validated.databaseIdentifier),
eq(datasets.schema, validated.schema), eq(datasets.schema, validated.schema),
eq(datasets.databaseName, validated.databaseName), eq(datasets.databaseName, validated.databaseName),
eq(datasets.name, validated.name),
isNull(datasets.deletedAt) isNull(datasets.deletedAt)
) )
) )
@ -41,7 +43,7 @@ export async function updateDatasetMetadata(input: UpdateDatasetMetadataInput) {
if (!result[0]) { if (!result[0]) {
throw new Error( throw new Error(
`Dataset not found: ${validated.databaseIdentifier}.${validated.schema}.${validated.databaseName}` `Dataset not found: ${validated.databaseIdentifier}.${validated.schema}.${validated.name}`
); );
} }