executor.py 文件源码

def __call__(self, event, *args, **kwargs):
        _chaos_event = self._chaos_events.get(event)
        if _chaos_event:
            exe_logger.debug("Calling event %s on %s" % (event, self.app))
            if isinstance(_chaos_event, (types.InstanceType,
                                    types.ObjectType, staticmethod)):
                return _chaos_event(self.app, *args, **kwargs)
            elif isinstance(_chaos_event, types.FunctionType):
                return _chaos_event(self, *args, **kwargs)
            else:
                raise UnknownChaosEvent(event)
        else:
            exe_logger.error("Unknown event requested :%s" % event)
            raise UnknownChaosEvent(event)