#celery

upgrading from celery 2.x to 3.0. we have some code that uses celery.task.control.inspect; however, though i have a worker running, at times celery.task.control.inspect().stats() returns None. why might that be?

pbx: maybe timeout is too low

ionelmc - good theory, but no, i get None regardless of what timeout i pass to inspect()

pbx: you always get none or some times?

ionelmc - "always" for my present purposes. i.e. can't coax the actual worker info out of inspect() now

the api for that call seems to have changed but the docs are mum

rabbitmq is finally running..i have run add_user, now rabbitmqctl add_vhost myvhost, i wonder whther myvhost is the same as server where listed in rabbit@server?

After i started celeryd, I get consumer: Connected to amqp://testuser@127.0.0.1:5672/myvhost. it seems connected, but whenever I add a task, there's no response there

do I know need to create any queue in rabbitmq?

emilyq: Did you add a user in rabbit and grant that user permission to that vhost?

(the same user you define in your celery config)

mdeboard: yes just added, the task got picked up by the queue already and seems completed already. but AsyncResult state always pending

Ah, don't know much about that stuff sorry

in upgrading from 2.x to 3.0 i'm having trouble getting some celery.task.control.inspect().stats() calls to return anything but None (regardless of timeout). a worker is running. is this likely an env problem or am i using a now-broken api?

i see a `celery.worker.control.stats` in the 3.0 docs but not sure what its required `panel` arg is supposed to be

really, any examples of celery.worker.control (or other worker/queue introspection) used in the wild would be helpful.