code: def format_to_parquet(src_file, dest_file):
      if not src_file.endswith(".csv"):
          logging.error(
              "Can only accept source files in CSV format, for the moment"
          )
          return
      table = pv.read_csv(src_file)
      pq.write_table(table, dest_file)
  
file_path: data-engineering-zoomcamp/cohorts/2022/week_2_data_ingestion/homework/solution.py
imports: import os
  import logging
  from datetime import datetime
  from airflow import DAG
  from airflow.utils.dates import days_ago
  from airflow.operators.bash import BashOperator
  from airflow.operators.python import PythonOperator
  from google.cloud import storage
  import pyarrow.csv
  import pyarrow.parquet
label_desc: Use image node_id 1 for calling a global function with example usage: format_to_parquet(src_file, dest_file) without return types