Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
386 changes: 356 additions & 30 deletions sqlmesh/core/engine_adapter/athena.py

Large diffs are not rendered by default.

2,244 changes: 1 addition & 2,243 deletions web/client/openapi.json

Large diffs are not rendered by default.

12 changes: 6 additions & 6 deletions web/client/src/api/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,8 @@ import {
getModelsApiModelsGet,
type ModelLineageApiLineageModelNameGet200,
modelLineageApiLineageModelNameGet,
type ColumnLineageApiLineageModelNameColumnNameGet200,
columnLineageApiLineageModelNameColumnNameGet,
type ColumnLineageApiLineageModelNameColumnsColumnNameGet200,
columnLineageApiLineageModelNameColumnsColumnNameGet,
fetchdfApiCommandsFetchdfPost,
renderApiCommandsRenderPost,
type RenderInput,
Expand All @@ -51,7 +51,7 @@ import {
getModelApiModelsNameGet,
getApiModulesApiModulesGet,
type Modules,
type ColumnLineageApiLineageModelNameColumnNameGetParams,
type ColumnLineageApiLineageModelNameColumnsColumnNameGetParams,
} from './client'
import {
useNotificationCenter,
Expand Down Expand Up @@ -213,13 +213,13 @@ export function useApiColumnLineage(
model: string,
column: string,
options?: ApiOptions,
params?: ColumnLineageApiLineageModelNameColumnNameGetParams,
): UseQueryWithTimeoutOptions<ColumnLineageApiLineageModelNameColumnNameGet200> {
params?: ColumnLineageApiLineageModelNameColumnsColumnNameGetParams,
): UseQueryWithTimeoutOptions<ColumnLineageApiLineageModelNameColumnsColumnNameGet200> {
return useQueryWithTimeout(
{
queryKey: ['/api/lineage', model, column],
queryFn: async ({ signal }) =>
await columnLineageApiLineageModelNameColumnNameGet(
await columnLineageApiLineageModelNameColumnsColumnNameGet(
model,
column,
params,
Expand Down
4 changes: 2 additions & 2 deletions web/client/src/library/components/graph/ModelColumns.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ import clsx from 'clsx'
import {
type ColumnDescription,
type Column,
type ColumnLineageApiLineageModelNameColumnNameGet200,
type ColumnLineageApiLineageModelNameColumnsColumnNameGet200,
type LineageColumn,
type LineageColumnSource,
type LineageColumnExpression,
Expand Down Expand Up @@ -391,7 +391,7 @@ function ModelColumn({
expression?: LineageColumnExpression
withDescription?: boolean
updateColumnLineage: (
lineage: ColumnLineageApiLineageModelNameColumnNameGet200,
lineage: ColumnLineageApiLineageModelNameColumnsColumnNameGet200,
) => void
removeEdges: (columnId: string) => void
selectManually?: React.Dispatch<
Expand Down
8 changes: 4 additions & 4 deletions web/client/src/models/sqlmesh-model.ts
Original file line number Diff line number Diff line change
Expand Up @@ -24,8 +24,8 @@ export class ModelSQLMeshModel<

name: string
fqn: string
path: string
full_path: string
path: string = ''
full_path: string = ''
dialect: string
type: ModelType
columns: Column[]
Expand All @@ -50,8 +50,8 @@ export class ModelSQLMeshModel<
this.name = encodeURI(this.initial.name)
this.fqn = encodeURI(this.initial.fqn)
this.default_catalog = this.initial.default_catalog
this.path = this.initial.path
this.full_path = this.initial.full_path
this.path = this.initial.path ?? ''
this.full_path = this.initial.full_path ?? ''
this.dialect = this.initial.dialect
this.description = this.initial.description
this.sql = this.initial.sql
Expand Down
2 changes: 1 addition & 1 deletion web/server/api/endpoints/environments.py
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ async def get_environments(
)


@router.delete("/{environment:str}")
@router.delete("/{environment:path}")
async def delete_environment(
response: Response,
environment: str,
Expand Down
4 changes: 2 additions & 2 deletions web/server/api/endpoints/lineage.py
Original file line number Diff line number Diff line change
Expand Up @@ -130,7 +130,7 @@ def create_models_only_lineage_adjacency_list(
return graph


@router.get("/{model_name:str}/{column_name:str}")
@router.get("/{model_name:path}/columns/{column_name:str}")
def column_lineage(
model_name: str,
column_name: str,
Expand All @@ -150,7 +150,7 @@ def column_lineage(
)


@router.get("/{model_name:str}")
@router.get("/{model_name:path}")
def model_lineage(
model_name: str,
context: Context = Depends(get_loaded_context),
Expand Down
2 changes: 1 addition & 1 deletion web/server/api/endpoints/models.py
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ def get_models(context: Context = Depends(get_loaded_context)) -> t.List[models.


@router.get(
"/{name:str}",
"/{name:path}",
response_model=models.Model,
response_model_exclude_unset=True,
response_model_exclude_none=True,
Expand Down