update samples to use environment configuration for client (#233)

* update samples to use environment configuration for client

* linting fixes

* update to direct profile mutation

* mutate config as dict

* update client config usage

* Update temporalio dependency (includes optional profile commit)

* remove unused toml & util

* Update SDK version to 1.18 (#247)

* Update SDK version to 1.18

* Update openai breaking change

* update samples to use environment configuration for client

* linting fixes

* update to direct profile mutation

* update new samples to use envconfig

* linting again

* remove redundant files/code

---------

Co-authored-by: tconley1428 <timothy.conley@temporal.io>

Author: THardy98

activity_worker/activity_worker.py

@@ -4,6 +4,7 @@
 
 from temporalio import activity
 from temporalio.client import Client
+from temporalio.envconfig import ClientConfig
 from temporalio.worker import Worker
 
 task_queue = "say-hello-task-queue"
@@ -18,7 +19,9 @@ async def say_hello_activity(name: str) -> str:
 
 async def main():
     # Create client to localhost on default namespace
-    client = await Client.connect("localhost:7233")
+    config = ClientConfig.load_client_connect_config()
+    config.setdefault("target_host", "localhost:7233")
+    client = await Client.connect(**config)
 
     # Run activity worker
     async with Worker(client, task_queue=task_queue, activities=[say_hello_activity]):

batch_sliding_window/starter.py

@@ -6,6 +6,7 @@
 import logging
 
 from temporalio.client import Client
+from temporalio.envconfig import ClientConfig
 
 from batch_sliding_window.batch_workflow import (
     ProcessBatchWorkflow,
@@ -19,7 +20,9 @@ async def main():
     logging.basicConfig(level=logging.INFO)
 
     # Create client
-    client = await Client.connect("localhost:7233")
+    config = ClientConfig.load_client_connect_config()
+    config.setdefault("target_host", "localhost:7233")
+    client = await Client.connect(**config)
 
     # Create unique workflow ID with timestamp
     timestamp = datetime.datetime.now().strftime("%Y%m%d_%H%M%S")

batch_sliding_window/worker.py

@@ -6,6 +6,7 @@
 
 from temporalio import worker
 from temporalio.client import Client
+from temporalio.envconfig import ClientConfig
 
 from batch_sliding_window.batch_workflow import ProcessBatchWorkflow
 from batch_sliding_window.record_loader_activity import RecordLoader
@@ -19,7 +20,9 @@ async def main():
     logging.basicConfig(level=logging.INFO)
 
     # Create client
-    client = await Client.connect("localhost:7233")
+    config = ClientConfig.load_client_connect_config()
+    config.setdefault("target_host", "localhost:7233")
+    client = await Client.connect(**config)
 
     # Create RecordLoader activity with sample data
     record_loader = RecordLoader(record_count=90)

bedrock/basic/run_worker.py

@@ -3,6 +3,7 @@
 import logging
 
 from temporalio.client import Client
+from temporalio.envconfig import ClientConfig
 from temporalio.worker import Worker
 from workflows import BasicBedrockWorkflow
 
@@ -11,7 +12,10 @@
 
 async def main():
     # Create client connected to server at the given address
-    client = await Client.connect("localhost:7233")
+    config = ClientConfig.load_client_connect_config()
+    config.setdefault("target_host", "localhost:7233")
+    client = await Client.connect(**config)
+
     activities = BedrockActivities()
 
     # Run the worker

bedrock/basic/send_message.py

@@ -2,12 +2,15 @@
 import sys
 
 from temporalio.client import Client
+from temporalio.envconfig import ClientConfig
 from workflows import BasicBedrockWorkflow
 
 
 async def main(prompt: str) -> str:
     # Create client connected to server at the given address
-    client = await Client.connect("localhost:7233")
+    config = ClientConfig.load_client_connect_config()
+    config.setdefault("target_host", "localhost:7233")
+    client = await Client.connect(**config)
 
     # Start the workflow
     workflow_id = "basic-bedrock-workflow"

bedrock/entity/end_chat.py

@@ -2,12 +2,15 @@
 import sys
 
 from temporalio.client import Client
+from temporalio.envconfig import ClientConfig
 from workflows import EntityBedrockWorkflow
 
 
 async def main():
     # Create client connected to server at the given address
-    client = await Client.connect("localhost:7233")
+    config = ClientConfig.load_client_connect_config()
+    config.setdefault("target_host", "localhost:7233")
+    client = await Client.connect(**config)
 
     workflow_id = "entity-bedrock-workflow"
 

bedrock/entity/get_history.py

@@ -1,12 +1,16 @@
 import asyncio
 
 from temporalio.client import Client
+from temporalio.envconfig import ClientConfig
 from workflows import EntityBedrockWorkflow
 
 
 async def main():
     # Create client connected to server at the given address
-    client = await Client.connect("localhost:7233")
+    config = ClientConfig.load_client_connect_config()
+    config.setdefault("target_host", "localhost:7233")
+    client = await Client.connect(**config)
+
     workflow_id = "entity-bedrock-workflow"
 
     handle = client.get_workflow_handle(workflow_id)

bedrock/entity/run_worker.py

@@ -3,6 +3,7 @@
 import logging
 
 from temporalio.client import Client
+from temporalio.envconfig import ClientConfig
 from temporalio.worker import Worker
 from workflows import EntityBedrockWorkflow
 
@@ -11,7 +12,10 @@
 
 async def main():
     # Create client connected to server at the given address
-    client = await Client.connect("localhost:7233")
+    config = ClientConfig.load_client_connect_config()
+    config.setdefault("target_host", "localhost:7233")
+    client = await Client.connect(**config)
+
     activities = BedrockActivities()
 
     # Run the worker

bedrock/entity/send_message.py

@@ -2,12 +2,15 @@
 import sys
 
 from temporalio.client import Client
+from temporalio.envconfig import ClientConfig
 from workflows import BedrockParams, EntityBedrockWorkflow
 
 
 async def main(prompt):
     # Create client connected to server at the given address
-    client = await Client.connect("localhost:7233")
+    config = ClientConfig.load_client_connect_config()
+    config.setdefault("target_host", "localhost:7233")
+    client = await Client.connect(**config)
 
     workflow_id = "entity-bedrock-workflow"
 

bedrock/signals_and_queries/get_history.py

@@ -1,12 +1,16 @@
 import asyncio
 
 from temporalio.client import Client
+from temporalio.envconfig import ClientConfig
 from workflows import SignalQueryBedrockWorkflow
 
 
 async def main():
     # Create client connected to server at the given address
-    client = await Client.connect("localhost:7233")
+    config = ClientConfig.load_client_connect_config()
+    config.setdefault("target_host", "localhost:7233")
+    client = await Client.connect(**config)
+
     workflow_id = "bedrock-workflow-with-signals"
 
     handle = client.get_workflow_handle(workflow_id)