| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
|
Thanks for your pull request. It looks like this may be your first contribution to a Google open source project. Before we can look at your pull request, you'll need to sign a Contributor License Agreement (CLA). 📝 Please visit https://cla.developers.google.com/ to sign. Once you've signed, please reply here (e.g. I signed it!) and we'll verify. Thanks.
|
Sorry, something went wrong.
|
So there's good news and bad news. 👍 The good news is that everyone that needs to sign a CLA (the pull request submitter and all commit authors) have done so. Everything is all good there. 😕 The bad news is that it appears that one or more commits were authored by someone other than the pull request submitter. We need to confirm that they're okay with their commits being contributed to this project. Please have them confirm that here in the pull request. Note to project maintainer: This is a terminal state, meaning the cla/google commit status will not change from this state. It's up to you to confirm consent of the commit author(s) and merge this pull request when appropriate. |
Sorry, something went wrong.
|
CLAs look good, thanks! |
Sorry, something went wrong.
|
@calpeyser The cover environment is also failing because several lines do not have tests exercising them / some branches may not have all paths covered: google/cloud/bigtable/retry.py: 60-61, 78-120, 123, 126, 175, 45->exit, 172->175 google/cloud/bigtable/row_data.py: 279, 277->279 |
Sorry, something went wrong.
| table = instance.table("table") | ||
|
|
||
| # Run test, line by line | ||
| script = open(TEST_SCRIPT, 'r') |
| Sets the row key at which this iterator will begin reading. | ||
| """ | ||
| self.start_key = start_key | ||
| self.start_key_closed = False |
|
Hi @dhermes, can you help take a look at this? |
Sorry, something went wrong.
There was a problem hiding this comment.
Hi @calpeyser, thanks for submitting.
I have a few concerns about this as given. The principle of retrying when we know that we can seems fine, but I would ask that you do some cleanup before we accept this.
Thank you very much! :-)
Sorry, something went wrong.
| _MILLIS_PER_SECOND = 1000 | ||
|
|
||
|
|
||
| class ReadRowsIterator(): |
| if code not in self.retry_options.retry_codes: | ||
| six.reraise(type(error), error) | ||
|
|
||
| # pylint: disable=redefined-variable-type |
| deadline - now) | ||
| self.set_stream() | ||
|
|
||
| six.reraise(errors.RetryError, exc) |
|
|
||
| self._validate_chunk(chunk) | ||
|
|
||
| if ("ReadRowsIterator" in |
|
|
||
| test_platform = platform.system() | ||
| if (test_platform not in MOCK_SERVER_URLS): | ||
| self.fail("Retry server not available for platform " + test_platform) |
| table = instance.table("table") | ||
|
|
||
| # Run test, line by line | ||
| script = open(TEST_SCRIPT, 'r') |
| if line.startswith("CLIENT:"): | ||
| chunks = line.split(" ") | ||
| op = chunks[1] | ||
| if (op != "SCAN"): |
| process_scan(table, chunks[2], chunks[3]) | ||
|
|
||
| # Clean up | ||
| server.kill() |
| if (op != "SCAN"): | ||
| self.fail("Script contained " + op + " operation. Only \'SCAN\' is supported.") | ||
| else: | ||
| process_scan(table, chunks[2], chunks[3]) |
| return StatusCode.DEADLINE_EXCEEDED | ||
|
|
||
| def _wait_then_raise(): | ||
| time.sleep(0.5) |
|
@lukesneeringer @garye - I've attempted to address the comments above. Thanks for bearing with me! |
Sorry, something went wrong.
|
@calpeyser -- looks like you have some conflicts with the base branch, please resolve them. @lukesneeringer, @garye -- please take a look at the PR, it would be great to merge this functionality soon. Thanks everyone! |
Sorry, something went wrong.
|
LGTM from a bigtable perspective |
Sorry, something went wrong.
|
Conflict resolved, tests are passing. @lukesneeringer, what do you think? |
Sorry, something went wrong.
|
Reading now |
Sorry, something went wrong.
There was a problem hiding this comment.
This seems fine to me at this point.
Sorry, something went wrong.
|
@lukesneeringer - can you merge it? Neither I nor @garye have write permissions. |
Sorry, something went wrong.
|
🎉 |
Sorry, something went wrong.
|
Thank you @calpeyser for your work on this and thanks to @garye and @lukesneeringer for the reviews! |
Sorry, something went wrong.
|
This caused a system test breakage, I'm very tempted to roll it back and iterate in a PR / branch until the system tests are passing |
Sorry, something went wrong.
This reverts commit 67f4ba4.
This reverts commit 67f4ba4.
This reverts commit 67f4ba4.
This reverts commit 67f4ba4.
| Back | FazBrowse Home | New Git URL |
Since the repo's layout has changed significantly since the last PR, I've opened a new PR. I've attempted to address the comments from the last go-around - please have a look.