:(

asksol u still here?

fire up an amazon ec2 instance to test if nothing else, quick :)

elnio: did you ping me earlier?

hi

yes cause you where the only one i saw in

and i needed some help with my celery prject

if anyone is willing to help let me know

is anyone here?

i need some help with my celery project can somebody help

?

elnio: just ask a question.

don't ask if you can ask first

yp i ask cause i want to see if there is actually hearing

and its a bit more complex to describe

the thing is that i have a problem returning the value from the task to the actual code which handles the return value

it seems like it gets messed up in the sending process

cause i have a print method inside the tasks code

and it prints the value just fine

so what do you get and what did you expect to get?

but when i receive it in my code with these lines job = TaskSet( tasks = taskList )

result = job.apply_async()

result.ready() # has all subtasks completed?

result.successful() # was all subtasks successful?

resultsList = result.join()

for example i try to return a string

and i get instead �Uadadadadadaq.

or with an int i get something else

the thing is that this was working before

but i changed the celeryd invokation

before i run it with django

but now i made a celeryconfig module and i put backend the amqp

this is why i was wondering if i do something wrong

cause the result is correct inside the task code..

when its returned there is the prob

can you help?

might be the serialization

resultsList contains a number of strings I guess?

yp

or a list of ints or whatever

is the return value

it's not the return value, it's the set of return values, but OK

how are those values different from the ones you expected

yp you are right

well for example i waited adadadadada and i got �Uadadadadadaq. or i waited 9 and i got �K .

did i help at all?

try printing the hex values for three first bytes of that string. might be a BOM

print [hex(ord(e) for e in retval[:3]]

or something like that

ok just a sec

i put a print [hex(ord(e) for e in resultsList[:3]]

where resultsList has the resultset

but it throws an exception on this line

you didn't close the laste parenthisis

or, I didn't and you copypasted

:P

still my fault

man can i ask something else

cause i get an error that i dont know why its occuring

Missing hostname for AMQP connection. Exception Location: /usr/lib/python2.6/site-packages/carrot/backends/pyamqplib.py in establish_connection, line 186

what is this does anybody know?

misconfigured settings

_cheerios:what do you mean misconfigured settings?

can someone else answer me why i get this error

Missing hostname for AMQP connection. Exception Location: /usr/lib/python2.6/site-packages/carrot/backends/pyamqplib.py in establish_connection, line 186

elnio: Presumably because the host name for the AMQP connection is missing?

which means?

i dont use ampq as the backend

i use a database

elnio: are you sure you have the correct settings? Don't see a reason why code should be running in pyamqplib.py if you've set it up with db backend

running into 'Missing hostname for AMQP connection.' --> using ghettoq Redis backend - anyone familiar with this error?

cleifer: that sounds like you haven't properly configured your settings. have you done it like this http://ask.github.com/celery/tutorials/otherque... ?

bahamas, we're moving from celery 1. something to 2.0 so that's quite likely things are out of sync

oh, you should read the differences then

get_backend_cls()

Out[5]: <class 'carrot.backends.pyamqplib.Backend'>

yah -- that there's my problem ^^ need it to use redis

I'm getting celery started up for the first time. Using django. Are the configuration lines supposed to go in my settings.py or in /etc/default/celeryd?

Scala: in your settings.py

The broker settings go in settings.py and daemon settings go in /etc/default/celeryd, correct?

yup.

bahamas: Neato. thanks.

yw

Has anyone tried running djcelery with celerybeat from head?

I would like to use the new periodic task database admin stuff, but it appears to be broken.

hi everyone, new to celery/rabbitmq and have a quick question: I know rabbitMQ doesn't support priorities, but I need to have a Priority 1 tasks that need to be run as soon as possible and Priority 10 tasks that should only be run if there are NO priority 1 tasks in the queue. Is there any way to set this up using multiple queues?

druski: You could use routing.

and set up some workers specifically for priority 1 tasks.

With django-celery, I have a couple functions marked with @task decorator and are executed in a view. Do I need to restart celeryd if I make any changes to my task function?

Scala: yes, you do

I'm trying to route different tasks into different queues and it seems to be not working, all of the tasks end up in the default queue instead

I'm using the dict method in CELERY_ROUTES where I have a task name -> queue mapping

there's a lot in the docs and I've tried a number of different things, so I'm not even sure what info would be useful to share to help anyone help me troubleshoot it

Hi all

I'm encountering really strange errors both on my local machine and on one of my servers... I'm getting CarrotListener: Connection Error: Socket closed. Trying again in 4 seconds...

when i start up celery

rabbitmq seems to be running fine

i screwed up the hostname on the server but on my local box that definitely hasn't changed but randomly started having issues

is there some way to examine a task without modifying it in the queue? I have CELERY_TRACK_STARTED = True in my config... when a job gets picked up, the status changes from PENDING to STARTED, but only once. the next time I check on that task, it shows PENDING again, and stays that way until it finishes and changes to SUCCESS

or specifically, it'd be nice if the state stayed as STARTED until it finished instead of going back to PENDING when I look at it