@@ -26,6 +26,18 @@ def _get_operation_request(self):
26
26
return request
27
27
28
28
29
+ def _list_operations_response (rpc_state , response ): # pylint: disable=W0613
30
+ issues ._process_response (response )
31
+
32
+
33
+ def _list_operations_request (kind : str , page_size : int , page_token : str ):
34
+ return _apis .ydb_operation .ListOperationsRequest (
35
+ kind = kind ,
36
+ page_size = page_size ,
37
+ page_token = page_token
38
+ )
39
+
40
+
29
41
class OperationClient (object ):
30
42
def __init__ (self , driver ):
31
43
self ._driver = driver
@@ -48,6 +60,15 @@ def forget(self, operation_id, settings=None):
48
60
settings ,
49
61
)
50
62
63
+ def list (self , kind : str , page_size : int , page_token : str , settings = None ):
64
+ return self ._driver (
65
+ _list_operations_request (kind , page_size , page_token ),
66
+ _apis .OperationService .Stub ,
67
+ _apis .OperationService .ListOperations ,
68
+ _list_operations_response ,
69
+ settings ,
70
+ )
71
+
51
72
52
73
class Operation (object ):
53
74
__slots__ = ("id" , "_driver" , "self_cls" )
@@ -99,3 +120,14 @@ def get(self, settings=None):
99
120
settings ,
100
121
(self ._driver ,),
101
122
)
123
+
124
+ def list (self , kind : str , page_size : int , page_token : str , settings = None ):
125
+ self ._ensure_implements ()
126
+ return self ._driver (
127
+ _list_operations_request (kind , page_size , page_token ),
128
+ _apis .OperationService .Stub ,
129
+ _apis .OperationService .ListOperations ,
130
+ self .__class__ ,
131
+ settings ,
132
+ (self ._driver ,),
133
+ )
0 commit comments