docs: def _onsuccess(cls, kmsg, result):
          """ To execute on execution success
  
          :param kser.schemas.Message kmsg: Kafka message
          :param kser.result.Result result: Execution result
          :return: Execution result
          :rtype: kser.result.Result
          """
          logger.info(
              "{}.Success: {}[{}]: {}".format(
                  cls.__name__, kmsg.entrypoint, kmsg.uuid, result
              ),
              extra=dict(
                  kmsg=kmsg.dump(),
                  kresult=ResultSchema().dump(result) if result else dict()
              )
          )
          return cls.onsuccess(kmsg, result)