Skip to content

Commit 4960884

Browse files
Api clients refactoring
1 parent 1648c81 commit 4960884

27 files changed

Lines changed: 935 additions & 1100 deletions

src/conductor/client/http/api/admin_resource_api.py

Lines changed: 24 additions & 36 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,3 @@
1-
# coding: utf-8
2-
3-
"""
4-
Orkes Conductor API Server
5-
6-
Orkes Conductor API Server # noqa: E501
7-
8-
OpenAPI spec version: v2
9-
10-
Generated by: https://github.com/swagger-api/swagger-codegen.git
11-
"""
12-
131
from __future__ import absolute_import
142

153
import re # noqa: F401
@@ -41,7 +29,7 @@ def clear_task_execution_cache(self, task_def_name, **kwargs): # noqa: E501
4129
>>> result = thread.get()
4230
4331
:param async_req bool
44-
:param object task_def_name: (required)
32+
:param str task_def_name: (required)
4533
:return: None
4634
If the method is called asynchronously,
4735
returns the request thread.
@@ -62,7 +50,7 @@ def clear_task_execution_cache_with_http_info(self, task_def_name, **kwargs): #
6250
>>> result = thread.get()
6351
6452
:param async_req bool
65-
:param object task_def_name: (required)
53+
:param str task_def_name: (required)
6654
:return: None
6755
If the method is called asynchronously,
6856
returns the request thread.
@@ -130,7 +118,7 @@ def get_redis_usage(self, **kwargs): # noqa: E501
130118
>>> result = thread.get()
131119
132120
:param async_req bool
133-
:return: object
121+
:return: dict(str, object)
134122
If the method is called asynchronously,
135123
returns the request thread.
136124
"""
@@ -150,7 +138,7 @@ def get_redis_usage_with_http_info(self, **kwargs): # noqa: E501
150138
>>> result = thread.get()
151139
152140
:param async_req bool
153-
:return: object
141+
:return: dict(str, object)
154142
If the method is called asynchronously,
155143
returns the request thread.
156144
"""
@@ -198,7 +186,7 @@ def get_redis_usage_with_http_info(self, **kwargs): # noqa: E501
198186
body=body_params,
199187
post_params=form_params,
200188
files=local_var_files,
201-
response_type='object', # noqa: E501
189+
response_type='dict(str, object)', # noqa: E501
202190
auth_settings=auth_settings,
203191
async_req=params.get('async_req'),
204192
_return_http_data_only=params.get('_return_http_data_only'),
@@ -215,8 +203,8 @@ def requeue_sweep(self, workflow_id, **kwargs): # noqa: E501
215203
>>> result = thread.get()
216204
217205
:param async_req bool
218-
:param object workflow_id: (required)
219-
:return: object
206+
:param str workflow_id: (required)
207+
:return: str
220208
If the method is called asynchronously,
221209
returns the request thread.
222210
"""
@@ -236,8 +224,8 @@ def requeue_sweep_with_http_info(self, workflow_id, **kwargs): # noqa: E501
236224
>>> result = thread.get()
237225
238226
:param async_req bool
239-
:param object workflow_id: (required)
240-
:return: object
227+
:param str workflow_id: (required)
228+
:return: str
241229
If the method is called asynchronously,
242230
returns the request thread.
243231
"""
@@ -291,7 +279,7 @@ def requeue_sweep_with_http_info(self, workflow_id, **kwargs): # noqa: E501
291279
body=body_params,
292280
post_params=form_params,
293281
files=local_var_files,
294-
response_type='object', # noqa: E501
282+
response_type='str', # noqa: E501
295283
auth_settings=auth_settings,
296284
async_req=params.get('async_req'),
297285
_return_http_data_only=params.get('_return_http_data_only'),
@@ -308,8 +296,8 @@ def verify_and_repair_workflow_consistency(self, workflow_id, **kwargs): # noqa
308296
>>> result = thread.get()
309297
310298
:param async_req bool
311-
:param object workflow_id: (required)
312-
:return: object
299+
:param str workflow_id: (required)
300+
:return: str
313301
If the method is called asynchronously,
314302
returns the request thread.
315303
"""
@@ -329,8 +317,8 @@ def verify_and_repair_workflow_consistency_with_http_info(self, workflow_id, **k
329317
>>> result = thread.get()
330318
331319
:param async_req bool
332-
:param object workflow_id: (required)
333-
:return: object
320+
:param str workflow_id: (required)
321+
:return: str
334322
If the method is called asynchronously,
335323
returns the request thread.
336324
"""
@@ -384,7 +372,7 @@ def verify_and_repair_workflow_consistency_with_http_info(self, workflow_id, **k
384372
body=body_params,
385373
post_params=form_params,
386374
files=local_var_files,
387-
response_type='object', # noqa: E501
375+
response_type='str', # noqa: E501
388376
auth_settings=auth_settings,
389377
async_req=params.get('async_req'),
390378
_return_http_data_only=params.get('_return_http_data_only'),
@@ -401,10 +389,10 @@ def view(self, tasktype, **kwargs): # noqa: E501
401389
>>> result = thread.get()
402390
403391
:param async_req bool
404-
:param object tasktype: (required)
405-
:param object start:
406-
:param object count:
407-
:return: object
392+
:param str tasktype: (required)
393+
:param int start:
394+
:param int count:
395+
:return: list[Task]
408396
If the method is called asynchronously,
409397
returns the request thread.
410398
"""
@@ -424,10 +412,10 @@ def view_with_http_info(self, tasktype, **kwargs): # noqa: E501
424412
>>> result = thread.get()
425413
426414
:param async_req bool
427-
:param object tasktype: (required)
428-
:param object start:
429-
:param object count:
430-
:return: object
415+
:param str tasktype: (required)
416+
:param int start:
417+
:param int count:
418+
:return: list[Task]
431419
If the method is called asynchronously,
432420
returns the request thread.
433421
"""
@@ -485,7 +473,7 @@ def view_with_http_info(self, tasktype, **kwargs): # noqa: E501
485473
body=body_params,
486474
post_params=form_params,
487475
files=local_var_files,
488-
response_type='object', # noqa: E501
476+
response_type='list[Task]', # noqa: E501
489477
auth_settings=auth_settings,
490478
async_req=params.get('async_req'),
491479
_return_http_data_only=params.get('_return_http_data_only'),

0 commit comments

Comments
 (0)