Skip to content

Commit d89ca03

Browse files
committed
code tidy
1 parent d10662a commit d89ca03

File tree

3 files changed

+10
-4
lines changed

3 files changed

+10
-4
lines changed

countess/core/plugins.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -231,6 +231,10 @@ def execute(
231231
]
232232
if len(tablenames_filenames_and_params) == 0:
233233
return None
234+
235+
for num, (tablename, filename, _) in enumerate(tablenames_filenames_and_params, 1):
236+
logger.debug("DuckdbLoadFilePlugin.execute File #%d %s %s", num, tablename, repr(filename))
237+
234238
row_limit_per_file = (row_limit // len(tablenames_filenames_and_params)) if row_limit else None
235239
logger.debug("row_limit_per_file %s", row_limit_per_file)
236240

countess/plugins/csv.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -101,6 +101,7 @@ class SaveCsvOrderParameter(TabularMultiParam):
101101
order_by = ColumnChoiceParam("Order By")
102102
descending = BooleanParam("Descending")
103103

104+
104105
class SaveCsvPlugin(DuckdbSaveFilePlugin):
105106
name = "CSV Save"
106107
description = "Save data as CSV or similar delimited text files"
@@ -126,10 +127,11 @@ def execute(
126127
) -> None:
127128
filename = self.filename.value
128129

129-
if len(self.sorting):
130+
if source is None:
131+
return
132+
elif len(self.sorting):
130133
order_by = ",".join(
131-
duckdb_escape_identifier(sp.order_by.value) + (" desc" if sp.descending else "")
132-
for sp in self.sorting
134+
duckdb_escape_identifier(sp.order_by.value) + (" desc" if sp.descending else "") for sp in self.sorting
133135
)
134136
logger.debug("SaveCsvPlugin.execute order_by %s", order_by)
135137
table = source.order(order_by)

countess/plugins/frequency.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ def prepare(self, ddbc: DuckDBPyConnection, source: Optional[DuckDBPyRelation])
2525
# set default values for converting "count" columns
2626
if not any(cp.value for cp in self.columns):
2727
for cp in self.columns:
28-
if 'count' in cp.label:
28+
if "count" in cp.label:
2929
cp.value = True
3030

3131
def sql(self, table_name: str, columns: Iterable[str]) -> Optional[str]:

0 commit comments

Comments
 (0)