code: def _ReadStorageMetadata(self):
      
      query = 'SELECT key, value FROM metadata'
      self._cursor.execute(query)
  
      metadata_values = {row[0]: row[1] for row in self._cursor.fetchall()}
  
      self._compression_format = metadata_values['compression_format']
docs: Reads the task storage metadata.