code: 
  
  import os
  
  from apache_beam.io.filesystems import FileSystems
  from apache_beam.pipeline import Pipeline
  
  from .logging import get_logger
  
  
  __snake_case             =	2 << 2_0  # 2mb
  __snake_case             =	get_logger(__name__)
  
  
  
  class   __lowerCamelCase (a_	):
  
  
  
  
  
  
  
         def 		snake_case_  ( self:   str				):
  
  
  
  
  
  
              '''simple docstring'''
  
  
  
  
              __UpperCamelCase   = self._options.get_all_options().get('runner'				)
              return runner in [None, "DirectRunner", "PortableRunner"]
  
  
  
  
  
  
  def 		_A		(		_lowercase				,     _lowercase				,     _lowercase=False   )				->   Optional[Any]:
  
  
       """simple docstring"""
  
  
       __UpperCamelCase   = FileSystems
       if fs.exists(_lowercase   ):
            if force_upload:
                 logger.info(f'''Remote path already exist: {remote_file_path}. Overwriting it as force_upload=True.'''   )
            else:
                 logger.info(f'''Remote path already exist: {remote_file_path}. Skipping it as force_upload=False.'''   )
                 return
       with fs.create(_lowercase   ) as remote_file:
            with open(_lowercase				,     'rb'   ) as local_file:
                 __UpperCamelCase   = local_file.read(_lowercase   )
                 while chunk:
                      remote_file.write(_lowercase   )
                      __UpperCamelCase   = local_file.read(_lowercase   )
  
  
  
  
  
  
  def 		_A		(		_lowercase				,     _lowercase				,     _lowercase=False   )				->   Union[str, Any]:
  
  
       """simple docstring"""
  
  
       __UpperCamelCase   = FileSystems
       if os.path.exists(_lowercase   ):
            if force_download:
                 logger.info(f'''Local path already exist: {remote_file_path}. Overwriting it as force_upload=True.'''   )
            else:
                 logger.info(f'''Local path already exist: {remote_file_path}. Skipping it as force_upload=False.'''   )
                 return
       with fs.open(_lowercase   ) as remote_file:
            with open(_lowercase				,     'wb'   ) as local_file:
                 __UpperCamelCase   = remote_file.read(_lowercase   )
                 while chunk:
                      local_file.write(_lowercase   )
                      __UpperCamelCase   = remote_file.read(_lowercase   )
  
  
  
style_context: 
  
  
  def 		_A		(		_lowercase   )				->   bool:
  
  
       """simple docstring"""
  
  
       if not isinstance(_lowercase				,     _lowercase   ):
            raise ValueError('Input series is not valid, valid series - [1, 2/3, 2]'   )
       if len(_lowercase   ) == 0:
            raise ValueError('Input list must be a non empty list'   )
       if len(_lowercase   ) == 1 and series[0] != 0:
            return True
       __UpperCamelCase   = []
       __UpperCamelCase   = len(_lowercase   )
       for i in range(0				,     _lowercase   ):
            if series[i] == 0:
                 raise ValueError('Input series cannot have 0 as an element'   )
            rec_series.append(1 / series[i]   )
       __UpperCamelCase   = rec_series[1] - rec_series[0]
       for index in range(2				,     _lowercase   ):
            if rec_series[index] - rec_series[index - 1] != common_diff:
                 return False
       return True
  
  
  
  
  
  
  def 		_A		(		_lowercase   )				->   float:
  
  
       """simple docstring"""
  
  
       if not isinstance(_lowercase				,     _lowercase   ):
            raise ValueError('Input series is not valid, valid series - [2, 4, 6]'   )
       if len(_lowercase   ) == 0:
            raise ValueError('Input list must be a non empty list'   )
       __UpperCamelCase   = 0
       for val in series:
            answer += 1 / val
       return len(_lowercase   ) / answer
  
  
  if __name__ == "__main__":
      import doctest
  
      doctest.testmod()
  
  
  