Skip to content

feat: Add Async refresh to Sql Registry #4251

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.

Sign up for GitHub

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

Merged
franciscojavierarceo merged 14 commits into from
Jul 9, 2024
Merged

feat: Add Async refresh to Sql Registry #4251

Changes from 1 commit
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
c05b0db
Add sql registry async refresh
Jun 3, 2024
2074959
make refresh code a daemon thread
Jun 5, 2024
956b759
Change RegistryConfig to cacheMode
Jun 11, 2024
da82ba0
Only run async when ttl > 0
Jun 11, 2024
d4f58b6
make refresh async run in a loop
Jun 12, 2024
3092823
make refresh async run in a loop
Jun 12, 2024
9a5cc16
Reorder async refresh call
Jun 12, 2024
4593127
Add documentation
Jun 17, 2024
16c3646
Merge branch 'master' into support_async_refresh
stanconia Jul 2, 2024
a8513f8
Merge branch 'master' into support_async_refresh
stanconia Jul 2, 2024
8798696
Update test_universal_registry.py
stanconia Jul 2, 2024
00a1501
Force rerun of tests
Jul 3, 2024
3195382
Force rerun of tests
Jul 3, 2024
b7df692
Format repo config file
Jul 5, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
make refresh async run in a loop 
Signed-off-by: Stanley Opara <a-sopara@expediagroup.com>
  • Loading branch information
Stanley Opara committed Jun 12, 2024
commit 30928236e3ff97676d0ad957980edf409ddab23c
2 changes: 1 addition & 1 deletion sdk/python/tests/integration/registration/test_universal_registry.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -854,7 +854,7 @@ def test_registry_cache_thread_async(test_registry):
assert len(registry_data_sources_cached) == 0

# Wait for cache to be refreshed
time.sleep(8)
time.sleep(4)
# Now objects exist
registry_data_sources_cached = test_registry.list_data_sources(
project, allow_cache=True
Expand Down