from celery import Celery, platforms

import time

import os

from datetime import datetime

app = Celery('proj',

             broker='amqp://admin:admin@ip:5672',     //rabbitmq

             backend='amqp://admin:admin@ip:5672',    //redis

             //backend='redis://ip:10013/0',

             include=['tasks']

             )

app.conf.update(

    CELERYD_PREFETCH_MULTIPLIER=,

    CELERY_ACKS_LAT = True,

)

@app.task

def fun_1(n):

    return {"task_id": "0a14c9ac91de419880c4499a8f57418e",

            "status": ,

            "desc": str(n) }

@app.task

def chk_total_callback(tasks_rets):

    end_time = datetime.now()

    print "end_time", end_time

    return 

if __name__ == "__main__":

    app.start()

from tasks import *

from celery import group, chain

from datetime import datetime

import time                                                            

#job_group = group([fun_1.s(i) for i in range()])

beg_time = datetime.now()

for j in range():

    job_group = group([fun_1.s(i) for i in range()])

    chain(job_group, chk_total_callback.s())()

    #time.sleep(0.25)                                                  

print "beg_time:", beg_time