Sawra/sdk go fix

CHANGELOG.md

@@ -1,20 +1,19 @@
 # Changelog
 All notable changes to this project's latest version.
 
-## [0.1.40] - 2025-11-19
+## [0.1.41] - 2025-11-19
 
-### Bug Fixes
+### Documentation
 
-- Update Go SDK version handling in release script and workflow
+- Update changelog for v0.1.40
 
 ### Miscellaneous Tasks
 
-- Clean up release scripts and workflows
-- Bump version to v0.1.40
+- Bump version to v0.1.41
 
 ### Refactor
 
-- Clean up whitespace in serializer tests
-- Improve release process and add Go SDK
+- Clean up whitespace and formatting in example files
+- Enhance code quality and implement default traits
 
 <!-- generated by git-cliff -->

pyproject.toml

@@ -5,7 +5,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "runagent"
-version = "0.1.40"
+version = "0.1.41"
 description = "A command-line tool and SDK for deploying, managing, and interacting with AI agents"
 readme = "README.md"
 requires-python = ">=3.9"
@@ -103,7 +103,7 @@ line_length = 88
 skip = ["docs"]
 
 [tool.mypy]
-python_version = "0.1.40"
+python_version = "0.1.41"
 warn_return_any = true
 warn_unused_configs = true
 disallow_untyped_defs = true
@@ -159,7 +159,7 @@ fail_under = 80
 
 [tool.ruff]
 line-length = 88
-target-version = "0.1.40"
+target-version = "0.1.41"
 select = [
     "E",   # pycodestyle errors
     "W",   # pycodestyle warnings

runagent-go/version.go

@@ -1,4 +1,4 @@
 package runagent
 
 // Version represents the current version of the RunAgent Go SDK
-const Version = "0.1.40"
+const Version = "0.1.41"

runagent-rust/runagent/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "runagent"
-version = "0.1.40"
+version = "0.1.41"
 edition = "2021"
 description = "RunAgent SDK for Rust - Client SDK for interacting with deployed AI agents"
 license = "MIT"

runagent-rust/runagent/examples/async_example.rs

@@ -16,12 +16,12 @@ async fn main() -> runagent::RunAgentResult<()> {
         RunAgentClientConfig::new(agent_id, entrypoint_tag)
             .with_local(true)
             .with_address("127.0.0.1", 8452)
-            .with_enable_registry(false) // Skip DB lookup since we have explicit address
-    ).await?;
+            .with_enable_registry(false), // Skip DB lookup since we have explicit address
+    )
+    .await?;
 
     let response = client.run(&[("message", json!("Hello!"))]).await?;
 
     println!("Response: {}", response);
     Ok(())
 }
-

runagent-rust/runagent/examples/direct_construction.rs

@@ -11,18 +11,20 @@ async fn main() -> runagent::RunAgentResult<()> {
     let client = RunAgentClient::new(runagent::RunAgentClientConfig {
         agent_id: "a6977384-6c88-40dc-a629-e6bf077786ae".to_string(),
         entrypoint_tag: "minimal".to_string(),
-        api_key: Some("rau_b4dcebdef6386726b08971a1cc968d8a2b77c5834d30f3f5a43bddf065cd95cb".to_string()),
+        api_key: Some(
+            "rau_b4dcebdef6386726b08971a1cc968d8a2b77c5834d30f3f5a43bddf065cd95cb".to_string(),
+        ),
         base_url: Some("http://localhost:8333/".to_string()),
         local: None,
         host: None,
         port: None,
         extra_params: None,
         enable_registry: None,
-    }).await?;
+    })
+    .await?;
 
     let response = client.run(&[("message", json!("Hello!"))]).await?;
 
     println!("Response: {}", response);
     Ok(())
 }
-

runagent-rust/runagent/examples/direct_construction_omitted.rs

@@ -11,14 +11,16 @@ async fn main() -> runagent::RunAgentResult<()> {
     let client = RunAgentClient::new(runagent::RunAgentClientConfig {
         agent_id: "a6977384-6c88-40dc-a629-e6bf077786ae".to_string(),
         entrypoint_tag: "minimal".to_string(),
-        api_key: Some("rau_b4dcebdef6386726b08971a1cc968d8a2b77c5834d30f3f5a43bddf065cd95cb".to_string()),
+        api_key: Some(
+            "rau_b4dcebdef6386726b08971a1cc968d8a2b77c5834d30f3f5a43bddf065cd95cb".to_string(),
+        ),
         base_url: Some("http://localhost:8333/".to_string()),
         ..runagent::RunAgentClientConfig::default() // Omits all None fields
-    }).await?;
+    })
+    .await?;
 
     let response = client.run(&[("message", json!("Hello!"))]).await?;
 
     println!("Response: {}", response);
     Ok(())
 }
-

runagent-rust/runagent/examples/sync_example.rs

@@ -16,12 +16,11 @@ fn main() -> runagent::RunAgentResult<()> {
         RunAgentClientConfig::new(agent_id, entrypoint_tag)
             .with_local(true)
             .with_address("127.0.0.1", 8452)
-            .with_enable_registry(false) // Skip DB lookup since we have explicit address
+            .with_enable_registry(false), // Skip DB lookup since we have explicit address
     )?;
 
     let response = client.run(&[("message", json!("Hello!"))])?;
 
     println!("Response: {}", response);
     Ok(())
 }
-

runagent-rust/runagent/examples/test_deserialize.rs

@@ -3,13 +3,13 @@ use serde_json::json;
 
 fn main() {
     let serializer = CoreSerializer::new(10.0).unwrap();
-    
+
     // Test the exact structure we're getting
     let test_response = json!({
         "payload": "\"Hello, world!\"",
         "type": "string"
     });
-    
+
     println!("Input: {}", test_response);
     let result = serializer.deserialize_object(test_response).unwrap();
     println!("Result: {}", result);

runagent-rust/runagent/src/blocking.rs

@@ -98,10 +98,7 @@ impl RunAgentClient {
     ///     Ok(())
     /// }
     /// ```
-    pub fn run_stream(
-        &self,
-        input_kwargs: &[(&str, Value)],
-    ) -> RunAgentResult<BlockingStream> {
+    pub fn run_stream(&self, input_kwargs: &[(&str, Value)]) -> RunAgentResult<BlockingStream> {
         let stream = self.runtime.block_on(self.inner.run_stream(input_kwargs))?;
         Ok(BlockingStream::new(stream))
     }
@@ -193,9 +190,9 @@ impl BlockingStream {
         use futures::StreamExt;
         use std::sync::mpsc;
         use std::thread;
-        
+
         let (tx, rx) = mpsc::channel();
-        
+
         // Spawn a background task that continuously polls the stream
         let handle = thread::spawn(move || {
             // Create a new runtime for the background thread
@@ -209,7 +206,7 @@ impl BlockingStream {
                 }
             });
         });
-        
+
         Self {
             receiver: rx,
             _handle: handle,
@@ -224,4 +221,3 @@ impl Iterator for BlockingStream {
         self.receiver.recv().ok()
     }
 }
-

runagent-rust/runagent/src/client/mod.rs

@@ -5,6 +5,6 @@ pub mod runagent_client;
 pub mod socket_client;
 
 // Re-export the main client
-pub use runagent_client::{RunAgentClient, RunAgentClientConfig};
 pub use rest_client::RestClient;
-pub use socket_client::SocketClient;
+pub use runagent_client::{RunAgentClient, RunAgentClientConfig};
+pub use socket_client::SocketClient;