小编kni*_*oid的帖子

When I use Django Celery apply_async with eta, it does the job immediately

i looked at celery documentation and trying something from it but it not work like the example. maybe i'm wrong at some point, please give me some pointer if i'm wrong about the following code

in views.py i have something like this:

class Something(CreateView):
  model = something

  def form_valid(self, form):
    obj = form.save(commit=False)
    number = 5
    test_limit = datetime.now() + timedelta(minutes=5)
    testing_something.apply_async((obj, number), eta=test_limit)
    obj.save()
Run Code Online (Sandbox Code Playgroud)

and in celery tasks i wrote something like this:

@shared_task()
def add_number(obj, number):
    base = …
Run Code Online (Sandbox Code Playgroud)

python django celery celery-task django-celery

8
推荐指数
1
解决办法
5192
查看次数

标签 统计

celery ×1

celery-task ×1

django ×1

django-celery ×1

python ×1