MaybeEncodingError while raising error in task

[hd5970]

hi

CELERY_TASK_SERIALIZER: 'pickle'
Celery(broker=BaseConfig.CELERY_BROKER_URL) no backend
VERSION 4.0.0
Python 2.7.12

class CanNotHandleAnyMore(Exception):
    def __init__(self, message):
        self.message = message

    def __repr__(self):
        return self.message

#task code
@celery.task
def balaba():
      # raise ValueError , nothing unexpected happened, Task balaba raised unexpected: ValueError
      raise ValueError
      # raise CanNotHandleAnyMore instance
      raise CanNotHandleAnyMore("I don't wanna handle any more")
      # here comes the exception Task handler raised error in celery stdout
      # traceback
      [2016-11-24 14:55:45,282: ERROR/MainProcess] Task handler raised error: 
<MaybeEncodingError: Error sending result: ''(1, <ExceptionInfo: CanNotHandleAnyMore()>, None)''. Reason: ''PicklingError("Can\'t pickle <class \'src.handlers.base.CanNotHandleAnyMore\'>: it\'s not the same object as src.handlers.base.CanNotHandleAnyMore",)''.>

Thank you

[ask]

Your exception is not properly defined as it does not call super().init.

To fix this you need to change your code to:

class CanNotHandleAnyMore(Exception):

    def __init__(self, message):
        self.message = message
        super(CanNotHandleAnyMore, self).__init__(message)

    def __repr__(self):
        return self.message