This is an automated email from the ASF dual-hosted git repository.
ruanhang1993 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 9fcb46e79e2 [FLINK-38602][python] Correct misuse of typehint (#27179)
9fcb46e79e2 is described below
commit 9fcb46e79e2f7d5ea69d03b9f2247dd2d58594b1
Author: Dian Fu <[email protected]>
AuthorDate: Fri Oct 31 22:42:02 2025 +0800
[FLINK-38602][python] Correct misuse of typehint (#27179)
---
.../fn_execution/datastream/process/async_function/operation.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/flink-python/pyflink/fn_execution/datastream/process/async_function/operation.py
b/flink-python/pyflink/fn_execution/datastream/process/async_function/operation.py
index 1f30e2ba303..7d6e52cf594 100644
---
a/flink-python/pyflink/fn_execution/datastream/process/async_function/operation.py
+++
b/flink-python/pyflink/fn_execution/datastream/process/async_function/operation.py
@@ -63,7 +63,7 @@ class ResultHandler(ResultFuture, Generic[IN, OUT]):
def __init__(self,
classname: str,
- timeout_func: Callable[[IN, ResultFuture[[OUT]]], None],
+ timeout_func: Callable[[IN, ResultFuture[OUT]], None],
exception_handler: Callable[[Exception], None],
record: IN,
result_future: ResultFuture[OUT]):
@@ -122,7 +122,7 @@ class RetryableResultHandler(ResultFuture, Generic[IN,
OUT]):
def __init__(self,
result_handler: ResultHandler[IN, OUT],
- async_invoke_func_runner: Callable[[IN, ResultFuture[[OUT]]],
None],
+ async_invoke_func_runner: Callable[[IN, ResultFuture[OUT]],
None],
retry_strategy: AsyncRetryStrategy[OUT]):
self._result_handler = result_handler
self._async_invoke_func_runner = async_invoke_func_runner
