summaryrefslogtreecommitdiff
path: root/megapixels/app/server/tasks/blur.py
diff options
context:
space:
mode:
Diffstat (limited to 'megapixels/app/server/tasks/blur.py')
-rw-r--r--megapixels/app/server/tasks/blur.py15
1 files changed, 9 insertions, 6 deletions
diff --git a/megapixels/app/server/tasks/blur.py b/megapixels/app/server/tasks/blur.py
index 42977097..74798cee 100644
--- a/megapixels/app/server/tasks/blur.py
+++ b/megapixels/app/server/tasks/blur.py
@@ -14,14 +14,14 @@ import app.settings.app_cfg as cfg
from app.server.tasks import celery
from celery.utils.log import get_task_logger
-celery_logger = get_task_logger(__name__)
+log = get_task_logger(__name__)
import imutils
@celery.task(bind=True)
def blur_task(self, uuid_name, fn):
"""Process image and update during"""
- celery_logger.debug('process_image_task, uuid: {}'.format(uuid_name))
- celery_logger.debug('fn: {}'.format(fn))
+ log.debug('process_image_task, uuid: {}'.format(uuid_name))
+ log.debug('fn: {}'.format(fn))
files = []
@@ -48,7 +48,7 @@ def blur_task(self, uuid_name, fn):
fn = uuid_name + '_blur.jpg'
fpath = os.path.join(cfg.DIR_SITE_USER_CONTENT, fn)
im_blur_pil.save(fpath, 'JPEG', quality=80)
- celery_logger.debug('fpath: {}'.format(fpath))
+ log.debug('fpath: {}'.format(fpath))
print('fpath: {}'.format(fpath))
# files.append({
@@ -58,7 +58,10 @@ def blur_task(self, uuid_name, fn):
meta['step'] += 1
meta['message'] = 'Applying blur'
- meta['data']['blur_fn'] = os.path.join('/user_content/', fn)
+ meta['data']['blur_fn'] = {
+ 'title': 'Blurred image',
+ 'url': os.path.join('/user_content/', fn)
+ }
self.update_state(state='PROCESSING', meta=meta)
time.sleep(3)
@@ -70,7 +73,7 @@ def blur_task(self, uuid_name, fn):
self.update_state(state='PROCESSING', meta=meta)
time.sleep(2)
- celery_logger.debug('done!!')
+ log.debug('done!!')
meta['step'] = meta['total']
meta['state'] = 'complete'