From 47955d7d65f0a4bbb8d2dda4f6c7fd7afbabb859 Mon Sep 17 00:00:00 2001 From: nowanti Date: Thu, 26 Oct 2023 15:39:23 +0800 Subject: [PATCH] =?UTF-8?q?=F0=9F=90=B3=20chore:=20improve=20the=20notes?= =?UTF-8?q?=20of=20some=20methods?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/onestep/broker/base.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/onestep/broker/base.py b/src/onestep/broker/base.py index 5133179..4d7a801 100644 --- a/src/onestep/broker/base.py +++ b/src/onestep/broker/base.py @@ -35,14 +35,14 @@ def send(self, message): @abc.abstractmethod def publish(self, message: Any): """ - 如果当前Broker是Job的to_broker, 则必须实现此方法 + 将消息原样发布到 broker 中。如果当前Broker是Job的to_broker, 则必须实现此方法 """ raise NotImplementedError('Please implement in subclasses.') @abc.abstractmethod def consume(self, *args, **kwargs): """ - 如果当前Broker是Job的from_broker, 则必须实现此方法 + 消费消息。如果当前Broker是Job的from_broker, 则必须实现此方法 """ raise NotImplementedError('Please implement in subclasses.')