is there a way to launch N chords in parallel? Let say I have 10 items and i want to process the first them in groups of 2, why this is not working? http://pastebin.com/ReikNhvz
*process them
woah! I got it, the problem is the get
not sure why though
georgeirwin has quit
bmbouter is now known as bmbouter_afk
magicflakes has quit
asksol
rhymes: you're synchronizing by calling .get()
rhymes
yeah but i thought that after the first chunk it would call the second a synchronize again
no?
harijay has quit
harijay joined the channel
irwingeorge joined the channel
k_sze[work] joined the channel
pfreixes joined the channel
ineedarobot has quit
k_sze[work] has quit
ineedarobot joined the channel
b8sell joined the channel
ineedarobot has quit
ineedarobot joined the channel
ineedarobot has quit
asksol
rhymes: the loop will for each iteration call a chord then wait for that chord
ineedarobot joined the channel
ineedarobot has quit
kikimeter joined the channel
darrenxy_ joined the channel
darrenxyli has quit
adam__ joined the channel
Flonka joined the channel
georgeirwin joined the channel
Flonka has quit
dstarnes joined the channel
harijay has quit
Flonka joined the channel
Flonka has quit
_mdg joined the channel
esauro has left the channel
samstav joined the channel
harijay joined the channel
samstav has quit
italorossi has quit
the_rat has quit
the_rat joined the channel
Frosh joined the channel
samstav joined the channel
harijay has quit
the_rat has quit
the_rat joined the channel
ineedarobot joined the channel
rhymes has quit
bmbouter_afk is now known as bmbouter
rhymes joined the channel
harijay joined the channel
becks__ joined the channel
mike_n joined the channel
mike_n
Should my celery.amqp.queues be containing "unbound Queue" and "unbound Exchange" instances? (I'm primarily concerned with the objects being "unbound")
surabujin has quit
ineedarobot has quit
surabujin joined the channel
bwreilly joined the channel
asksol, ?
gigimon has quit
Ergo has quit
ineedarobot joined the channel
darrenxy_ has quit
bwreilly_ joined the channel
_mdg has quit
bwreilly has quit
I'm following the tutorial here (http://celery.readthedocs.org/en/latest/usergui...), but it doesn't work for me; when I execute the line "basic.publish 'This is a message!' testexchange testkey", I get "unknown syntax: "basic.publish 'This is a message!' testexchange testkey". how about some 'help'?"
However I'm unable to get out of the mentioned loop, and our production system is stall
any hints on how to get out of this one ?
frodopwns joined the channel
harijay has quit
georgeirwin joined the channel
bkuberek joined the channel
georgeir_ has quit
lduros joined the channel
lduros
Any idea why one would get IOError: [Errno 32] Broken pipe when trying to create a "subtask": sub = subtask('tasks.send_notification_to_app', (notification,))
it seems to have started happening only after I set the CELERYD_PREFETCH_MULTIPLIER to 1, but it may only be a coincidence
bwreilly_ has quit
pfreixes has quit
edulix has quit
qba73 has quit
brockhaywood joined the channel
edulix joined the channel
surabujin has quit
ryanisnan joined the channel
edulix has quit
dstarnes has quit
bwreilly joined the channel
looks like it was due to the fact I would do: sub.apply_async() and then returning the task
if works if I do sub() instead of sub.apply_async()
edulix joined the channel
hmm, actually it still happens, just less often
harijay joined the channel
edulix has quit
ryanisnan has quit
if you do sub.apply_async() will you still get the error from the subtask in the parent task?
marek_sv joined the channel
will a failure in sub result in a failure in the "parent task"? Is what I mean?