Skip to content

Commit 9fcb46e

Browse files
authored
[FLINK-38602][python] Correct misuse of typehint (#27179)
1 parent 162025a commit 9fcb46e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

flink-python/pyflink/fn_execution/datastream/process/async_function/operation.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ class ResultHandler(ResultFuture, Generic[IN, OUT]):
6363

6464
def __init__(self,
6565
classname: str,
66-
timeout_func: Callable[[IN, ResultFuture[[OUT]]], None],
66+
timeout_func: Callable[[IN, ResultFuture[OUT]], None],
6767
exception_handler: Callable[[Exception], None],
6868
record: IN,
6969
result_future: ResultFuture[OUT]):
@@ -122,7 +122,7 @@ class RetryableResultHandler(ResultFuture, Generic[IN, OUT]):
122122

123123
def __init__(self,
124124
result_handler: ResultHandler[IN, OUT],
125-
async_invoke_func_runner: Callable[[IN, ResultFuture[[OUT]]], None],
125+
async_invoke_func_runner: Callable[[IN, ResultFuture[OUT]], None],
126126
retry_strategy: AsyncRetryStrategy[OUT]):
127127
self._result_handler = result_handler
128128
self._async_invoke_func_runner = async_invoke_func_runner

0 commit comments

Comments
 (0)