make sure its in same event loop (#241)

datadog_sync/utils/base_resource.py

@@ -63,6 +63,9 @@ class ResourceConfig:
     tagging_config: Optional[TaggingConfig] = None
     async_lock: Optional[Lock] = None
 
+    async def init_async(self) -> None:
+        self.async_lock = Lock()
+
     def __post_init__(self) -> None:
         self.build_excluded_attributes()
         if not self.concurrent:
@@ -84,6 +87,9 @@ def __init__(self, config: Configuration) -> None:
             self.resource_type
         )
 
+    async def init_async(self):
+        await self.resource_config.init_async()
+
     @abc.abstractmethod
     async def get_resources(self, client: CustomClient) -> List[Dict]:
         pass

datadog_sync/utils/configuration.py

@@ -50,6 +50,8 @@ class Configuration(object):
     async def init_async(self, cmd: Command):
         await self.source_client._init_session()
         await self.destination_client._init_session()
+        for resource in self.resources.values():
+            await resource.init_async()
 
         # Validate the clients. For import we only validate the source client
         # For sync/diffs we validate the destination client.