27 lines
692 B
Python
27 lines
692 B
Python
import pickle
|
|
from celery import Celery
|
|
from datetime import date
|
|
|
|
celery = Celery('tasks', backend='redis://localhost', broker='redis://localhost')
|
|
|
|
def serializingTask(function):
|
|
@celery.task
|
|
def wrapper(string):
|
|
(args, kargs) = pickle.loads(string)
|
|
return function(*args, **kargs)
|
|
delay = wrapper.delay
|
|
wrapper.delay = lambda *args, **kargs: delay(pickle.dumps((args, kargs)))
|
|
wrapper.direct = function
|
|
return wrapper
|
|
|
|
@celery.task
|
|
def add(x, y):
|
|
print(x)
|
|
return x + y
|
|
|
|
@serializingTask
|
|
def findIt(start, end):
|
|
format = '%d.%m.%Y'
|
|
print(start.strftime(format))
|
|
print(end.strftime(format))
|
|
pass |