[2011-05-12 12:40:22,469: WARNING/MainProcess]

 -------------- celery@box v2.3.0a2
---- **** -----
--- * ***  * -- [Configuration]
-- * - **** ---   . broker:      amqplib://nimble_user@localhost:5672/nimble_vhost
- ** ----------   . loader:      celery.loaders.default.Loader
- ** ----------   . logfile:     [stderr]@INFO
- ** ----------   . concurrency: 4
- ** ----------   . events:      OFF
- *** --- * ---   . beat:        OFF
-- ******* ----
--- ***** ----- [Queues]
 --------------   . celery:      exchange:celery (direct) binding:celery


[Tasks]
  . tasks.add
  . tasks.tsum

[2011-05-12 12:40:22,487: INFO/PoolWorker-1] child process calling self.run()
[2011-05-12 12:40:22,489: INFO/PoolWorker-2] child process calling self.run()
[2011-05-12 12:40:22,490: INFO/PoolWorker-3] child process calling self.run()
[2011-05-12 12:40:22,491: INFO/PoolWorker-4] child process calling self.run()
[2011-05-12 12:40:22,493: WARNING/MainProcess] celery@thephatness4 has started.
[2011-05-12 12:40:26,121: INFO/MainProcess] Got task from broker: celery.chord[1dfb3ad3-d004-4b32-aa91-4e3274c55280]
[2011-05-12 12:40:26,240: INFO/MainProcess] Got task from broker: tasks.add[c5ecd078-11f5-4679-a791-beb8fc923f73]
[2011-05-12 12:40:26,240: INFO/MainProcess] Got task from broker: tasks.add[9d63ee85-ea99-4722-95c9-52e7e37bdd74]
[2011-05-12 12:40:26,241: INFO/MainProcess] Got task from broker: tasks.add[e399fb20-a950-4e1c-a3db-1e29956187f9]
[2011-05-12 12:40:26,241: INFO/MainProcess] Got task from broker: tasks.add[e46113d2-3488-47b6-ad28-f07e205734af]
[2011-05-12 12:40:26,242: INFO/MainProcess] Task celery.chord[1dfb3ad3-d004-4b32-aa91-4e3274c55280] succeeded in 0.0828831195831s: <celery.result.TaskSetResult object at...
[2011-05-12 12:40:26,242: INFO/MainProcess] Got task from broker: tasks.add[1cba6f81-f230-4f40-a11c-80478ed57dd4]
[2011-05-12 12:40:26,242: INFO/MainProcess] Got task from broker: tasks.add[16024f56-f093-4c02-8023-f16ae8480561]
[2011-05-12 12:40:26,243: INFO/MainProcess] Got task from broker: tasks.add[68c2b20c-c2f5-4b8f-9800-4be38989aacf]
[2011-05-12 12:40:26,243: INFO/MainProcess] Got task from broker: tasks.add[44a2d0cb-983c-4285-a274-80623a0ae99e]
[2011-05-12 12:40:26,243: INFO/MainProcess] Got task from broker: tasks.add[48a1f8ab-1a71-491b-a7cb-c512ee57f042]
[2011-05-12 12:40:26,244: INFO/MainProcess] Got task from broker: tasks.add[ada9e628-516a-46a5-a923-7c730049f615]
[2011-05-12 12:40:26,279: INFO/MainProcess] Task tasks.add[c5ecd078-11f5-4679-a791-beb8fc923f73] succeeded in 0.00642991065979s: 0
[2011-05-12 12:40:26,280: INFO/MainProcess] Task tasks.add[e399fb20-a950-4e1c-a3db-1e29956187f9] succeeded in 0.00508904457092s: 4
[2011-05-12 12:40:26,281: INFO/MainProcess] Task tasks.add[e46113d2-3488-47b6-ad28-f07e205734af] succeeded in 0.00368404388428s: 6
[2011-05-12 12:40:26,282: INFO/MainProcess] Task tasks.add[9d63ee85-ea99-4722-95c9-52e7e37bdd74] succeeded in 0.00717711448669s: 2
[2011-05-12 12:40:26,283: INFO/MainProcess] Task tasks.add[1cba6f81-f230-4f40-a11c-80478ed57dd4] succeeded in 0.00155901908875s: 8
[2011-05-12 12:40:26,284: INFO/MainProcess] Task tasks.add[68c2b20c-c2f5-4b8f-9800-4be38989aacf] succeeded in 0.00137591362s: 12
[2011-05-12 12:40:26,285: INFO/MainProcess] Task tasks.add[48a1f8ab-1a71-491b-a7cb-c512ee57f042] succeeded in 0.000825881958008s: 16
[2011-05-12 12:40:26,285: INFO/MainProcess] Task tasks.add[44a2d0cb-983c-4285-a274-80623a0ae99e] succeeded in 0.00183510780334s: 14
[2011-05-12 12:40:26,285: INFO/MainProcess] Task tasks.add[16024f56-f093-4c02-8023-f16ae8480561] succeeded in 0.0031590461731s: 10
[2011-05-12 12:40:26,285: INFO/MainProcess] Task tasks.add[ada9e628-516a-46a5-a923-7c730049f615] succeeded in 0.00105309486389s: 18



Python 2.7.0+ (r27:82500, May  9 2011, 20:36:12)
[GCC 4.4.5] on linux2
Type "help", "copyright", "credits" or "license" for more information.
>>> from celery.task import chord
>>> from tasks import add, tsum
>>> chord(add.subtask((i, i))
...     for i in xrange(10))(tsum.subtask()).get()


tasks.py
================
from celery.task import chord, task

@task
def add(x, y):
    return x + y

@task
def tsum(numbers):
    return sum(numbers)


celeryconfig.py
================
BROKER_HOST = "localhost"
BROKER_PORT = 5672
BROKER_USER = "nimble_user"
BROKER_PASSWORD = "nimble_pass"
BROKER_VHOST = "nimble_vhost"

CELERY_RESULT_BACKEND = "redis"
REDIS_HOST = "localhost"
REDIS_PORT = 6379
REDIS_DB = 0
REDIS_CONNECT_RETRY = True

CELERY_IMPORTS = ("tasks", )