@@ -968,14 +968,14 @@ def get_schema_definition(
968968 i.e. fetching view definition of all the views in schema storing it
969969 in cache and using the same cache to fetch the view definition.
970970
971- To fetch defintion for other types of tables, we have used the
971+ To fetch definition for other types of tables, we have used the
972972 get_ddl method, since this method only accepts string literal as arguments
973973 it is not possible to do something like this:
974974
975975 select table_name, schema, get_ddl('table', table_name) from information_schema.tables
976976 so we have to fetch the ddl for each table individually.
977977
978- Alternavies are executing an stroed procedure to automate this but
978+ Alternatives are executing an stored procedure to automate this but
979979 it requires additional permissions like execute which users may not be comfortable doing.
980980 Or reconstruct the ddl from column types, which we can explore in the future.
981981 """
@@ -989,6 +989,10 @@ def get_schema_definition(
989989 schema_definition = inspector .get_stream_definition (
990990 self .connection , table_name , schema_name
991991 )
992+ elif table_type == TableType .Stage :
993+ # Snowflake Stage does not have a DDL or definition,
994+ # so we will return None for stage type
995+ pass
992996 elif self .source_config .includeDDL or table_type == TableType .Dynamic :
993997 schema_definition = inspector .get_table_ddl (
994998 self .connection , table_name , schema_name
0 commit comments