samples.snippets.subscriber_test: test_remove_dead_letter_policy failed #227

flaky-bot · 2020-10-21T11:12:24Z

This test failed!

To configure my behavior, see the Build Cop Bot documentation.

If I'm commenting on this issue too often, add the buildcop: quiet label and
I will stop commenting.

commit: 7de13b8
buildURL: Build Status, Sponge
status: failed

Test output

args = (subscription: "projects/python-docs-samples-tests/subscriptions/subscription-test-subscription-dlq-94797d067923478cb47afe733b09d01a"
,)
kwargs = {'metadata': [('x-goog-request-params', 'subscription=projects/python-docs-samples-tests/subscriptions/subscription-test-subscription-dlq-94797d067923478cb47afe733b09d01a'), ('x-goog-api-client', 'gl-python/3.8.3 grpc/1.32.0 gax/1.23.0')]}
@six.wraps(callable_)
def error_remapped_callable(*args, **kwargs):
    try:


      return callable_(*args, **kwargs)


.nox/py-3-8/lib/python3.8/site-packages/google/api_core/grpc_helpers.py:57:

self = <grpc._channel._UnaryUnaryMultiCallable object at 0x7f24afc6d6a0>

request = subscription: "projects/python-docs-samples-tests/subscriptions/subscription-test-subscription-dlq-94797d067923478cb47afe733b09d01a"
timeout = None

metadata = [('x-goog-request-params', 'subscription=projects/python-docs-samples-tests/subscriptions/subscription-test-subscription-dlq-94797d067923478cb47afe733b09d01a'), ('x-goog-api-client', 'gl-python/3.8.3 grpc/1.32.0 gax/1.23.0')]

credentials = None, wait_for_ready = None, compression = None
def __call__(self,
             request,
             timeout=None,
             metadata=None,
             credentials=None,
             wait_for_ready=None,
             compression=None):
    state, call, = self._blocking(request, timeout, metadata, credentials,
                                  wait_for_ready, compression)


  return _end_unary_response_blocking(state, call, False, None)


.nox/py-3-8/lib/python3.8/site-packages/grpc/_channel.py:826:

state = <grpc._channel._RPCState object at 0x7f24acb35a00>

call = <grpc._cython.cygrpc.SegregatedCall object at 0x7f24afbb06c0>

with_call = False, deadline = None
def _end_unary_response_blocking(state, call, with_call, deadline):
    if state.code is grpc.StatusCode.OK:
        if with_call:
            rendezvous = _MultiThreadedRendezvous(state, call, None, deadline)
            return state.response, rendezvous
        else:
            return state.response
    else:


      raise _InactiveRpcError(state)


E           grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:

E           	status = StatusCode.UNKNOWN

E           	details = "Stream removed"

E           	debug_error_string = "{"created":"@1603278725.494860777","description":"Error received from peer ipv4:74.125.195.95:443","file":"src/core/lib/surface/call.cc","file_line":1061,"grpc_message":"Stream removed","grpc_status":2}"

E           >
.nox/py-3-8/lib/python3.8/site-packages/grpc/_channel.py:729: _InactiveRpcError
The above exception was the direct cause of the following exception:
subscriber_client = <google.cloud.pubsub_v1.SubscriberClient object at 0x7f24afc81b50>

topic = 'projects/python-docs-samples-tests/topics/subscription-test-topic-94797d067923478cb47afe733b09d01a'
@pytest.fixture(scope="module")
def subscription_dlq(subscriber_client, topic):
    subscription_path = subscriber_client.subscription_path(PROJECT, SUBSCRIPTION_DLQ)

    try:
        subscription = subscriber_client.get_subscription(
            request={"subscription": subscription_path}
        )
    except:  # noqa
        subscription = subscriber_client.create_subscription(
            request={"name": subscription_path, "topic": topic}
        )

    yield subscription.name


  subscriber_client.delete_subscription(request={"subscription": subscription.name})


subscriber_test.py:144:

../../google/cloud/pubsub_v1/_gapic.py:40: in 

fx = lambda self, *a, **kw: wrapped_fx(self.api, *a, **kw)  # noqa

../../google/pubsub_v1/services/subscriber/client.py:723: in delete_subscription

rpc(

.nox/py-3-8/lib/python3.8/site-packages/google/api_core/gapic_v1/method.py:145: in call

return wrapped_func(*args, **kwargs)

.nox/py-3-8/lib/python3.8/site-packages/google/api_core/retry.py:281: in retry_wrapped_func

return retry_target(

.nox/py-3-8/lib/python3.8/site-packages/google/api_core/retry.py:184: in retry_target

return target()

.nox/py-3-8/lib/python3.8/site-packages/google/api_core/grpc_helpers.py:59: in error_remapped_callable

six.raise_from(exceptions.from_grpc_error(exc), exc)

value = None

from_value = <InactiveRpcError of RPC that terminated with:

status = StatusCode.UNKNOWN

details = "Stream removed"

debug_error....195.95:443","file":"src/core/lib/surface/call.cc","file_line":1061,"grpc_message":"Stream removed","grpc_status":2}"



???

E   google.api_core.exceptions.Unknown: None Stream removed

:3: Unknown

The text was updated successfully, but these errors were encountered:

flaky-bot · 2020-10-21T16:19:12Z

Looks like this issue is flaky. 😟

I'm going to leave this open and stop commenting.

A human should fix and close this.

When run at the same commit (7de13b8), this test passed in one build (Build Status, Sponge) and failed in another build (Build Status, Sponge).

anguillanneuf · 2020-10-23T22:27:06Z

I should probably remove test removing dead letter policy from subscription last.

flaky-bot · 2020-12-14T12:56:13Z

Oops! Looks like this issue is still flaky. It failed again. 😬