Updating _process_pipeline type hints to reflect return of None

mpenn · mpenn · commit f641a4cf885d · 2025-09-04T21:06:12.000-04:00
Signed-off-by: Matthew Penn &lt;mpenn@nvidia.com&gt;
diff --git a/src/nat/observability/exporter/processing_exporter.py b/src/nat/observability/exporter/processing_exporter.py
@@ -382,7 +382,7 @@ async def _pre_start(self) -> None:
                     self.output_type,
                     e)
 
-    async def _process_pipeline(self, item: PipelineInputT) -> PipelineOutputT:
+    async def _process_pipeline(self, item: PipelineInputT) -> PipelineOutputT | None:
         """Process item through all registered processors.
 
         Args:
@@ -481,7 +481,7 @@ async def _export_with_processing(self, item: PipelineInputT) -> None:
         """
         try:
             # Then, run through the processor pipeline
-            final_item: PipelineOutputT = await self._process_pipeline(item)
+            final_item: PipelineOutputT | None = await self._process_pipeline(item)
 
             # Skip export if pipeline dropped the item (returned None)
             if final_item is None:
