Commit0fb47b8

committed

Trying to handle within the get_column_specification method

1 parente2cf393 commit0fb47b8Copy full SHA for 0fb47b8

File tree

-0

lines changed

-0

lines changed

Lines changed: 9 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -37,6 +37,15 @@ def get_column_specification(self, column: DatabricksColumn, **kwargs): # TOD`
`37`	`37`	`)`
`38`	`38`	`)`
`39`	`39`
	`40`	`+# Consider the 'liquid_cluster' attribute`
	`41`	`+ifcolumn.dialect_optionsand'liquid'incolumn.dialect_options:`
	`42`	`+liquid_options=column.dialect_options['liquid']`
	`43`	`+if'liquid_cluster'inliquid_optionsandliquid_options['liquid_cluster']:`
	`44`	`+colspec+=" LIQUID_CLUSTER"`
	`45`	`+# TODO this else statement is a debugging line`
	`46`	`+else:`
	`47`	`+print(liquid_options)`
	`48`	`+`
`40`	`49`	`# TODO: debugging line`
`41`	`50`	`print(colspec)`
`42`	`51`

Comments

(0)