fix(ingest/okta): Conditionally close event_loop

metadata-ingestion/src/datahub/ingestion/source/identity/okta.py

@@ -303,11 +303,13 @@ def get_workunits_internal(self) -> Iterable[MetadataWorkUnit]:
         # This method can be called on the main thread or an async thread, so we must create a new loop if one doesn't exist
         # See https://docs.python.org/3/library/asyncio-eventloop.html for more info.
 
+        created_event_loop = False
         try:
             event_loop: asyncio.AbstractEventLoop = asyncio.get_event_loop()
         except RuntimeError:
             event_loop = asyncio.new_event_loop()
             asyncio.set_event_loop(event_loop)
+            created_event_loop = True
 
         # Step 1: Produce MetadataWorkUnits for CorpGroups.
         okta_groups: Optional[Iterable[Group]] = None
@@ -408,7 +410,8 @@ def get_workunits_internal(self) -> Iterable[MetadataWorkUnit]:
                 ).as_workunit()
 
         # Step 4: Close the event loop
-        event_loop.close()
+        if created_event_loop:
+            event_loop.close()
 
     def get_report(self):
         return self.report