From 30117ecb943f92822336354def683ab8d5939659 Mon Sep 17 00:00:00 2001 From: Kevin Zhang Date: Tue, 26 Jul 2022 11:12:53 -0700 Subject: [PATCH] Fix lint Signed-off-by: Kevin Zhang --- .../offline_stores/contrib/spark_offline_store/spark_source.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/sdk/python/feast/infra/offline_stores/contrib/spark_offline_store/spark_source.py b/sdk/python/feast/infra/offline_stores/contrib/spark_offline_store/spark_source.py index 734da608f6..454e7ee87e 100644 --- a/sdk/python/feast/infra/offline_stores/contrib/spark_offline_store/spark_source.py +++ b/sdk/python/feast/infra/offline_stores/contrib/spark_offline_store/spark_source.py @@ -177,8 +177,7 @@ def get_table_query_string(self) -> str: """Returns a string that can directly be used to reference this table in SQL""" if self.table: # Backticks make sure that spark sql knows this a table reference. - # return f"`{self.table}`" - table = '.'.join(map(lambda x: f'`{x}`', self.table.split('.'))) + table = ".".join([f"`{x}`" for x in self.table.split(".")]) return table if self.query: return f"({self.query})"