Function remove_comments_from_file

python/pathway/internals/schema.py:962–965

(f: Iterable[str], comment_char: str | None)

    """

    def remove_comments_from_file(f: Iterable[str], comment_char: str | None):
        for line in f:
            if line.lstrip()[0] != comment_char:
                yield line

    with open(path) as f:
        csv_reader = csv.DictReader(