From ed2c89977bee234d4475694bac69743a703be20b Mon Sep 17 00:00:00 2001 From: Boyang Jerry Peng Date: Fri, 22 Feb 2019 10:34:11 -0800 Subject: [PATCH] fix context publish signature (#3669) --- pulsar-client-cpp/python/pulsar/functions/context.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-client-cpp/python/pulsar/functions/context.py b/pulsar-client-cpp/python/pulsar/functions/context.py index 26e86069b90..bad6f352663 100644 --- a/pulsar-client-cpp/python/pulsar/functions/context.py +++ b/pulsar-client-cpp/python/pulsar/functions/context.py @@ -124,7 +124,7 @@ class Context(object): pass @abstractmethod - def publish(self, topic_name, message, serde_class_name="serde.IdentitySerDe", properties=None, compression_type=None): + def publish(self, topic_name, message, serde_class_name="serde.IdentitySerDe", properties=None, compression_type=None, callback=None): """Publishes message to topic_name by first serializing the message using serde_class_name serde The message will have properties specified if any""" pass -- GitLab