@@ -112,7 +112,8 @@ class CSVParserAdvanced(AsyncParser[str | bytes]):
for row_num, row in enumerate(csv_reader):
print(row)
chunk_rows.append(row)
- if row_num % num_rows == 0:
+ #if num_rows > 0 and row_num > 0 and row_num % num_rows == 0:
+ if True:
yield (
", ".join(header)
+ "\n"
