Python-сообщество

class ImportThread(Thread):
    def __init__(self, import_product_query):
        Thread.__init__(self)
        self.import_query = import_query
        self.total_imported = 0
        
    def run(self):
        time.sleep(10)
        while True:
            if self.import_query.total() > 0:
                try: 
                    import_data = self.import_query.get()
                except Exception, e:
                    log.exception(e)
                finally:
                    pass
                time.sleep(0.5)
            else:
                time.sleep(10)
    
    def get_status(self):
        return (self.import_query.total(), self.total_imported)

class ImportQuery(object):  
    
    def get(self):
        pass

    def total(self):
        pass
    
    def total_imported(self):
        pass
        
    def get_status(self, company_id, key_uniq=None):
        pass