old_contents: '''
  Return data to a Cassandra ColumFamily
  
  Here's an example Keyspace/ColumnFamily setup that works with this
  returner::
  
      create keyspace salt;
      use salt;
      create column family returns
        with key_validation_class='UTF8Type'
        and comparator='UTF8Type'
        and default_validation_class='UTF8Type';
  '''
  
  import logging
  import pycassa
  
  log = logging.getLogger(__name__)
  
  __opts__ = {'cassandra.servers': ['localhost:9160'],
              'cassandra.keyspace': 'salt',
              'cassandra.column_family': 'returns',
              'cassandra.consistency_level': 'ONE'}
  
  def returner(ret):
      '''
      Return data to a Cassandra ColumnFamily
      '''
  
      consistency_level = getattr(pycassa.ConsistencyLevel,
                                  __opts__['cassandra.consistency_level'])
  
      pool = pycassa.ConnectionPool(__opts__['cassandra.keyspace'],
                                    __opts__['cassandra.servers'])
      cf = pycassa.ColumnFamily(pool, __opts__['cassandra.column_family'],
                                write_consistency_level=consistency_level)
  
      columns = {'fun': ret['fun'],
                 'id': ret['id']}
      if isinstance(ret['return'], dict):
          for key, value in ret['return'].iteritems():
              columns['return.%s' % (key,)] = str(value)
      else:
          columns['return'] = str(ret['return'])
  
      log.debug(back)
      cf.insert(ret['jid'], columns)
  
new_contents: '''
  Return data to a Cassandra ColumFamily
  
  Here's an example Keyspace/ColumnFamily setup that works with this
  returner::
  
      create keyspace salt;
      use salt;
      create column family returns
        with key_validation_class='UTF8Type'
        and comparator='UTF8Type'
        and default_validation_class='UTF8Type';
  '''
  
  import logging
  import pycassa
  
  log = logging.getLogger(__name__)
  
  __opts__ = {'cassandra.servers': ['localhost:9160'],
              'cassandra.keyspace': 'salt',
              'cassandra.column_family': 'returns',
              'cassandra.consistency_level': 'ONE'}
  
  def returner(ret):
      '''
      Return data to a Cassandra ColumnFamily
      '''
  
      consistency_level = getattr(pycassa.ConsistencyLevel,
                                  __opts__['cassandra.consistency_level'])
  
      pool = pycassa.ConnectionPool(__opts__['cassandra.keyspace'],
                                    __opts__['cassandra.servers'])
      cf = pycassa.ColumnFamily(pool, __opts__['cassandra.column_family'],
                                write_consistency_level=consistency_level)
  
      columns = {'fun': ret['fun'],
                 'id': ret['id']}
      if isinstance(ret['return'], dict):
          for key, value in ret['return'].iteritems():
              columns['return.%s' % (key,)] = str(value)
      else:
          columns['return'] = str(ret['return'])
  
      log.debug(columns)
      cf.insert(ret['jid'], columns)
  
subject: Debug statement used the wrong variable.