Uh oh!
There was an error while loading. Please reload this page.
feat(core, postgres): Add RunFunctionWaitStrategy and use it in pg - #908
feat(core, postgres): Add RunFunctionWaitStrategy and use it in pg#908jankatins wants to merge 2 commits into
Conversation
b4ea0ee to
d2b2200Compare| result = self.func(container) | ||
| if result: | ||
| return result | ||
| except tuple(self._transient_exceptions) as e: |
There was a problem hiding this comment.
I actually found no reason why this shouldn't be a tuple already on self -> might be an nice refactoring on WaitStrategy and where it's used.
| ] | ||
| ) | ||
| if result.exit_code: | ||
| raise ConnectionError("pg_isready is not ready yet") |
There was a problem hiding this comment.
I assume that the pg_isready is some missing change in an older commit. I haven't investigated more...
| return returns.pop(0) | ||
| strategy = RunFunctionWaitStrategy(func).with_poll_interval(0) | ||
| strategy.wait_until_ready(mock_container) # type: ignore[arg-type] |
There was a problem hiding this comment.
For some reason mypy didn't like passing in the mock and I had to add the ignore despite other places in the same file not having this problem with mock. No idea why :-(
Codecov Report✅ All modified and coverable lines are covered by tests. Additional details and impacted files@@ Coverage Diff @@## main #908 +/- ##
==========================================
+ Coverage 79.78% 80.25% +0.46%
==========================================
Files 14 14 Lines 1182 1200 +18 Branches 184 186 +2 ==========================================
+ Hits 943 963 +20 + Misses 197 195 -2
Partials 42 42 ☔ View full report in Codecov by Sentry. 🚀 New features to boost your workflow:
|
8c1e4f9 to
531934aCompareThis is usefull for converting old wait_container_is_ready which use container.exec() to check for a condition to become True.
This gets rid of a annoying depcreation warning.
394bc31 to
202c8f4Comparejankatins
commented
Jan 7, 2026
I guess this can be closed after #935 was merged? |
I found no way to convert the current
container.exec()based check function to any of the currently existingWaitStartegiesand so I addedRunFunctionWaitStrategywhich can be used to convert suchcontainer.exec()based checks.Helps with: #874
Closes: #883