Callbacks and errbacks do not work with CELERY_ALWAYS_EAGER

[charlax]

Here's an example code:

from celery import Celery

celery = Celery('hello',
                backend='redis://localhost:6379/3',
                broker='redis://localhost:6379/3')

celery.conf.update(
    CELERY_ALWAYS_EAGER=True,
)


@celery.task
def hello():
    print "Here"
    return


@celery.task
def raise_exception():
    raise TypeError()


def main():
    r = raise_exception.apply_async(link_error=hello.s())
    # r.get()

if __name__ == '__main__':
    main()

One would expect that this code prints "Here", but it does not.

Will try to fix by myself, in the meantime would appreciate any help.

Thanks

[charlax]

Note that using CELERY_EAGER_PROPAGATES_EXCEPTIONS is even worse because it raises the exception directly:

Traceback (most recent call last):
  File "hello.py", line 29, in <module>
    main()
  File "hello.py", line 25, in main
    r = raise_exception.apply_async(link_error=hello.s())
  File "/Users/ca/.virtualenvs/celerydebug/lib/python2.7/site-packages/celery-3.1.0rc1-py2.7.egg/celery/app/task.py", line 458, in apply_async
    return self.apply(args, kwargs, task_id=task_id, **options)
  File "/Users/ca/.virtualenvs/celerydebug/lib/python2.7/site-packages/celery-3.1.0rc1-py2.7.egg/celery/app/task.py", line 633, in apply
    request=request, propagate=throw)
  File "/Users/ca/.virtualenvs/celerydebug/lib/python2.7/site-packages/celery-3.1.0rc1-py2.7.egg/celery/task/trace.py", line 292, in eager_trace_task
    uuid, args, kwargs, request)
  File "/Users/ca/.virtualenvs/celerydebug/lib/python2.7/site-packages/celery-3.1.0rc1-py2.7.egg/celery/task/trace.py", line 204, in trace_task
    R = retval = fun(*args, **kwargs)
  File "hello.py", line 21, in raise_exception
    raise TypeError()
TypeError

[ask]

Maybe the better solution is to avoid calling the errback in this case.

Always eager will never be feature complete anyway, and it's better for tests to mock this.

[charlax]

Awesome! Thanks @ask!