You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zi...@apache.org on 2022/12/05 07:52:55 UTC
[pulsar] branch master updated: [improve][fn] Expose pulsar client in python instance (#18739)
This is an automated email from the ASF dual-hosted git repository.
zixuan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 2dbd2526fa8 [improve][fn] Expose pulsar client in python instance (#18739)
2dbd2526fa8 is described below
commit 2dbd2526fa84d6045c4ca05a2b94e15d882953df
Author: jiangpengcheng <sc...@gmail.com>
AuthorDate: Mon Dec 5 15:52:49 2022 +0800
[improve][fn] Expose pulsar client in python instance (#18739)
---
pulsar-functions/instance/src/main/python/contextimpl.py | 3 +++
1 file changed, 3 insertions(+)
diff --git a/pulsar-functions/instance/src/main/python/contextimpl.py b/pulsar-functions/instance/src/main/python/contextimpl.py
index 84a7d898395..63581d1e4be 100755
--- a/pulsar-functions/instance/src/main/python/contextimpl.py
+++ b/pulsar-functions/instance/src/main/python/contextimpl.py
@@ -240,3 +240,6 @@ class ContextImpl(pulsar.Context):
def get_state(self, key):
return self.state_context.get_value(key)
+
+ def get_pulsar_client(self):
+ return self.pulsar_client