|
@@ -32,6 +32,7 @@ class CSVParser(AsyncParser[str | bytes]):
|
|
|
self, data: str | bytes, *args, **kwargs
|
|
self, data: str | bytes, *args, **kwargs
|
|
|
) -> AsyncGenerator[str, None]:
|
|
) -> AsyncGenerator[str, None]:
|
|
|
"""Ingest CSV data and yield text from each row."""
|
|
"""Ingest CSV data and yield text from each row."""
|
|
|
|
|
+ print(data)
|
|
|
if isinstance(data, bytes):
|
|
if isinstance(data, bytes):
|
|
|
data = data.decode("utf-8")
|
|
data = data.decode("utf-8")
|
|
|
csv_reader = self.csv.reader(self.StringIO(data))
|
|
csv_reader = self.csv.reader(self.StringIO(data))
|
