streamcorpus_pipeline/_pycassa_simple_table.py
def tasks(self, key_prefix=''):
        '''
        generate the data objects for every task
        '''
        for row in self._tasks.get_range():
            logger.debug(row)
            if not row[0].startswith(key_prefix):
                continue
            data = json.loads(row[1]['task_data'])
            data['task_key'] = row[0]
            yield data
def tasks(self, key_prefix=''):
        '''
        generate the data objects for every task
        '''
        for row in self._tasks.get_range():
            logger.debug(row)
            if not row[0].startswith(key_prefix):
                continue
            data = json.loads(row[1]['task_data'])
            data['task_key'] = row[0]
            yield data
def tasks ( self , key_prefix = '' ) : for row in self . _tasks . get_range ( ) : logger . debug ( row ) if not row [ 0 ] . startswith ( key_prefix ) : continue data = json . loads ( row [ 1 ] [ 'task_data' ] ) data [ 'task_key' ] = row [ 0 ] yield data
generate the data objects for every task
generate the data objects for every task