expose timeout variables, change agent-session-key->id (#69)

Author: ren-jentic

python/examples/real_cli.py

@@ -3,6 +3,7 @@
 from typing import Any, Dict
 
 import jentic
+
 try:
     import click  # type: ignore
 except Exception:  # pragma: no cover - graceful fallback if click missing
@@ -78,7 +79,10 @@ def default_for(name: str, prop_schema: Dict[str, Any]) -> Any:
     for name, prop_schema in properties.items():
         if name in inputs:
             continue
-        if any(k in name.lower() for k in ["query", "q", "search", "topic", "keywords", "limit", "count"]):
+        if any(
+            k in name.lower()
+            for k in ["query", "q", "search", "topic", "keywords", "limit", "count"]
+        ):
             inputs[name] = default_for(name, prop_schema)
 
     return inputs
@@ -89,7 +93,9 @@ async def concept_find_articles_about_ai(client: jentic.Jentic) -> int:
 
     query = "find articles about AI"
     print(f"Searching: {query}")
-    search_response = await client.search(jentic.SearchRequest(query=query, limit=5, filter_by_credentials=False))
+    search_response = await client.search(
+        jentic.SearchRequest(query=query, limit=5, filter_by_credentials=False)
+    )
 
     if not search_response.results:
         print("No results found.")
@@ -181,6 +187,8 @@ async def concept_send_discord_message(
         print(f"Output: {out_preview}")
 
     return 0 if exec_resp.success else 1
+
+
 def main() -> None:
     if click is None:
         print("This CLI requires 'click'. Install it with: pip install click")
@@ -206,7 +214,9 @@ def cli(ctx: Any, agent_key: str, environment: str) -> None:  # noqa: ANN401 - c
         ctx.obj["agent_key"] = agent_key
         ctx.obj["environment"] = environment
 
-    @cli.command("articles-ai", help="Run the 'find articles about AI' concept (search → load → execute)")
+    @cli.command(
+        "articles-ai", help="Run the 'find articles about AI' concept (search → load → execute)"
+    )
     @click.pass_context
     def articles_ai(ctx: Any) -> None:  # noqa: ANN401 - click runtime
         config = jentic.AgentConfig(
@@ -240,4 +250,3 @@ def discord_send(ctx: Any, message: str | None, channel_id: str | None) -> None:
 
 if __name__ == "__main__":
     main()
-

python/src/jentic/lib/cfg.py

@@ -1,5 +1,6 @@
 import os
 from dataclasses import dataclass
+from typing import cast
 
 from jentic.lib.exc import JenticEnvironmentError, MissingAgentKeyError
 
@@ -49,7 +50,17 @@ def from_env(cls) -> "AgentConfig":
         if environment not in _ENDPOINTS:
             raise JenticEnvironmentError(f"Invalid environment: {environment}")
 
+        # Expose timeouts as environment variables
+        connect_timeout = cast(float, os.getenv("JENTIC_CONNECT_TIMEOUT", 10.0))
+        read_timeout = cast(float, os.getenv("JENTIC_READ_TIMEOUT", 10.0))
+        write_timeout = cast(float, os.getenv("JENTIC_WRITE_TIMEOUT", 120.0))
+        pool_timeout = cast(float, os.getenv("JENTIC_POOL_TIMEOUT", 120.0))
+
         return AgentConfig(
             agent_api_key=agent_api_key,
             environment=environment,
+            connect_timeout=connect_timeout,
+            read_timeout=read_timeout,
+            write_timeout=write_timeout,
+            pool_timeout=pool_timeout,
         )

python/src/jentic/lib/core_api.py

@@ -198,8 +198,8 @@ def _create_client(self) -> httpx.AsyncClient:
             headers["x-jentic-identity"] = os.getenv("x-jentic-identity")
         if os.getenv("x-jentic-session-id"):
             headers["x-jentic-session-id"] = os.getenv("x-jentic-session-id")
-        if os.getenv("x-jentic-agent-session-key"):
-            headers["x-jentic-agent-session-key"] = os.getenv("x-jentic-agent-session-key")
+        if os.getenv("x-jentic-agent-session-id"):
+            headers["x-jentic-agent-session-id"] = os.getenv("x-jentic-agent-session-id")
 
         # Timeouts (connect, read, write, pool)
         timeouts = httpx.Timeout(