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
Sorry, something went wrong.
| 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.
Sorry, something went wrong.
| ] | ||
| ) | ||
| 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...
Sorry, something went wrong.
| 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 :-(
Sorry, something went wrong.
Codecov Report✅ All modified and coverable lines are covered by tests. @@ 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.
|
Sorry, something went wrong.
This 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.
|
I guess this can be closed after #935 was merged? |
Sorry, something went wrong.
I found no way to convert the current container.exec() based check function to any of the currently existing WaitStartegies and so I added RunFunctionWaitStrategy which can be used to convert such container.exec() based checks.
Helps with: #874
Closes: #883