# Path: forsun/servers/processor/ttypes.py
# class ForsunPlanError(TException):
#     """
#     Attributes:
#      - code
#      - message
#     """
# 
# 
#     def __init__(self, code=None, message=None,):
#         self.code = code
#         self.message = message
# 
#     def read(self, iprot):
#         if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
#             iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
#             return
#         iprot.readStructBegin()
#         while True:
#             (fname, ftype, fid) = iprot.readFieldBegin()
#             if ftype == TType.STOP:
#                 break
#             if fid == 1:
#                 if ftype == TType.I16:
#                     self.code = iprot.readI16()
#                 else:
#                     iprot.skip(ftype)
#             elif fid == 2:
#                 if ftype == TType.STRING:
#                     self.message = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
#                 else:
#                     iprot.skip(ftype)
#             else:
#                 iprot.skip(ftype)
#             iprot.readFieldEnd()
#         iprot.readStructEnd()
# 
#     def write(self, oprot):
#         if oprot._fast_encode is not None and self.thrift_spec is not None:
#             oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
#             return
#         oprot.writeStructBegin('ForsunPlanError')
#         if self.code is not None:
#             oprot.writeFieldBegin('code', TType.I16, 1)
#             oprot.writeI16(self.code)
#             oprot.writeFieldEnd()
#         if self.message is not None:
#             oprot.writeFieldBegin('message', TType.STRING, 2)
#             oprot.writeString(self.message.encode('utf-8') if sys.version_info[0] == 2 else self.message)
#             oprot.writeFieldEnd()
#         oprot.writeFieldStop()
#         oprot.writeStructEnd()
# 
#     def validate(self):
#         return
# 
#     def __str__(self):
#         return repr(self)
# 
#     def __repr__(self):
#         L = ['%s=%r' % (key, value)
#              for key, value in self.__dict__.items()]
#         return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
# 
#     def __eq__(self, other):
#         return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
# 
#     def __ne__(self, other):
#         return not (self == other)


from .servers.processor.ttypes import ForsunPlanError
# -*- coding: utf-8 -*-
# 18/1/23
# create by: snower


class ActionExecuteRetry(Exception):
    def __init__(self):
        pass

class UnknownError(ForsunPlanError):
    def __init__(self):
        super(UnknownError, self).__init__(1001, u"未知错误")

    def __hash__(self):
        return id(self)


# Path: forsun/servers/processor/ttypes.py
# class ForsunPlanError(TException):
#     """
#     Attributes:
#      - code
#      - message
#     """
# 
# 
#     def __init__(self, code=None, message=None,):
#         self.code = code
#         self.message = message
# 
#     def read(self, iprot):
#         if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
#             iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
#             return
#         iprot.readStructBegin()
#         while True:
#             (fname, ftype, fid) = iprot.readFieldBegin()
#             if ftype == TType.STOP:
#                 break
#             if fid == 1:
#                 if ftype == TType.I16:
#                     self.code = iprot.readI16()
#                 else:
#                     iprot.skip(ftype)
#             elif fid == 2:
#                 if ftype == TType.STRING:
#                     self.message = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
#                 else:
#                     iprot.skip(ftype)
#             else:
#                 iprot.skip(ftype)
#             iprot.readFieldEnd()
#         iprot.readStructEnd()
# 
#     def write(self, oprot):
#         if oprot._fast_encode is not None and self.thrift_spec is not None:
#             oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
#             return
#         oprot.writeStructBegin('ForsunPlanError')
#         if self.code is not None:
#             oprot.writeFieldBegin('code', TType.I16, 1)
#             oprot.writeI16(self.code)
#             oprot.writeFieldEnd()
#         if self.message is not None:
#             oprot.writeFieldBegin('message', TType.STRING, 2)
#             oprot.writeString(self.message.encode('utf-8') if sys.version_info[0] == 2 else self.message)
#             oprot.writeFieldEnd()
#         oprot.writeFieldStop()
#         oprot.writeStructEnd()
# 
#     def validate(self):
#         return
# 
#     def __str__(self):
#         return repr(self)
# 
#     def __repr__(self):
#         L = ['%s=%r' % (key, value)
#              for key, value in self.__dict__.items()]
#         return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
# 
#     def __eq__(self, other):
#         return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
# 
#     def __ne__(self, other):
#         return not (self == other)


# Path: forsun/error.py
from .servers.processor.ttypes import ForsunPlanError

# -*- coding: utf-8 -*-
# 18/1/23
# create by: snower


class ActionExecuteRetry(Exception):
    def __init__(self):
        pass

class UnknownError(ForsunPlanError):
    def __init__(self):
        super(UnknownError, self).__init__(1001, u"未知错误")

    def __hash__(self):
        return id(self)


class WillNeverArriveTimeError(ForsunPlanError):