Refactoring improve sdk logging (#328)

Author: IgorChvyrov-sm

examples/async/dynamic_workflow.py

@@ -7,9 +7,9 @@
 
 import asyncio
 
+from conductor.asyncio_client.adapters import ApiClient
 from conductor.asyncio_client.automator.task_handler import TaskHandler
 from conductor.asyncio_client.configuration.configuration import Configuration
-from conductor.asyncio_client.adapters import ApiClient
 from conductor.asyncio_client.orkes.orkes_clients import OrkesClients
 from conductor.asyncio_client.worker.worker_task import worker_task
 from conductor.asyncio_client.workflow.conductor_workflow import AsyncConductorWorkflow
@@ -31,6 +31,7 @@ async def main():
     # CONDUCTOR_AUTH_KEY : API Authentication Key
     # CONDUCTOR_AUTH_SECRET: API Auth Secret
     api_config = Configuration()
+    api_config.apply_logging_config()
     task_handler = TaskHandler(configuration=api_config)
     task_handler.start_processes()
 

examples/async/helloworld/helloworld.py

@@ -2,9 +2,9 @@
 
 from greetings_workflow import greetings_workflow
 
+from conductor.asyncio_client.adapters import ApiClient
 from conductor.asyncio_client.automator.task_handler import TaskHandler
 from conductor.asyncio_client.configuration import Configuration
-from conductor.asyncio_client.adapters import ApiClient
 from conductor.asyncio_client.workflow.conductor_workflow import AsyncConductorWorkflow
 from conductor.asyncio_client.workflow.executor.workflow_executor import (
     AsyncWorkflowExecutor,
@@ -22,6 +22,7 @@ async def register_workflow(
 async def main():
     # points to http://localhost:8080/api by default
     api_config = Configuration()
+    api_config.apply_logging_config()
     async with ApiClient(api_config) as api_client:
         workflow_executor = AsyncWorkflowExecutor(
             configuration=api_config, api_client=api_client

examples/async/kitchensink.py

@@ -1,8 +1,8 @@
 import asyncio
 
+from conductor.asyncio_client.adapters import ApiClient
 from conductor.asyncio_client.automator.task_handler import TaskHandler
 from conductor.asyncio_client.configuration.configuration import Configuration
-from conductor.asyncio_client.adapters import ApiClient
 from conductor.asyncio_client.orkes.orkes_clients import OrkesClients
 from conductor.asyncio_client.worker.worker_task import worker_task
 from conductor.asyncio_client.workflow.conductor_workflow import AsyncConductorWorkflow
@@ -33,6 +33,7 @@ def start_workers(api_config):
 
 async def main():
     api_config = Configuration()
+    api_config.apply_logging_config()
 
     async with ApiClient(api_config) as api_client:
         clients = OrkesClients(api_client=api_client, configuration=api_config)

examples/async/orkes/copilot/open_ai_copilot.py

@@ -5,11 +5,11 @@
 from dataclasses import dataclass
 from typing import Dict, List
 
+from conductor.asyncio_client.adapters import ApiClient
 from conductor.asyncio_client.adapters.models import ExtendedTaskDef, TaskResult
 from conductor.asyncio_client.ai.orchestrator import AsyncAIOrchestrator
 from conductor.asyncio_client.automator.task_handler import TaskHandler
 from conductor.asyncio_client.configuration.configuration import Configuration
-from conductor.asyncio_client.adapters import ApiClient
 from conductor.asyncio_client.http.models.workflow_state_update import (
     WorkflowStateUpdate,
 )
@@ -115,6 +115,7 @@ async def main():
     llm_provider = "openai"
     chat_complete_model = "gpt-5"
     api_config = Configuration()
+    api_config.apply_logging_config()
 
     async with ApiClient(api_config) as api_client:
         clients = OrkesClients(api_client=api_client, configuration=api_config)

examples/async/orkes/fork_join_script.py

@@ -1,7 +1,7 @@
 import asyncio
 
-from conductor.asyncio_client.configuration import Configuration
 from conductor.asyncio_client.adapters import ApiClient
+from conductor.asyncio_client.configuration import Configuration
 from conductor.asyncio_client.orkes.orkes_clients import OrkesClients
 from conductor.asyncio_client.workflow.conductor_workflow import AsyncConductorWorkflow
 from conductor.asyncio_client.workflow.task.fork_task import ForkTask
@@ -13,6 +13,7 @@
 
 async def main():
     api_config = Configuration()
+    api_config.apply_logging_config()
     async with ApiClient(api_config) as api_client:
         clients = OrkesClients(configuration=api_config, api_client=api_client)
         executor = clients.get_workflow_executor()

examples/async/orkes/http_poll.py

@@ -1,8 +1,8 @@
 import asyncio
 import uuid
 
-from conductor.asyncio_client.configuration import Configuration
 from conductor.asyncio_client.adapters import ApiClient
+from conductor.asyncio_client.configuration import Configuration
 from conductor.asyncio_client.orkes.orkes_clients import OrkesClients
 from conductor.asyncio_client.workflow.conductor_workflow import AsyncConductorWorkflow
 from conductor.asyncio_client.workflow.task.http_poll_task import HttpPollTask
@@ -11,6 +11,7 @@
 
 async def main():
     configuration = Configuration()
+    configuration.apply_logging_config()
     async with ApiClient(configuration) as api_client:
         workflow_executor = OrkesClients(api_client).get_workflow_executor()
         workflow = AsyncConductorWorkflow(

examples/async/orkes/multiagent_chat.py

@@ -1,8 +1,8 @@
 import asyncio
 
+from conductor.asyncio_client.adapters import ApiClient
 from conductor.asyncio_client.ai.orchestrator import AsyncAIOrchestrator
 from conductor.asyncio_client.configuration.configuration import Configuration
-from conductor.asyncio_client.adapters import ApiClient
 from conductor.asyncio_client.orkes.orkes_clients import OrkesClients
 from conductor.asyncio_client.workflow.conductor_workflow import AsyncConductorWorkflow
 from conductor.asyncio_client.workflow.task.do_while_task import LoopTask
@@ -27,6 +27,7 @@ async def main():
     moderator_model = "command-r"
 
     api_config = Configuration()
+    api_config.apply_logging_config()
     async with ApiClient(api_config) as api_client:
         clients = OrkesClients(configuration=api_config, api_client=api_client)
         workflow_executor = clients.get_workflow_executor()

examples/async/orkes/open_ai_chat_gpt.py

@@ -3,10 +3,10 @@
 
 from workers.chat_workers import collect_history
 
+from conductor.asyncio_client.adapters import ApiClient
 from conductor.asyncio_client.ai.orchestrator import AsyncAIOrchestrator
 from conductor.asyncio_client.automator.task_handler import TaskHandler
 from conductor.asyncio_client.configuration.configuration import Configuration
-from conductor.asyncio_client.adapters import ApiClient
 from conductor.asyncio_client.orkes.orkes_clients import OrkesClients
 from conductor.asyncio_client.workflow.conductor_workflow import AsyncConductorWorkflow
 from conductor.asyncio_client.workflow.task.do_while_task import LoopTask
@@ -54,6 +54,7 @@ async def main():
     chat_complete_model = "gpt-5"
 
     api_config = Configuration()
+    api_config.apply_logging_config()
     task_handler = start_workers(api_config=api_config)
     async with ApiClient(api_config) as api_client:
         clients = OrkesClients(configuration=api_config, api_client=api_client)

examples/async/orkes/open_ai_function_example.py

@@ -2,11 +2,11 @@
 
 from workers.chat_workers import collect_history
 
+from conductor.asyncio_client.adapters import ApiClient
 from conductor.asyncio_client.adapters.models import ExtendedTaskDef
 from conductor.asyncio_client.ai.orchestrator import AsyncAIOrchestrator
 from conductor.asyncio_client.automator.task_handler import TaskHandler
 from conductor.asyncio_client.configuration.configuration import Configuration
-from conductor.asyncio_client.adapters import ApiClient
 from conductor.asyncio_client.orkes.orkes_clients import OrkesClients
 from conductor.asyncio_client.worker.worker_task import worker_task
 from conductor.asyncio_client.workflow.conductor_workflow import AsyncConductorWorkflow
@@ -45,6 +45,7 @@ async def main():
     chat_complete_model = "gpt-5"
 
     api_config = Configuration()
+    api_config.apply_logging_config()
     async with ApiClient(api_config) as api_client:
         clients = OrkesClients(configuration=api_config, api_client=api_client)
         workflow_executor = clients.get_workflow_executor()

examples/async/orkes/open_ai_helloworld.py

@@ -1,9 +1,9 @@
 import asyncio
 
+from conductor.asyncio_client.adapters import ApiClient
 from conductor.asyncio_client.ai.orchestrator import AsyncAIOrchestrator
 from conductor.asyncio_client.automator.task_handler import TaskHandler
 from conductor.asyncio_client.configuration.configuration import Configuration
-from conductor.asyncio_client.adapters import ApiClient
 from conductor.asyncio_client.worker.worker_task import worker_task
 from conductor.asyncio_client.workflow.conductor_workflow import AsyncConductorWorkflow
 from conductor.asyncio_client.workflow.task.llm_tasks.llm_text_complete import (
@@ -34,6 +34,7 @@ async def main():
     embedding_complete_model = "text-embedding-ada-002"
 
     api_config = Configuration()
+    api_config.apply_logging_config()
     async with ApiClient(api_config) as api_client:
         task_workers = start_workers(api_config)