Geek Answers Handbook

Eta celery task is off using rabbitmq

I have problems with Celery that run fine using the default settings in manuals and rabbitmq running on ubuntu. Everything is fine when I plan a task without delay, but when I give them eta, they are planned in the future, as if my watch had gone somewhere.

Here is what python code is asking for tasks:

for index, to_address in enumerate(email_addresses):
        # schedule one email every two seconds
        delay = index * 2
        log.info("MessageUsersFormView.process_action() scheduling task,"
            "email to %s, countdown = %i" % (to_address, delay) )
        tasks.send_email.apply_async(args=[to_address, subject, body],
            countdown = delay)

So, the first one should exit right away, and then every two seconds. Looking at my console with celery, the first happens immediately, and then the rest is planned for two seconds, but starting tomorrow:

[2012-03-09 17:32:40,988: INFO/MainProcess] Got task from broker: stabil.tasks.send_email[24fafc0b-071b-490b-a808-29d47bbee435]
[2012-03-09 17:32:40,989: INFO/MainProcess] Got task from broker: stabil.tasks.send_email[3eb6c3ea-2c84-4368-babe-8a2ac0093836] eta:[2012-03-10 01:32:42.971072-08:00]
[2012-03-09 17:32:40,991: INFO/MainProcess] Got task from broker: stabil.tasks.send_email[a53110d6-b704-4d9c-904a-8d74b99a33af] eta:[2012-03-10 01:32:44.971779-08:00]
[2012-03-09 17:32:40,992: INFO/MainProcess] Got task from broker: stabil.tasks.send_email[2363329b-47e7-4edd-b38e-b09fed232003] eta:[2012-03-10 01:32:46.972422-08:00]

I am completely new to Celery and RabbitMQ, so any advice on how to fix this or where to look for the cause will be great. This is in the VMWare Ubuntu virtual machine, but I set the clock correctly. Thank you

+5
1

, , . ( INFO/MainProcess) , eta UTC. :

ETA, :

2012-03-10 01:32:42.971072-08:00

8 (-08:00 - ), :

2012-03-09 17:32:42.971072

2 :

2012-03-09 17:32:40,989

, . .

+2

More articles:


All Articles