diff --git a/examples/greetings.py b/examples/greetings.py index b80f72e3..4e5f62db 100644 --- a/examples/greetings.py +++ b/examples/greetings.py @@ -4,6 +4,3 @@ @worker_task(task_definition_name='greet') def greet(name: str) -> str: return f'Hello my friend {name}' - - - diff --git a/examples/hello_world.py b/examples/hello_world.py index dc1ff0b1..9da914e7 100644 --- a/examples/hello_world.py +++ b/examples/hello_world.py @@ -3,7 +3,6 @@ from conductor.client.configuration.configuration import Configuration from conductor.client.configuration.settings.authentication_settings import AuthenticationSettings from conductor.client.orkes_clients import OrkesClients -from conductor.client.worker.worker_task import worker_task from conductor.client.workflow.conductor_workflow import ConductorWorkflow from conductor.client.workflow.task.http_task import HttpTask from conductor.client.workflow.task.javascript_task import JavascriptTask diff --git a/examples/kitchensink.py b/examples/kitchensink.py index ea4595d0..662fcd2f 100644 --- a/examples/kitchensink.py +++ b/examples/kitchensink.py @@ -1,5 +1,4 @@ import os -import random from multiprocessing import set_start_method from sys import platform @@ -11,10 +10,8 @@ from conductor.client.workflow.conductor_workflow import ConductorWorkflow from conductor.client.workflow.task.http_task import HttpTask from conductor.client.workflow.task.javascript_task import JavascriptTask -from conductor.client.workflow.task.join_task import JoinTask from conductor.client.workflow.task.json_jq_task import JsonJQTask from conductor.client.workflow.task.set_variable_task import SetVariableTask -from conductor.client.workflow.task.sub_workflow_task import SubWorkflowTask from conductor.client.workflow.task.switch_task import SwitchTask from conductor.client.workflow.task.terminate_task import TerminateTask, WorkflowStatus from conductor.client.workflow.task.wait_task import WaitTask diff --git a/examples/open_ai_example.py b/examples/open_ai_example.py index 37749ddd..e4dc067c 100644 --- a/examples/open_ai_example.py +++ b/examples/open_ai_example.py @@ -1,21 +1,18 @@ import os import time -import uuid -from multiprocessing import set_start_method, Process +from multiprocessing import set_start_method from sys import platform + from conductor.client.ai.configuration import LLMProvider -from conductor.client.ai.integrations import AzureOpenAIConfig, OpenAIConfig +from conductor.client.ai.integrations import OpenAIConfig from conductor.client.ai.orchestrator import AIOrchestrator from conductor.client.automator.task_handler import TaskHandler from conductor.client.configuration.configuration import Configuration from conductor.client.configuration.settings.authentication_settings import AuthenticationSettings -from conductor.client.http.models import TaskResult, Task -from conductor.client.worker.worker import Worker -from conductor.client.worker.worker_task import WorkerTask, worker_task +from conductor.client.worker.worker_task import worker_task from conductor.client.workflow.conductor_workflow import ConductorWorkflow from conductor.client.workflow.task.llm_tasks.llm_text_complete import LlmTextComplete from conductor.client.workflow.task.llm_tasks.utils.prompt import Prompt -from conductor.client.workflow.task.simple_task import SimpleTask key = os.getenv("KEY") secret = os.getenv("SECRET") diff --git a/examples/workflow_ops.py b/examples/workflow_ops.py index 147da35f..f327eb71 100644 --- a/examples/workflow_ops.py +++ b/examples/workflow_ops.py @@ -17,7 +17,5 @@ def main(): wait_for_seconds=12) - - if __name__ == '__main__': main()