addressed python 3.9 issue and added duckduckgo search to the pyproject for building

Author: haneric00

aws-opentelemetry-distro/pyproject.toml

@@ -87,6 +87,7 @@ dependencies = [
   "langchain-aws == 0.2.15",
   "langchain-community == 0.3.27",
   "langgraph == 0.6.3",
+  "duckduckgo-search == 8.1.1",
 ]
 
 [project.optional-dependencies]

aws-opentelemetry-distro/src/amazon/opentelemetry/distro/opentelemetry/instrumentation/langchain_v2/callback_handler.py

@@ -218,9 +218,9 @@ def on_llm_start(
         prompts: list[str],
         *,
         run_id: UUID,
-        parent_run_id: UUID | None = None,
-        tags: Optional[list[str]] | None = None,
-        metadata: Optional[dict[str, Any]] | None = None,
+        parent_run_id: Optional[UUID] = None,
+        tags: Optional[list[str]] = None,
+        metadata: Optional[dict[str, Any]] = None,
         **kwargs: Any,
     ):
         if context_api.get_value(_SUPPRESS_INSTRUMENTATION_KEY):
@@ -254,8 +254,8 @@ def on_llm_end(
         response: LLMResult,
         *,
         run_id: UUID,
-        parent_run_id: UUID | None = None,
-        tags: Optional[list[str]] | None = None,
+        parent_run_id: Optional[UUID] = None,
+        tags: Optional[list[str]] = None,
         **kwargs: Any,
     ):
         if context_api.get_value(_SUPPRESS_INSTRUMENTATION_KEY):
@@ -302,8 +302,8 @@ def on_llm_error(
         error: BaseException,
         *,
         run_id: UUID,
-        parent_run_id: UUID | None = None,
-        tags: Optional[list[str]] | None = None,
+        parent_run_id: Optional[UUID] = None,
+        tags: Optional[list[str]] = None,
         **kwargs: Any,
     ):
         self._handle_error(error, run_id, parent_run_id, **kwargs)
@@ -314,9 +314,9 @@ def on_chain_start(
         inputs: dict[str, Any],
         *,
         run_id: UUID,
-        parent_run_id: UUID | None = None,
-        tags: Optional[list[str]] | None = None,
-        metadata: Optional[dict[str, Any]] | None = None,
+        parent_run_id: Optional[UUID] = None,
+        tags: Optional[list[str]] = None,
+        metadata: Optional[dict[str, Any]] = None,
         **kwargs: Any,
     ):
         if context_api.get_value(_SUPPRESS_INSTRUMENTATION_KEY):
@@ -342,8 +342,8 @@ def on_chain_end(
         outputs: dict[str, Any],
         *,
         run_id: UUID,
-        parent_run_id: UUID | None = None,
-        tags: list[str] | None = None,
+        parent_run_id: Optional[UUID] = None,
+        tags: Optional[list[str]] = None,
         **kwargs: Any,
     ):
 
@@ -359,8 +359,8 @@ def on_chain_error(
         self,
         error: BaseException,
         run_id: UUID,
-        parent_run_id: UUID | None = None,
-        tags: Optional[list[str]] | None = None,
+        parent_run_id: Optional[UUID] = None,
+        tags: Optional[list[str]] = None,
         **kwargs: Any,
     ):
         self._handle_error(error, run_id, parent_run_id, **kwargs)
@@ -371,10 +371,10 @@ def on_tool_start(
         input_str: str,
         *,
         run_id: UUID,
-        parent_run_id: UUID | None = None,
-        tags: list[str] | None = None,
-        metadata: dict[str, Any] | None = None,
-        inputs: dict[str, Any] | None = None,
+        parent_run_id: Optional[UUID] = None,
+        tags: Optional[list[str]] = None,
+        metadata: Optional[dict[str, Any]] = None,
+        inputs: Optional[dict[str, Any]] = None,
         **kwargs: Any,
     ):
         if context_api.get_value(_SUPPRESS_INSTRUMENTATION_KEY):
@@ -410,8 +410,8 @@ def on_tool_end(
         output: Any,
         *,
         run_id: UUID,
-        parent_run_id: UUID | None = None,
-        tags: list[str] | None = None,
+        parent_run_id: Optional[UUID] = None,
+        tags: Optional[list[str]] = None,
         **kwargs: Any,
     ):
         if context_api.get_value(_SUPPRESS_INSTRUMENTATION_KEY):
@@ -426,8 +426,8 @@ def on_tool_error(
         self,
         error: BaseException,
         run_id: UUID,
-        parent_run_id: UUID | None = None,
-        tags: list[str] | None = None,
+        parent_run_id: Optional[UUID] = None,
+        tags: Optional[list[str]] = None,
         **kwargs: Any,
     ):
         self._handle_error(error, run_id, parent_run_id, **kwargs)