def dog_entries_parquet_lz4(dog_entries, cloud_test_catalog) -> bytes:
    """
    Returns dogs entries in lz4 compressed parquet format
    """
    src_uri = cloud_test_catalog.src_uri

    def _adapt_row(row):
        """
        Adjusting row values to match remote response
        """
        adapted = {}
        for k, v in row.items():
            if isinstance(v, datetime):
                adapted[k] = v.timestamp()
            elif v is None:
                adapted[k] = ""
            else:
                adapted[k] = v

        adapted["sys__id"] = 1
        adapted["sys__rand"] = 1
        adapted["file__location"] = ""
        adapted["file__source"] = src_uri
        adapted["file__version"] = ""
        return adapted

    dog_entries = [_adapt_row(e) for e in dog_entries]
    df = pd.DataFrame.from_records(dog_entries)
    buffer = io.BytesIO()
    df.to_parquet(buffer, engine="auto")

    return lz4.frame.compress(buffer.getvalue())

    Returns dogs entries in lz4 compressed parquet format
    
tests/func/test_pull.py