old_contents: #!/usr/bin/env python3
  
  import logging
  import time
  import os
  import sqlalchemy
  from data_processing.tools import io
  
  # Configure logging
  logger = logging.getLogger('EEEE')
  logger.setLevel(logging.INFO)
  ch = logging.StreamHandler()
  ch.setLevel(logging.INFO)
  formatter = logging.Formatter('%(asctime)s %(message)s',
                                datefmt='%Y-%m-%d %I:%M:%S')
  ch.setFormatter(formatter)
  logger.addHandler(ch)
  
  # get current time and inform about start
  total_time = time.time()
  logger.info('eGo data processing started...')
  
  # list of sql_snippets that process the data in correct order
  snippet_dir = 'sql_snippets'
  sql_snippets = ['process_vg250.sql']
  
  # get database connection
  conn = io.oedb_session(section='oedb')
  
  # iterate over list of sql snippets and execute them
  for snippet in sql_snippets:
      # timing and logging
      snippet_time = time.time()
      logger.info("Execute '{}' ...".format(snippet))
      snippet_str = open(os.path.join(snippet_dir, snippet)).read()
  
      # execute desired sql snippet
      conn.execute(snippet_str)
  
      # inform the user
      logger.info('...successfully done in {:.2f} seconds.'.format(
          time.time() - snippet_time))
  
  logger.info('Data processing script successfully executed in {:.2f} seconds'.format(
      time.time() - total_time))
new_contents: #!/usr/bin/env python3
  
  import logging
  import time
  import os
  from data_processing.tools import io
  
  # Configure logging
  logger = logging.getLogger('EEEE')
  logger.setLevel(logging.INFO)
  ch = logging.StreamHandler()
  ch.setLevel(logging.INFO)
  formatter = logging.Formatter('%(asctime)s %(message)s',
                                datefmt='%Y-%m-%d %I:%M:%S')
  ch.setFormatter(formatter)
  logger.addHandler(ch)
  
  # get current time and inform about start
  total_time = time.time()
  logger.info('eGo data processing started...')
  
  # list of sql_snippets that process the data in correct order
  snippet_dir = 'sql_snippets'
  sql_snippets = ['process_vg250.sql']
  
  # get database connection
  conn = io.oedb_session(section='oedb')
  
  # iterate over list of sql snippets and execute them
  for snippet in sql_snippets:
      # timing and logging
      snippet_time = time.time()
      logger.info("Execute '{}' ...".format(snippet))
      snippet_str = open(os.path.join(snippet_dir, snippet)).read()
  
      # execute desired sql snippet
      conn.execute(snippet_str)
  
      # inform the user
      logger.info('...successfully done in {:.2f} seconds.'.format(
          time.time() - snippet_time))
  
  logger.info('Data processing script successfully executed in {:.2f} seconds'.format(
      time.time() - total_time))
subject: Remove unused import