#celery

bmbouter, ping

hey everyone

im upgrading celery 3 to 4, and taking the time to re-check our tasks and configurations

i couldn't find what is the best way to declare periodic tasks per app..

this is old but reflects my thoughts https://github.com/celery/celery/issues/1764

for a non monolithic app, where should i declare the periodic tasks, and how?

I wonder did Celery guys intentionally decide to use celery celery-task-meta-<id> keys in Redis for all tasks. Why not have subkeys like... celery-task-meta:pending:<id> , celery-task-meta:started:<id> etc?

Since celery can't tell me what is waiting in the queue, I have to go through Redis keys to find this information

and I may have million keys...

woohoo what did i miss

?

spill the beans

:)

nothing really...

it is mostly quiet here

too quiet

people working on celery too much

i am trolling to find some friends

lol

guru's on Celery

its kicking my butt

Dejan are u kicking ass and taking names

nope

Dejan, that is celery 4?

i hust recently upgraded and saw on 4 release notes that some info of the task(like args and kwargs) was moved from payload to header to more easly spot that stuf maybe

yea, that is a different story

what I was talking about is the inspection

as far as I know, you can't inspect tasks that are waiting in the queue

hi, anyone have luck using celery with AMQP 1.0?

nope

I only used Redis so far

and still do

redis all the way baby

i'll die if redis drys u[

up

we can inspect active, scheduled, revoked, but how can i inspect what tasks are waiting in the queue to be picked?

i never done with celery, only with a rabbit lib that tells me how many are in queue(and all of those are ready in my case)

abhaykadam: hey yes we can talk about amqp 1.0 and celery if you want here

I'm very familiar with this topic

and it's challenges...

would it be posible to chain tasks together from .task()?

Basically I an trying to send_task from a flask app, then consume from a standalone celery app, but I have several tasks that I want to chain together in the celery app

each task has the link parameter