-
Notifications
You must be signed in to change notification settings - Fork 1.5k
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
Add system test for 'Sink.create' using a Pubsub topic. #1656
Add system test for 'Sink.create' using a Pubsub topic. #1656
Conversation
try: | ||
doomed.delete() | ||
except NotFound as error: | ||
print('Unable to delete resource: %s' % error) |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Convert names from the XML API to the equivalent JSON names. Fixes #1659.
Rebased after merging #1658 to the |
…n_spellings Allow predefined ACL names from either XML or JSON APIs.
fix failing tests remove typing from expected value remove schema marker from dns#quotas return value update test specs for dns.Client#quotas remove schema marker from dns#quotas return value update test specs for dns.Client#quotas remove schema marker from dns#quotas return value fix failing tests for dns#quotas return value conditional skipping of the `kind` key
…o ojengwa-master
Improve correspondence w/ role names used by pubsub. Addresses: #1654 (comment) #1654 (comment).
Address three separate cases: - Query finishes within timeout, with all rows present. - Query finishes within timeout, but result set is too large for initial response. - Query times out. Closes #1551.
Expand/clarify synchronous query usage docs.
Add system tests for topic/subscription IAM policy get/set methods.
Cache job constructed for a synchronous query.
@@ -51,6 +52,7 @@ def setUp(self): | |||
self.to_delete = [] | |||
|
|||
def tearDown(self): | |||
from gcloud.exceptions import NotFound |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
Broken because 'Topic.set_iam_policy' returns 503s. See: #1654.
We found a Contributor License Agreement for you (the sender of this pull request) and all commit authors, but as best as we can tell these commits were authored by someone else. If that's the case, please add them to this pull request and have them confirm that they're okay with these commits being contributed to Google. If we're mistaken and you did author these commits, just reply here to confirm. |
Bad rebase? |
Continuing our discussion. Yeah it is too clever but a few more lines will get you where you need without having a hardcoded URL in two different places. url = pubsub_client.connection.api_base_url + topic.path
if url.startswith('https://'):
url = url[8:] |
Yup, I hadn't pushed the underlying |
Ping me when this PR looks how you expected it to? |
Using |
Sigh. I'll open a new PR. |
Currently broken because 'Topic.set_iam_policy' returns 503s. See: #1654.