async def ingest(
        self, data: str | bytes, *args, **kwargs
    ) -> AsyncGenerator[str, None]:
        """Ingest TSV data and yield text from each row."""
        if isinstance(data, bytes):
            data = data.decode("utf-8")
        tsv_reader = self.csv.reader(self.StringIO(data), delimiter="\t")
        for row in tsv_reader:
            yield ", ".join(row)  # Still join with comma for readability
Ingest TSV data and yield text from each row.
py/core/parsers/structured/tsv_parser.py