Skip to content

Commit

Permalink
formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
v1r3n committed Dec 26, 2023
1 parent 432e6ea commit 53620ca
Show file tree
Hide file tree
Showing 5 changed files with 4 additions and 16 deletions.
3 changes: 0 additions & 3 deletions examples/greetings.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,3 @@
@worker_task(task_definition_name='greet')
def greet(name: str) -> str:
return f'Hello my friend {name}'



1 change: 0 additions & 1 deletion examples/hello_world.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
3 changes: 0 additions & 3 deletions examples/kitchensink.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,4 @@
import os
import random
from multiprocessing import set_start_method
from sys import platform

Expand All @@ -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
Expand Down
11 changes: 4 additions & 7 deletions examples/open_ai_example.py
Original file line number Diff line number Diff line change
@@ -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")
Expand Down
2 changes: 0 additions & 2 deletions examples/workflow_ops.py
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,5 @@ def main():
wait_for_seconds=12)




if __name__ == '__main__':
main()

0 comments on commit 53620ca

Please sign in to comment.