This is an automated email from the ASF dual-hosted git repository. sijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push: new 8dbee11 Fix var names of context that were changed (#1676) 8dbee11 is described below commit 8dbee119232d58cf5fb617f5dfeaea5fcf44aa09 Author: Sanjeev Kulkarni <sanjee...@gmail.com> AuthorDate: Fri Apr 27 16:20:25 2018 -0700 Fix var names of context that were changed (#1676) --- pulsar-functions/instance/src/main/python/contextimpl.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/pulsar-functions/instance/src/main/python/contextimpl.py b/pulsar-functions/instance/src/main/python/contextimpl.py index f950abf..6e59306 100644 --- a/pulsar-functions/instance/src/main/python/contextimpl.py +++ b/pulsar-functions/instance/src/main/python/contextimpl.py @@ -73,7 +73,7 @@ class ContextImpl(pulsar.Context): return self.current_topic_name def get_function_name(self): - return self.instance_config.function_config.name + return self.instance_config.function_details.name def get_function_id(self): return self.instance_config.function_id @@ -88,13 +88,13 @@ class ContextImpl(pulsar.Context): return self.log def get_user_config_value(self, key): - if key in self.instance_config.function_config.userConfig: - return str(self.instance_config.function_config.userConfig[key]) + if key in self.instance_config.function_details.userConfig: + return str(self.instance_config.function_details.userConfig[key]) else: return None def get_user_config_map(self): - return self.instance_config.function_config.userConfig + return self.instance_config.function_details.userConfig def record_metric(self, metric_name, metric_value): if not metric_name in self.accumulated_metrics: @@ -102,10 +102,10 @@ class ContextImpl(pulsar.Context): self.accumulated_metrics[metric_name].update(metric_value) def get_output_topic(self): - return self.instance_config.function_config.output + return self.instance_config.function_details.output def get_output_serde_class_name(self): - return self.instance_config.function_config.outputSerdeClassName + return self.instance_config.function_details.outputSerdeClassName def publish(self, topic_name, message): return self.publish(topic_name, message, "serde.IdentitySerDe") -- To stop receiving notification emails like this one, please contact si...@apache.org.