Fixed #54 -- Replaced celery task decorator with shared_task.

geodesign · May 18, 2021 · 7ca9407 · 7ca9407
1 parent ca9b3a0
commit 7ca9407
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/raster/tasks.py b/raster/tasks.py
@@ -1,14 +1,14 @@
 import shutil
 import traceback
 
-from celery import group, task
+from celery import group, shared_task
 
 from django.conf import settings
 from raster.tiles.const import GLOBAL_MAX_ZOOM_LEVEL, MIN_ZOOMLEVEL_TASK_PARALLEL
 from raster.tiles.parser import RasterLayerParser
 
 
-@task
+@shared_task
 def create_tiles(rasterlayer_id, zoom, extract_metadata=False):
     """
     Create all tiles for a raster layer at the input zoom level.
@@ -51,7 +51,7 @@ def create_tiles(rasterlayer_id, zoom, extract_metadata=False):
             shutil.rmtree(tmpdir)
 
 
-@task
+@shared_task
 def clear_tiles(rasterlayer_id):
     """
     Drop all tiles of a rasterlayer.
@@ -60,7 +60,7 @@ def clear_tiles(rasterlayer_id):
     parser.drop_all_tiles()
 
 
-@task
+@shared_task
 def send_success_signal(rasterlayer_id):
     """
     Drop empty tiles of a raster layer and send parse succes signal.
@@ -69,7 +69,7 @@ def send_success_signal(rasterlayer_id):
     parser.send_success_signal()
 
 
-@task
+@shared_task
 def all_in_one(rasterlayer_id, zoom_range):
     """
     Parses raster in a single task.