#celery

a task with time.sleep(x) doesn't seem to return instantly

I was under the impressong that any @task would return without blocking

impression*

Is there a standard way to specify a path for or look up stderr and stdout for any given task?

theres CELERYD_HIJACK_ROOT_LOGGER, but i think for granularity of a given task you'll want to setup the logger in the worker

task_prerun signal might also be a good place, if you wanted a different log by task

True. And for the case I was thinking about my question actually doesn't make any sense. I was needing it for tasks which run a command via subprocess. That module gives me stdout and stderr definitions that I can then store. I should have though that through more before asking.

anyone here on edge?

as in master 3.1?

howdy

asksol, is kombu currently in a transitional state?

when I tried to pull from master earlier today, I ended up with workers that didn't want to read from queues.. its possible it's some of my commits not playing nicely with yours, i suppose...

also, must retry always be called from within the failed task? is there no way to use the asyncresult instance and tell it to call itself again with the same arguments? I suppose I could find some way to serialize a subgoal representation of the task on the initial apply_async call...

mdan: upgrade kombu and py-amqp

Hello all, what's the best way to register tasks that are in another codebase? (currently i'm using @celery.task def task: pass)

italorossi: just import the other codebase

italorossi: tasks are shared between apps by default

i'm using different projects on different machines..

the worker needs to be able to import the source code...

or you may be able to find some serializer that can transfer code objects

but that is very, very tricky to get right

actually the source is in the worker and I have a "frontend" project sending tasks to my worker

I was trying to avoid duplicate code between the "frontend" and the worker

app.send_task(name, args=(), kwargs={}, **options)

send_task works.. but there's some difference using subtasks with chain

using chain and subtask i'm getting: celery.exceptions.NotRegistered

so, I've defined the task o the "frontend" with def task: pass and it worked

what version?

*on

3.0.12

you have to upgrade

ok, let me see if it works on 3.0.24

asksol: after upgrade i'm getting: NotImplementedError('Tasks must define the run method.',)

tasks must have a method named 'run'