link + link_error now works with send_task. Thanks to Taylor Nelson

celery/app/base.py

@@ -29,7 +29,7 @@ from celery.exceptions import AlwaysEagerIgnored, ImproperlyConfigured
 from celery.five import items, values
 from celery.loaders import get_loader_cls
 from celery.local import PromiseProxy, maybe_evaluate
-from celery.utils.functional import first
+from celery.utils.functional import first, maybe_list
 from celery.utils.imports import instantiate, symbol_by_name
 from celery.utils.log import ensure_process_aware_logger
 from celery.utils.objects import mro_lookup
@@ -279,6 +279,7 @@ class Celery(object):
     def send_task(self, name, args=None, kwargs=None, countdown=None,
                   eta=None, task_id=None, producer=None, connection=None,
                   result_cls=None, expires=None, queues=None, publisher=None,
+                  link=None, link_error=None,
                   **options):
         producer = producer or publisher  # XXX compat
         if self.conf.CELERY_ALWAYS_EAGER:  # pragma: no cover
@@ -295,6 +296,8 @@ class Celery(object):
                 name, args, kwargs,
                 task_id=task_id,
                 countdown=countdown, eta=eta,
+                callbacks=maybe_list(link),
+                errbacks=maybe_list(link_error),
                 expires=expires, **options
             ))