during startup self.producer will always be null (apache#186)

sijie · Mar 4, 2018 · 3448c10 · 3448c10
1 parent a954d96
commit 3448c10
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-functions/runtime/src/main/python/python_instance.py b/pulsar-functions/runtime/src/main/python/python_instance.py
@@ -185,7 +185,7 @@ def done_producing(self, consumer, orig_message, result, sent_message):
       consumer.acknowledge(orig_message)
 
   def process_result(self, output, msg):
-    if output is not None and self.producer is not None:
+    if output is not None:
       output_bytes = None
       if self.output_serde is None:
         self.setup_output_serde()