diff --git a/CHANGES/427.misc b/CHANGES/427.misc new file mode 100644 index 000000000..3f1ed947f --- /dev/null +++ b/CHANGES/427.misc @@ -0,0 +1 @@ +Updated ``ProgressReport`` to use new async API in sync task for pulpcore 3.15 diff --git a/pulp_python/app/tasks/sync.py b/pulp_python/app/tasks/sync.py index e65e86aa1..53ef763b5 100644 --- a/pulp_python/app/tasks/sync.py +++ b/pulp_python/app/tasks/sync.py @@ -116,7 +116,7 @@ async def run(self): environ.pop('http_proxy') deferred_download = self.remote.policy != Remote.IMMEDIATE workers = self.remote.download_concurrency or self.remote.DEFAULT_DOWNLOAD_CONCURRENCY - with ProgressReport( + async with ProgressReport( message="Fetching Project Metadata", code="sync.fetching.project" ) as p: pmirror = PulpMirror( @@ -198,7 +198,7 @@ async def determine_packages_to_sync(self): async def process_package(self, package): """Filters the package and creates content from it""" # Don't save anything if our metadata filters all fail. - self.progress_report.increment() + await self.progress_report.aincrement() if not package.filter_metadata(self.filters.filter_metadata_plugins()): return None