django.db.utils.ProgrammingError: can't adapt type 'DeferredAttribute'
@receiver(post_save, sender=Posts)
def create_task(sender, instance, **kwargs):
if instance.autoup:
interval = instance.autoup_type
run.apply_async(args=[instance.id, interval], eta=instance.next_run)
@task(name="run")
def run(instance_id, interval):
date = now()
next_run = date + timedelta(minutes=interval)
models.Posts.objects.filter(
pk=instance_id).update(date=date, next_run=next_run)
interval
.next_run
меняется на поставленный интервал но новая задача не ставитсяapply_async
?, но все равно не очень понятно почему не работает второй раз @receiver(post_save, sender=Posts)
def create_task(sender, instance, **kwargs):
run.apply_async(eta=instance.next_run)
celery worker
выдает [2019-08-27 15:28:30,847: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [Errno 61] Connection refused.
Trying again in 2.00 seconds...