text: from typing import Dict, Any
  
  from hetdesrun.models.data_selection import FilteredSource, FilteredSink
  
  from hetdesrun.adapters.local_file.load_file import load_file_from_id
  
  from hetdesrun.adapters.local_file.write_file import write_to_file
  
  
  try:
      with open("VERSION", "r") as version_file:
          VERSION = version_file.read().strip()
  except FileNotFoundError:
      VERSION = "dev snapshot"
  
  
  async def load_data(
      wf_input_name_to_filtered_source_mapping_dict: Dict[str, FilteredSource],
      adapter_key: str,  # pylint: disable=unused-argument
  ) -> Dict[str, Any]:
  
      return {
          wf_input_name: load_file_from_id(str(filtered_source.ref_id))
          for wf_input_name, filtered_source in wf_input_name_to_filtered_source_mapping_dict.items()
      }
  
  
  async def send_data(
      wf_output_name_to_filtered_sink_mapping_dict: Dict[str, FilteredSink],
      wf_output_name_to_value_mapping_dict: Dict[str, Any],
      adapter_key: str,  # pylint: disable=unused-argument
  ) -> Dict[str, Any]:
  
      for (
          wf_output_name,
          filtered_sink,
      ) in wf_output_name_to_filtered_sink_mapping_dict.items():
          df = wf_output_name_to_value_mapping_dict[wf_output_name]
          write_to_file(df, str(filtered_sink.ref_id))
      return {}
  