Fixed ruff lint issues in nemo guardrails (buerokratt#387)

* remove unwanted file

* updated changes

* fixed requested changes

* fixed issue

* service workflow implementation without calling service endpoints

* fixed requested changes

* fixed issues

* protocol related requested changes

* fixed requested changes

* update time tracking

* added time tracking and reloacate input guardrail before toolclassifiier

* fixed issue

* fixed issue

* added hybrid search for the service detection

* update tool classifier

* fixing merge conflicts

* fixed issue

* optimize first user query response generation time

* fixed pr reviewed issues

* service integration

* context based response generation flow

* fixed pr review suggested issues

* removed service project layer

* fixed issues

* delete unnessary files

* added requested changes

* fixed ruff lint issues for nemo guardrails

---------

Co-authored-by: Thiru Dinesh <56014038+Thirunayan22@users.noreply.github.com>

Author: nuwangeek

src/guardrails/dspy_nemo_adapter.py

@@ -62,7 +62,7 @@ def _identifying_params(self) -> Dict[str, Any]:
             "streaming": self.streaming,
         }
 
-    def _get_dspy_lm(self) -> Any:
+    def _get_dspy_lm(self) -> dspy.LM:
         """
         Get the active DSPy LM from settings.
 
@@ -264,9 +264,9 @@ async def _astream(
         loop = asyncio.get_running_loop()
 
         # Sentinel to mark end of stream
-        SENTINEL = object()
+        sentinel = object()
 
-        def producer():
+        def producer() -> None:
             """
             Synchronous producer running in a thread.
             Calls DSPy's LM with stream=True and pushes chunks to queue.
@@ -289,7 +289,7 @@ def producer():
                     loop.call_soon_threadsafe(queue.put_nowait, chunk)
 
                 # Signal completion
-                loop.call_soon_threadsafe(queue.put_nowait, SENTINEL)
+                loop.call_soon_threadsafe(queue.put_nowait, sentinel)
 
             except Exception as e:
                 # Pass exception to async consumer
@@ -305,7 +305,7 @@ def producer():
                 chunk = await queue.get()
 
                 # Check for completion
-                if chunk is SENTINEL:
+                if chunk is sentinel:
                     break
 
                 # Check for errors from producer

src/guardrails/optimized_guardrails_loader.py

@@ -19,7 +19,7 @@ class OptimizedGuardrailsLoader:
     - Falls back to base config if optimization not found
     """
 
-    def __init__(self, optimized_modules_dir: Optional[Path] = None):
+    def __init__(self, optimized_modules_dir: Optional[Path] = None) -> None:
         """
         Initialize the guardrails loader.