Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

API(maps): refactored concurrent mapping with coroutines #78

Merged
merged 4 commits into from
Dec 10, 2023
Merged

Conversation

ntessore
Copy link
Contributor

@ntessore ntessore commented Dec 9, 2023

Concurrent mapping of catalogues now uses async def coroutines with a much simpler implementation. Instead of passing catalogue pages to each mapper, mappers now individually iterate over catalogues using async for, and an improved caching mechanism (now using lru_cache) ensures that mappers receive the same rows and selections from a FITS file.

Besides, the progress display of map_catalogs() and transform_maps() is much improved by using the rich package for dynamic progress updates.

Closes: #76
Closes: #77

@ntessore ntessore merged commit 160f157 into main Dec 10, 2023
7 checks passed
@ntessore ntessore deleted the pr-76 branch December 10, 2023 21:51
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Turn progress bar into an iterable wrapper Refactor parallel mapping of catalogues
1 participant