File tree Expand file tree Collapse file tree 3 files changed +4
-1
lines changed
Expand file tree Collapse file tree 3 files changed +4
-1
lines changed Original file line number Diff line number Diff line change 1+ Fixed sync to use default concurrency (10) when download_concurrency was not specified
Original file line number Diff line number Diff line change @@ -166,6 +166,7 @@ class PythonRemote(Remote):
166166 """
167167
168168 TYPE = 'python'
169+ DEFAULT_DOWNLOAD_CONCURRENCY = 10
169170 prereleases = models .BooleanField (default = False )
170171 includes = JSONField (default = list )
171172 excludes = JSONField (default = list )
Original file line number Diff line number Diff line change @@ -115,13 +115,14 @@ async def run(self):
115115 if self .remote .proxy_url :
116116 environ .pop ('http_proxy' )
117117 deferred_download = self .remote .policy != Remote .IMMEDIATE
118+ workers = self .remote .download_concurrency or self .remote .DEFAULT_DOWNLOAD_CONCURRENCY
118119 with ProgressReport (
119120 message = "Fetching Project Metadata" , code = "sync.fetching.project"
120121 ) as p :
121122 pmirror = PulpMirror (
122123 serial = 0 , # Serial currently isn't supported by Pulp
123124 master = master ,
124- workers = self . remote . download_concurrency ,
125+ workers = workers ,
125126 deferred_download = deferred_download ,
126127 python_stage = self ,
127128 progress_report = p ,
You can’t perform that action at this time.
0 commit comments