Skip to content

Commit 765d0cb

Browse files
claudious96ddutt
authored andcommitted
Fix check on empty dataset
Without this fix we read empty datasets that resulted in several warnings. Signed-off-by: Claudio Usai <[email protected]>
1 parent c90ebbf commit 765d0cb

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

suzieq/db/parquet/parquetdb.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@ def read(self, table_name: str, data_format: str,
129129
dataset = ds.dataset(elem, format='parquet',
130130
partitioning='hive')
131131

132-
if not dataset:
132+
if not dataset.files:
133133
continue
134134

135135
tmp_df = self._process_dataset(dataset, namespace, start,

0 commit comments

Comments
 (0)