We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b927af1 commit a7f40c7Copy full SHA for a7f40c7
pub-mirror.py
@@ -239,7 +239,15 @@ def main():
239
if not (pkgs_url := resp["nextUrl"]):
240
break
241
242
+ # wait for all packages to be handled
243
+ for f in concurrent.futures.as_completed(pkg_futures):
244
+ try:
245
+ f.result()
246
+ except Exception as e:
247
+ logger.error(f"Error handling package: {e}")
248
+
249
pkg_executor.shutdown(wait=True)
250
+ download_executor.shutdown(wait=True)
251
252
if clean:
253
# clean up obsolete packages
0 commit comments