Support single-threaded mode

sync/cli/Main.py

@@ -232,6 +232,7 @@ def github(cls) -> int:
         tracks.get_tracks(
             user_name=cls._args.user_name,
             repo_names=cls._args.repo_names,
+            single=cls._args.single,
             cover=cls._args.cover,
             use_ssh=cls._args.ssh
         )
@@ -253,7 +254,8 @@ def sync(cls) -> int:
         sync.create_local_tracks()
         sync.update(
             module_ids=cls._args.module_ids,
-            force=cls._args.force
+            force=cls._args.force,
+            single=cls._args.single
         )
 
         index = Index(root_folder=root_folder, config=config)

sync/cli/Parameters.py

@@ -26,7 +26,12 @@ def __init__(self, *args, **kwargs):
         super().__init__(*args, **kwargs)
 
         if add_custom_help:
-            Parameters.add_parser_help(self)
+            self.add_argument(
+                "-h",
+                "--help",
+                action=_HelpAction,
+                help="Show this help message and exit.",
+            )
 
 
 class BoolOrStrAction(Action):
@@ -267,7 +272,12 @@ def configure_parser_github(cls, sub_parsers):
 
         env = cls.add_parser_env(p, add_quiet=True)
         env.add_argument(
-            "--api-token",
+            "--single",
+            action="store_true",
+            help="Run in single-threaded mode."
+        )
+        env.add_argument(
+            "--token",
             metavar="GITHUB_TOKEN",
             type=str,
             default=cls._github_token,
@@ -311,7 +321,12 @@ def configure_parser_sync(cls, sub_parsers):
             help="Remove all old versions of modules."
         )
         cls.add_parser_git(p)
-        cls.add_parser_env(p, add_quiet=True)
+        env = cls.add_parser_env(p, add_quiet=True)
+        env.add_argument(
+            "--single",
+            action="store_true",
+            help="Run in single-threaded mode."
+        )
 
     @classmethod
     def configure_parser_index(cls, sub_parsers):
@@ -393,7 +408,12 @@ def add_parser_env(cls, p, add_quiet=False):
         )
 
         if add_quiet:
-            cls.add_parser_quiet(env)
+            env.add_argument(
+                "-q",
+                "--quiet",
+                action="store_true",
+                help="Disable all logging piped through stdout."
+            )
 
         env.add_argument(
             "--debug",
@@ -438,7 +458,7 @@ def add_parser_quiet(cls, p):
             "-q",
             "--quiet",
             action="store_true",
-            help="Disable all logging piped through stdout."
+            help="Show only error logs (piped through stderr)."
         )
 
     @classmethod

sync/core/Sync.py

@@ -125,13 +125,14 @@ def create_local_tracks(self):
         )
         return self._tracks
 
-    def update(self, module_ids=None, force=False, **kwargs):
+    def update(self, module_ids=None, force=False, single=False, **kwargs):
         user_name = kwargs.get("user_name")
         if user_name is not None:
             if self._check_tracks(self._tracks, GithubTracks):
                 tracks = self._tracks.get_tracks(
                     user_name=user_name,
                     repo_names=module_ids,
+                    single=single,
                     cover=kwargs.get("cover", False),
                     use_ssh=kwargs.get("use_ssh", True)
                 )
@@ -141,7 +142,7 @@ def update(self, module_ids=None, force=False, **kwargs):
         else:
             tracks = self._tracks.get_tracks(module_ids)
 
-        with ThreadPoolExecutor() as executor:
+        with ThreadPoolExecutor(max_workers=1 if single else None) as executor:
             futures = []
             for track in tracks:
                 futures.append(

sync/core/Sync.pyi

@@ -30,6 +30,12 @@ class Sync:
     def _check_tracks(obj: BaseTracks, cls: type) -> bool: ...
     def create_github_tracks(self, api_token: str, after_date: Optional[date] = ...) -> BaseTracks: ...
     def create_local_tracks(self) -> BaseTracks: ...
-    def update(self, module_ids: Optional[List[str]] = ..., force: bool = ..., **kwargs): ...
+    def update(
+        self,
+        module_ids: Optional[List[str]] = ...,
+        force: bool = ...,
+        single: bool = ...,
+        **kwargs
+    ): ...
     def push_by_git(self, branch: str): ...
     def get_versions_diff(self) -> Optional[str]: ...

sync/track/GithubTracks.py

@@ -61,7 +61,7 @@ def _get_from_repo_common(self, repo: Repository, use_ssh):
             name=repo.name
         )
         if homepage is None:
-            homepage = repo.html_url
+            homepage = ""
 
         return TrackJson(
             id=repo.name,
@@ -106,7 +106,7 @@ def get_track(self, user_name, repo_name, *, cover=False, use_ssh=True):
 
         return self._get_from_repo(repo, cover, use_ssh)
 
-    def get_tracks(self, user_name, repo_names=None, *, cover=False, use_ssh=True):
+    def get_tracks(self, user_name, repo_names=None, *, single=False, cover=False, use_ssh=True):
         self._tracks.clear()
         self._log.i(f"get_tracks: user_name = {user_name}")
 
@@ -124,7 +124,7 @@ def get_tracks(self, user_name, repo_names=None, *, cover=False, use_ssh=True):
         else:
             repos = user.get_repos()
 
-        with ThreadPoolExecutor() as executor:
+        with ThreadPoolExecutor(max_workers=1 if single else None) as executor:
             futures = []
             for repo in repos:
                 futures.append(

sync/track/GithubTracks.pyi

@@ -44,6 +44,7 @@ class GithubTracks(BaseTracks):
         user_name: str,
         repo_names: Optional[List[str]] = ...,
         *,
+        single: bool = ...,
         cover: bool = ...,
         use_ssh: bool = ...
     ) -> List[TrackJson]: ...