opentelemetry: add pop_finished_spans

automon/integrations/openTelemetryWrapper/config.py

@@ -30,6 +30,12 @@ async def is_ready(self):
     async def get_finished_spans(self):
         return self.memory_processor.get_finished_spans()
 
+    async def pop_finished_spans(self):
+        """ideal is to lock, pop spans, and clear"""
+        spans = await self.get_finished_spans()
+        clear = await self.clear()
+        return spans
+
     async def test(self):
         with self.tracer.start_as_current_span("rootSpan"):
             with self.tracer.start_as_current_span("childSpan"):

automon/integrations/openTelemetryWrapper/test/test_pop_finished_spans.py

@@ -0,0 +1,23 @@
+import unittest
+import asyncio
+
+from automon.integrations.openTelemetryWrapper import OpenTelemetryConfig
+
+
+class MyTestCase(unittest.TestCase):
+    config = OpenTelemetryConfig()
+
+    if asyncio.run(config.is_ready()):
+        test = asyncio.run(config.test())
+
+        def test_pop_finished_spans(self):
+            spans = asyncio.run(self.config.pop_finished_spans())
+            self.assertIsNotNone(spans)
+
+            pass
+
+    pass
+
+
+if __name__ == '__main__':
+    unittest.main()