Skip to content

Commit

Permalink
Fix
Browse files Browse the repository at this point in the history
Signed-off-by: Kevin Zhang <kzhang@tecton.ai>
  • Loading branch information
kevjumba committed Apr 4, 2022
1 parent b96a3ab commit 9ff0ac1
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 4 deletions.
8 changes: 6 additions & 2 deletions sdk/python/feast/infra/offline_stores/snowflake_source.py
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,11 @@ def __init__(
_schema = "PUBLIC" if (database and table and not schema) else schema

self.snowflake_options = SnowflakeOptions(
database=database, schema=_schema, table=table, query=query, warehouse=warehouse
database=database,
schema=_schema,
table=table,
query=query,
warehouse=warehouse,
)

# If no name, use the table as the default name
Expand Down Expand Up @@ -301,7 +305,7 @@ def warehouse(self):
"""Returns the warehouse name of this snowflake table."""
return self._warehouse

@table.setter
@warehouse.setter
def warehouse(self, warehouse):
"""Sets the warehouse name of this snowflake table."""
self._warehouse = warehouse
Expand Down
2 changes: 0 additions & 2 deletions sdk/python/feast/templates/snowflake/bootstrap.py
Original file line number Diff line number Diff line change
Expand Up @@ -81,8 +81,6 @@ def bootstrap():
replace_str_in_file(driver_file, "SNOWFLAKE_WAREHOUSE", snowflake_warehouse)




def replace_str_in_file(file_path, match_str, sub_str):
with open(file_path, "r") as f:
contents = f.read()
Expand Down

0 comments on commit 9ff0ac1

Please sign in to comment.