code: def test_read_and_write_parquet(tmp_path):
      file_source = tmp_path.joinpath("sample-file-to-write")
      data_frame = pd.DataFrame(
          {"horizon": 10, "frequency": "W"}, index=[0]
      )
      write_pandas_df_as_parquet(data_frame, file_source)
      serialized_data_frame = read_parquet_as_pandas_df(file_source)
      pd.testing.assert_frame_equal(data_frame, serialized_data_frame)
  
imports: import codecs
  import filecmp
  import hashlib
  import json
  import os
  import shutil
  import stat
  import tarfile
  import jinja2.exceptions
  import pandas
  import pytest
  from pyspark.sql import SparkSession
  import mlflow
  from mlflow.exceptions import MissingConfigException
  from mlflow.utils import file_utils
  from mlflow.utils.file_utils import TempDir, _copy_file_or_tree, _handle_readonly_on_windows, get_parent_dir, get_total_file_size, local_file_uri_to_path, read_parquet_as_pandas_df, write_pandas_df_as_parquet, write_spark_dataframe_to_parquet_on_local_disk
  from mlflow.utils.os import is_windows
  from tests.helper_functions import random_file, random_int, safe_edit_yaml
  from tests.projects.utils import TEST_PROJECT_DIR
label_desc: Use image node_id 14 for calling a global function with example usage: test_read_and_write_parquet(tmp_path) without return types