import time # from .. import basemodels # celery = basemodels.celery from celery.utils.log import get_task_logger celery_logger = get_task_logger(__name__) from app.server.tasks import celery import imutils @celery.task(bind=True) def sleep_task(self, uuid_name): celery_logger.debug('sleep_task'.format(uuid_name)) msgs = [ {'msg':'Uploaded OK','time':.1}, {'msg':'Segmenting Image...','time':2}, {'msg':'Found: Person, Horse','time':1}, {'msg':'Creating Pix2Pix','time':2} ] for i,m in enumerate(msgs): percent = int(float(i)/float(len(msgs))*100.0) self.update_state( state = 'PROCESSING', meta = { 'percent': percent, 'message': m['msg'], 'uuid': uuid_name }) celery_logger.debug(m['msg']) time.sleep(m['time']) return { 'percent': 100, 'state': 'complete', 'uuid': uuid_name }