wenjin272 commented on code in PR #80:
URL: https://github.com/apache/flink-agents/pull/80#discussion_r2232367244
##########
python/flink_agents/plan/function.py:
##########
@@ -146,7 +146,59 @@ def check_signature(self, *args: Tuple[Any, ...]) -> None:
"""Check function signature is legal or not."""
+class PythonGeneratorWrapper:
+ """
+ A temporary wrapper class for Python generators to work around a
+ known issue in PEMJA, where the generator type is incorrectly handled.
+
+ Note: This wrapper is intended to be a temporary solution. Once PEMJA
+ version 0.6.0 (or later) fixes the bug related to generator type
conversion,
+ this wrapper should be removed.
+ """
Review Comment:
Maybe need add TODO and create correspond issue to track this.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
