Don't exit early if force for update_repository (#2434)

custom_components/hacs/repositories/appdaemon.py

@@ -7,6 +7,7 @@
 
 from ..enums import HacsCategory
 from ..exceptions import HacsException
+from ..utils.decorator import concurrent
 from .base import HacsRepository
 
 if TYPE_CHECKING:
@@ -57,9 +58,10 @@ async def validate_repository(self):
                     self.logger.error("%s %s", self, error)
         return self.validate.success
 
+    @concurrent(concurrenttasks=10, backoff_time=5)
     async def update_repository(self, ignore_issues=False, force=False):
         """Update."""
-        if not await self.common_update(ignore_issues, force):
+        if not await self.common_update(ignore_issues, force) and not force:
             return
 
         # Get appdaemon objects.

custom_components/hacs/repositories/integration.py

@@ -9,6 +9,7 @@
 from ..enums import HacsCategory, HacsGitHubRepo, RepositoryFile
 from ..exceptions import HacsException
 from ..utils.decode import decode_content
+from ..utils.decorator import concurrent
 from ..utils.filters import get_first_directory_in_directory
 from ..utils.version import version_to_download
 from .base import HacsRepository
@@ -97,9 +98,10 @@ async def validate_repository(self):
                     self.logger.error("%s %s", self, error)
         return self.validate.success
 
+    @concurrent(concurrenttasks=10, backoff_time=5)
     async def update_repository(self, ignore_issues=False, force=False):
         """Update."""
-        if not await self.common_update(ignore_issues, force):
+        if not await self.common_update(ignore_issues, force) and not force:
             return
 
         if self.data.content_in_root:

custom_components/hacs/repositories/netdaemon.py

@@ -6,6 +6,7 @@
 from ..enums import HacsCategory
 from ..exceptions import HacsException
 from ..utils import filters
+from ..utils.decorator import concurrent
 from .base import HacsRepository
 
 if TYPE_CHECKING:
@@ -61,9 +62,10 @@ async def validate_repository(self):
                     self.logger.error("%s %s", self, error)
         return self.validate.success
 
+    @concurrent(concurrenttasks=10, backoff_time=5)
     async def update_repository(self, ignore_issues=False, force=False):
         """Update."""
-        if not await self.common_update(ignore_issues, force):
+        if not await self.common_update(ignore_issues, force) and not force:
             return
 
         # Get appdaemon objects.

custom_components/hacs/repositories/plugin.py

@@ -5,6 +5,7 @@
 from typing import TYPE_CHECKING
 
 from ..exceptions import HacsException
+from ..utils.decorator import concurrent
 from .base import HacsRepository
 
 if TYPE_CHECKING:
@@ -51,9 +52,10 @@ async def validate_repository(self):
                     self.logger.error("%s %s", self, error)
         return self.validate.success
 
+    @concurrent(concurrenttasks=10, backoff_time=5)
     async def update_repository(self, ignore_issues=False, force=False):
         """Update."""
-        if not await self.common_update(ignore_issues, force):
+        if not await self.common_update(ignore_issues, force) and not force:
             return
 
         # Get plugin objects.

custom_components/hacs/repositories/python_script.py

@@ -5,6 +5,7 @@
 
 from ..enums import HacsCategory
 from ..exceptions import HacsException
+from ..utils.decorator import concurrent
 from .base import HacsRepository
 
 if TYPE_CHECKING:
@@ -62,9 +63,10 @@ async def async_post_registration(self):
         # Set name
         self.update_filenames()
 
+    @concurrent(concurrenttasks=10, backoff_time=5)
     async def update_repository(self, ignore_issues=False, force=False):
         """Update."""
-        if not await self.common_update(ignore_issues, force):
+        if not await self.common_update(ignore_issues, force) and not force:
             return
 
         # Get python_script objects.

custom_components/hacs/repositories/theme.py

@@ -5,6 +5,7 @@
 
 from ..enums import HacsCategory
 from ..exceptions import HacsException
+from ..utils.decorator import concurrent
 from .base import HacsRepository
 
 if TYPE_CHECKING:
@@ -68,9 +69,10 @@ async def async_post_registration(self):
         self.update_filenames()
         self.content.path.local = self.localpath
 
+    @concurrent(concurrenttasks=10, backoff_time=5)
     async def update_repository(self, ignore_issues=False, force=False):
         """Update."""
-        if not await self.common_update(ignore_issues, force):
+        if not await self.common_update(ignore_issues, force) and not force:
             return
 
         # Get theme objects.