Skip to content

Commit

Permalink
make compatible with a table being a csv file path
Browse files Browse the repository at this point in the history
  • Loading branch information
RobinL committed Jun 23, 2024
1 parent f312cab commit 57e0929
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion splink/duckdb/linker.py
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ class DuckDBDataFrame(SplinkDataFrame):
def columns(self) -> list[InputColumn]:
if not hasattr(self, "_columns_cache"):
result = self.linker._con.execute(
f"DESCRIBE {self.physical_name}"
f"DESCRIBE (select * from {self.physical_name} limit 1)"
).fetchall()
self._columns_cache = [
InputColumn(col[0], sql_dialect="duckdb") for col in result
Expand Down

0 comments on commit 57e0929

Please sign in to comment.