Function write_csv

python/pathway/tests/utils.py:781–787

(path: str | pathlib.Path, table_def: str, **kwargs)

def write_csv(path: str | pathlib.Path, table_def: str, **kwargs):
    df = _markdown_to_pandas(table_def)
    with tempfile.NamedTemporaryFile(mode="w+", delete=False) as f:
        tmp_path = f.name
        df.to_csv(tmp_path, encoding="utf-8", **kwargs)
    # Move is atomic in POSIX filesystems, that makes the whole write atomic as a result
    os.replace(tmp_path, path)


def write_lines(path: str | pathlib.Path, data: str | list[str]):