Skip to content

Commit 7ca9407

Browse files
committed
Fixed #54 -- Replaced celery task decorator with shared_task.
1 parent ca9b3a0 commit 7ca9407

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

raster/tasks.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,14 @@
11
import shutil
22
import traceback
33

4-
from celery import group, task
4+
from celery import group, shared_task
55

66
from django.conf import settings
77
from raster.tiles.const import GLOBAL_MAX_ZOOM_LEVEL, MIN_ZOOMLEVEL_TASK_PARALLEL
88
from raster.tiles.parser import RasterLayerParser
99

1010

11-
@task
11+
@shared_task
1212
def create_tiles(rasterlayer_id, zoom, extract_metadata=False):
1313
"""
1414
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):
5151
shutil.rmtree(tmpdir)
5252

5353

54-
@task
54+
@shared_task
5555
def clear_tiles(rasterlayer_id):
5656
"""
5757
Drop all tiles of a rasterlayer.
@@ -60,7 +60,7 @@ def clear_tiles(rasterlayer_id):
6060
parser.drop_all_tiles()
6161

6262

63-
@task
63+
@shared_task
6464
def send_success_signal(rasterlayer_id):
6565
"""
6666
Drop empty tiles of a raster layer and send parse succes signal.
@@ -69,7 +69,7 @@ def send_success_signal(rasterlayer_id):
6969
parser.send_success_signal()
7070

7171

72-
@task
72+
@shared_task
7373
def all_in_one(rasterlayer_id, zoom_range):
7474
"""
7575
Parses raster in a single task.

0 commit comments

Comments
 (0)