Skip to content

Commit bf63b20

Browse files
Refactor: orkes clients
1 parent a943651 commit bf63b20

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

src/conductor/asyncio_client/orkes/orkes_clients.py

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -136,7 +136,7 @@ def get_authorization_client(self) -> OrkesAuthorizationClient:
136136
- Application management and access control
137137
- Permission granting and revocation
138138
"""
139-
return OrkesAuthorizationClient(self.configuration)
139+
return OrkesAuthorizationClient(self.configuration, self.api_client)
140140

141141
def get_metadata_client(self) -> OrkesMetadataClient:
142142
"""
@@ -155,7 +155,7 @@ def get_metadata_client(self) -> OrkesMetadataClient:
155155
- Schema validation and versioning
156156
- Metadata querying and retrieval
157157
"""
158-
return OrkesMetadataClient(self.configuration)
158+
return OrkesMetadataClient(self.configuration, self.api_client)
159159

160160
def get_scheduler_client(self) -> OrkesSchedulerClient:
161161
"""
@@ -174,7 +174,7 @@ def get_scheduler_client(self) -> OrkesSchedulerClient:
174174
- Managing schedule policies and triggers
175175
- Querying schedule execution history
176176
"""
177-
return OrkesSchedulerClient(self.configuration)
177+
return OrkesSchedulerClient(self.configuration, self.api_client)
178178

179179
def get_secret_client(self) -> OrkesSecretClient:
180180
"""
@@ -193,7 +193,7 @@ def get_secret_client(self) -> OrkesSecretClient:
193193
- Controlling access to sensitive information
194194
- Organizing secrets with tags and metadata
195195
"""
196-
return OrkesSecretClient(self.configuration)
196+
return OrkesSecretClient(self.configuration, self.api_client)
197197

198198
def get_task_client(self) -> OrkesTaskClient:
199199
"""
@@ -214,7 +214,7 @@ def get_task_client(self) -> OrkesTaskClient:
214214
- Managing task queues and worker assignments
215215
- Retrieving task execution history and logs
216216
"""
217-
return OrkesTaskClient(self.configuration)
217+
return OrkesTaskClient(self.configuration, self.api_client)
218218

219219
def get_integration_client(self) -> OrkesIntegrationClient:
220220
"""
@@ -233,7 +233,7 @@ def get_integration_client(self) -> OrkesIntegrationClient:
233233
- Controlling integration authentication
234234
- Managing integration providers and APIs
235235
"""
236-
return OrkesIntegrationClient(self.configuration)
236+
return OrkesIntegrationClient(self.configuration, self.api_client)
237237

238238
def get_prompt_client(self) -> OrkesPromptClient:
239239
"""
@@ -252,7 +252,7 @@ def get_prompt_client(self) -> OrkesPromptClient:
252252
- Versioning and organizing prompts
253253
- Managing prompt template metadata and tags
254254
"""
255-
return OrkesPromptClient(self.configuration)
255+
return OrkesPromptClient(self.configuration, self.api_client)
256256

257257
def get_schema_client(self) -> OrkesSchemaClient:
258258
"""
@@ -271,7 +271,7 @@ def get_schema_client(self) -> OrkesSchemaClient:
271271
- Versioning schema definitions
272272
- Managing schema metadata and documentation
273273
"""
274-
return OrkesSchemaClient(self.configuration)
274+
return OrkesSchemaClient(self.configuration, self.api_client)
275275

276276
def get_workflow_executor(self) -> AsyncWorkflowExecutor:
277277
"""

0 commit comments

Comments
 (0)