Skip to content

Commit 73fc7e4

Browse files
authored
Merge pull request #428 from gerrod3/async_progress_reports
Use `ProgressReport`'s async API for pulpcore 3.15
2 parents d846942 + b931a37 commit 73fc7e4

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

CHANGES/427.misc

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
Updated ``ProgressReport`` to use new async API in sync task for pulpcore 3.15

pulp_python/app/tasks/sync.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ async def run(self):
116116
environ.pop('http_proxy')
117117
deferred_download = self.remote.policy != Remote.IMMEDIATE
118118
workers = self.remote.download_concurrency or self.remote.DEFAULT_DOWNLOAD_CONCURRENCY
119-
with ProgressReport(
119+
async with ProgressReport(
120120
message="Fetching Project Metadata", code="sync.fetching.project"
121121
) as p:
122122
pmirror = PulpMirror(
@@ -198,7 +198,7 @@ async def determine_packages_to_sync(self):
198198
async def process_package(self, package):
199199
"""Filters the package and creates content from it"""
200200
# Don't save anything if our metadata filters all fail.
201-
self.progress_report.increment()
201+
await self.progress_report.aincrement()
202202
if not package.filter_metadata(self.filters.filter_metadata_plugins()):
203203
return None
204204

0 commit comments

Comments
 (0)