Skip to content

Commit a1c1dbd

Browse files
authored
Fix FlushAll timeout (#1340)
Signed-off-by: bigsheeper <[email protected]>
1 parent 659f5e0 commit a1c1dbd

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pymilvus/client/grpc_handler.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1290,7 +1290,7 @@ def flush_all(self, timeout=None, **kwargs):
12901290
raise MilvusException(response.status.error_code, response.status.reason)
12911291

12921292
def _check():
1293-
self._wait_for_flush_all(response.flush_all_ts)
1293+
self._wait_for_flush_all(response.flush_all_ts, timeout, **kwargs)
12941294

12951295
if kwargs.get("_async", False):
12961296
flush_future = FlushFuture(future)

0 commit comments

Comments
 (0)