@connect_on_app_finalize
def add_chord_task(app):
 from celery import group, chord as _chord
 from celery.canvas import maybe_signature
 @app.task(name=u'celery.chord', bind=True, ignore_result=False, shared=False, lazy=False)
 def chord(self, header, body, partial_args=(), interval=None, countdown=1, max_retries=None, eager=False, **kwargs):
  app = self.app
  tasks = (header.tasks if isinstance(header, group) else header)
  header = group([maybe_signature(s, app=app) for s in tasks], app=self.app)
  body = maybe_signature(body, app=app)
  ch = _chord(header, body)
  return ch.run(header, body, partial_args, app, interval, countdown, max_retries, **kwargs)
 return chord

@ connect_on_app_finalize def add_chord_task ( app ) : from celery import group , chord as _chord from celery . canvas import maybe_signature @ app . task ( name = u'celery.chord' , bind = True , ignore_result = False , shared = False , lazy = False ) def chord ( self , header , body , partial_args = ( ) , interval = None , countdown = 1 , max_retries = None , eager = False , ** kwargs ) : app = self . app tasks = ( header . tasks if isinstance ( header , group ) else header ) header = group ( [ maybe_signature ( s , app = app ) for s in tasks ] , app = self . app ) body = maybe_signature ( body , app = app ) ch = _chord ( header , body ) return ch . run ( header , body , partial_args , app , interval , countdown , max_retries , ** kwargs ) return chord
no longer used .