@@ -26,6 +26,14 @@ 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 (kind = kind , page_size = page_size , page_token = page_token )
35
+
36
+
29
37
class OperationClient (object ):
30
38
def __init__ (self , driver ):
31
39
self ._driver = driver
@@ -48,6 +56,15 @@ def forget(self, operation_id, settings=None):
48
56
settings ,
49
57
)
50
58
59
+ def list (self , kind : str , page_size : int , page_token : str , settings = None ):
60
+ return self ._driver (
61
+ _list_operations_request (kind , page_size , page_token ),
62
+ _apis .OperationService .Stub ,
63
+ _apis .OperationService .ListOperations ,
64
+ _list_operations_response ,
65
+ settings ,
66
+ )
67
+
51
68
52
69
class Operation (object ):
53
70
__slots__ = ("id" , "_driver" , "self_cls" )
@@ -99,3 +116,14 @@ def get(self, settings=None):
99
116
settings ,
100
117
(self ._driver ,),
101
118
)
119
+
120
+ def list (self , kind : str , page_size : int , page_token : str , settings = None ):
121
+ self ._ensure_implements ()
122
+ return self ._driver (
123
+ _list_operations_request (kind , page_size , page_token ),
124
+ _apis .OperationService .Stub ,
125
+ _apis .OperationService .ListOperations ,
126
+ self .__class__ ,
127
+ settings ,
128
+ (self ._driver ,),
129
+ )
0 commit comments