googleapis/python-eventarc

This library has moved to https://github.com/googleapis/google-cloud-python/tree/main/packages/google-cloud-eventarc

NOTE

This github repository is archived. The repository contents and history have moved to google-cloud-python.

Python Client for Eventarc API

Eventarc API: lets you asynchronously deliver events from Google services, SaaS, and your own apps using loosely coupled services that react to state changes. Eventarc requires no infrastructure management, you can optimize productivity and costs while building a modern, event-driven solution.

• Client Library Documentation
• Product Documentation

Quick Start

In order to use this library, you first need to go through the following steps:

1. Select or create a Cloud Platform project.
2. Enable billing for your project.
3. Enable the Eventarc API.
4. Setup Authentication.

Installation

Install this library in a virtualenv using pip. virtualenv is a tool to create isolated Python environments. The basic problem it addresses is one of dependencies and versions, and indirectly permissions.

With virtualenv, it's possible to install this library without needing system install permissions, and without clashing with the installed system dependencies.

Code samples and snippets

Code samples and snippets live in the samples/ folder.

Supported Python Versions

Our client libraries are compatible with all current active and maintenance versions of Python.

Python >= 3.7

Unsupported Python Versions

Python <= 3.6

If you are using an end-of-life version of Python, we recommend that you update as soon as possible to an actively supported version.

Mac/Linux

pip install virtualenv
virtualenv <your-env>
source <your-env>/bin/activate
<your-env>/bin/pip install google-cloud-eventarc

Windows

pip install virtualenv
virtualenv <your-env>
<your-env>\Scripts\activate
<your-env>\Scripts\pip.exe install google-cloud-eventarc

Next Steps

• Read the Client Library Documentation for Eventarc API to see other available methods on the client.
• Read the Eventarc API Product documentation to learn more about the product and see How-to Guides.
• View this README to see the full list of Cloud APIs that we cover.

python-eventarc's Issues

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_channels_async_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

@pytest.mark.asyncio
    async def test_list_channels_async_pager():
        client = EventarcAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )
    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_channels), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                    channel.Channel(),
                    channel.Channel(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListChannelsResponse(
                channels=[],
                next_page_token="def",
            ),
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                    channel.Channel(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_channels(
            request={},
        )
        assert async_pager.next_page_token == "abc"
        responses = []
        async for response in async_pager:  # pragma: no branch
            responses.append(response)

        assert len(responses) == 6


      assert all(isinstance(i, channel.Channel) for i in responses)


E           assert False

E            +  where False = all(<generator object test_list_channels_async_pager.. at 0x7fac1b4b5cf0>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:2642: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_providers_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

transport_name = 'grpc'
def test_list_providers_pager(transport_name: str = "grpc"):
    client = EventarcClient(
        credentials=ga_credentials.AnonymousCredentials,
        transport=transport_name,
    )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(type(client.transport.list_providers), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                    discovery.Provider(),
                    discovery.Provider(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListProvidersResponse(
                providers=[],
                next_page_token="def",
            ),
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                    discovery.Provider(),
                ],
            ),
            RuntimeError,
        )

        metadata = ()
        metadata = tuple(metadata) + (
            gapic_v1.routing_header.to_grpc_metadata((("parent", ""),)),
        )
        pager = client.list_providers(request={})

        assert pager._metadata == metadata

        results = list(pager)
        assert len(results) == 6


      assert all(isinstance(i, discovery.Provider) for i in results)


E           assert False

E            +  where False = all(<generator object test_list_providers_pager.. at 0x7f49967f0d60>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:3915: AssertionError

Warning: a recent release failed

The following release PRs may have failed:

• #160 - The release job was triggered, but has not reported back success.

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_providers_async_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

@pytest.mark.asyncio
    async def test_list_providers_async_pager():
        client = EventarcAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )
    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_providers), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                    discovery.Provider(),
                    discovery.Provider(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListProvidersResponse(
                providers=[],
                next_page_token="def",
            ),
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                    discovery.Provider(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_providers(
            request={},
        )
        assert async_pager.next_page_token == "abc"
        responses = []
        async for response in async_pager:  # pragma: no branch
            responses.append(response)

        assert len(responses) == 6


      assert all(isinstance(i, discovery.Provider) for i in responses)


E           assert False

E            +  where False = all(<generator object test_list_providers_async_pager.. at 0x7fac1a9b7e40>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:4006: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_triggers_async_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

@pytest.mark.asyncio
    async def test_list_triggers_async_pager():
        client = EventarcAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )
    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_triggers), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListTriggersResponse(
                triggers=[
                    trigger.Trigger(),
                    trigger.Trigger(),
                    trigger.Trigger(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListTriggersResponse(
                triggers=[],
                next_page_token="def",
            ),
            eventarc.ListTriggersResponse(
                triggers=[
                    trigger.Trigger(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListTriggersResponse(
                triggers=[
                    trigger.Trigger(),
                    trigger.Trigger(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_triggers(
            request={},
        )
        assert async_pager.next_page_token == "abc"
        responses = []
        async for response in async_pager:  # pragma: no branch
            responses.append(response)

        assert len(responses) == 6


      assert all(isinstance(i, trigger.Trigger) for i in responses)


E           assert False

E            +  where False = all(<generator object test_list_triggers_async_pager.. at 0x7f499687bc10>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:1245: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_triggers_async_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

@pytest.mark.asyncio
    async def test_list_triggers_async_pager():
        client = EventarcAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )
    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_triggers), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListTriggersResponse(
                triggers=[
                    trigger.Trigger(),
                    trigger.Trigger(),
                    trigger.Trigger(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListTriggersResponse(
                triggers=[],
                next_page_token="def",
            ),
            eventarc.ListTriggersResponse(
                triggers=[
                    trigger.Trigger(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListTriggersResponse(
                triggers=[
                    trigger.Trigger(),
                    trigger.Trigger(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_triggers(
            request={},
        )
        assert async_pager.next_page_token == "abc"
        responses = []
        async for response in async_pager:  # pragma: no branch
            responses.append(response)

        assert len(responses) == 6


      assert all(isinstance(i, trigger.Trigger) for i in responses)


E           assert False

E            +  where False = all(<generator object test_list_triggers_async_pager.. at 0x7fac1a9b7f20>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:1245: AssertionError

Remove replacements in owlbot.py

The owlbot.py file contains workarounds which should be removed once the bug googleapis/gapic-generator-python#701 in the gapic generator is fixed.

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_channel_connections_async_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

@pytest.mark.asyncio
    async def test_list_channel_connections_async_pager():
        client = EventarcAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )
    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_channel_connections),
        "__call__",
        new_callable=mock.AsyncMock,
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[],
                next_page_token="def",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_channel_connections(
            request={},
        )
        assert async_pager.next_page_token == "abc"
        responses = []
        async for response in async_pager:  # pragma: no branch
            responses.append(response)

        assert len(responses) == 6


      assert all(


            isinstance(i, channel_connection.ChannelConnection) for i in responses
        )

E           assert False

E            +  where False = all(<generator object test_list_channel_connections_async_pager.. at 0x7fac1af173c0>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:4708: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_providers_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

transport_name = 'grpc'
def test_list_providers_pager(transport_name: str = "grpc"):
    client = EventarcClient(
        credentials=ga_credentials.AnonymousCredentials,
        transport=transport_name,
    )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(type(client.transport.list_providers), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                    discovery.Provider(),
                    discovery.Provider(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListProvidersResponse(
                providers=[],
                next_page_token="def",
            ),
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                    discovery.Provider(),
                ],
            ),
            RuntimeError,
        )

        metadata = ()
        metadata = tuple(metadata) + (
            gapic_v1.routing_header.to_grpc_metadata((("parent", ""),)),
        )
        pager = client.list_providers(request={})

        assert pager._metadata == metadata

        results = list(pager)
        assert len(results) == 6


      assert all(isinstance(i, discovery.Provider) for i in results)


E           assert False

E            +  where False = all(<generator object test_list_providers_pager.. at 0x7f2ba861e730>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:3915: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_providers_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

transport_name = 'grpc'
def test_list_providers_pager(transport_name: str = "grpc"):
    client = EventarcClient(
        credentials=ga_credentials.AnonymousCredentials,
        transport=transport_name,
    )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(type(client.transport.list_providers), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                    discovery.Provider(),
                    discovery.Provider(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListProvidersResponse(
                providers=[],
                next_page_token="def",
            ),
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                    discovery.Provider(),
                ],
            ),
            RuntimeError,
        )

        metadata = ()
        metadata = tuple(metadata) + (
            gapic_v1.routing_header.to_grpc_metadata((("parent", ""),)),
        )
        pager = client.list_providers(request={})

        assert pager._metadata == metadata

        results = list(pager)
        assert len(results) == 6


      assert all(isinstance(i, discovery.Provider) for i in results)


E           assert False

E            +  where False = all(<generator object test_list_providers_pager.. at 0x7f61807faed0>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:3915: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_channel_connections_async_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

@pytest.mark.asyncio
    async def test_list_channel_connections_async_pager():
        client = EventarcAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )
    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_channel_connections),
        "__call__",
        new_callable=mock.AsyncMock,
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[],
                next_page_token="def",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_channel_connections(
            request={},
        )
        assert async_pager.next_page_token == "abc"
        responses = []
        async for response in async_pager:  # pragma: no branch
            responses.append(response)

        assert len(responses) == 6


      assert all(


            isinstance(i, channel_connection.ChannelConnection) for i in responses
        )

E           assert False

E            +  where False = all(<generator object test_list_channel_connections_async_pager.. at 0x7f499687bdd0>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:4708: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_channels_async_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

@pytest.mark.asyncio
    async def test_list_channels_async_pager():
        client = EventarcAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )
    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_channels), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                    channel.Channel(),
                    channel.Channel(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListChannelsResponse(
                channels=[],
                next_page_token="def",
            ),
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                    channel.Channel(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_channels(
            request={},
        )
        assert async_pager.next_page_token == "abc"
        responses = []
        async for response in async_pager:  # pragma: no branch
            responses.append(response)

        assert len(responses) == 6


      assert all(isinstance(i, channel.Channel) for i in responses)


E           assert False

E            +  where False = all(<generator object test_list_channels_async_pager.. at 0x7f2babd7b290>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:2642: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_providers_async_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

@pytest.mark.asyncio
    async def test_list_providers_async_pager():
        client = EventarcAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )
    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_providers), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                    discovery.Provider(),
                    discovery.Provider(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListProvidersResponse(
                providers=[],
                next_page_token="def",
            ),
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                    discovery.Provider(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_providers(
            request={},
        )
        assert async_pager.next_page_token == "abc"
        responses = []
        async for response in async_pager:  # pragma: no branch
            responses.append(response)

        assert len(responses) == 6


      assert all(isinstance(i, discovery.Provider) for i in responses)


E           assert False

E            +  where False = all(<generator object test_list_providers_async_pager.. at 0x7f49962b9f90>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:4006: AssertionError

Warning: a recent release failed

The following release PRs may have failed:

• #10

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_channels_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

transport_name = 'grpc'
def test_list_channels_pager(transport_name: str = "grpc"):
    client = EventarcClient(
        credentials=ga_credentials.AnonymousCredentials,
        transport=transport_name,
    )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(type(client.transport.list_channels), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                    channel.Channel(),
                    channel.Channel(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListChannelsResponse(
                channels=[],
                next_page_token="def",
            ),
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                    channel.Channel(),
                ],
            ),
            RuntimeError,
        )

        metadata = ()
        metadata = tuple(metadata) + (
            gapic_v1.routing_header.to_grpc_metadata((("parent", ""),)),
        )
        pager = client.list_channels(request={})

        assert pager._metadata == metadata

        results = list(pager)
        assert len(results) == 6


      assert all(isinstance(i, channel.Channel) for i in results)


E           assert False

E            +  where False = all(<generator object test_list_channels_pager.. at 0x7f61807fad50>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:2551: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_triggers_async_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

@pytest.mark.asyncio
    async def test_list_triggers_async_pager():
        client = EventarcAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )
    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_triggers), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListTriggersResponse(
                triggers=[
                    trigger.Trigger(),
                    trigger.Trigger(),
                    trigger.Trigger(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListTriggersResponse(
                triggers=[],
                next_page_token="def",
            ),
            eventarc.ListTriggersResponse(
                triggers=[
                    trigger.Trigger(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListTriggersResponse(
                triggers=[
                    trigger.Trigger(),
                    trigger.Trigger(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_triggers(
            request={},
        )
        assert async_pager.next_page_token == "abc"
        responses = []
        async for response in async_pager:  # pragma: no branch
            responses.append(response)

        assert len(responses) == 6


      assert all(isinstance(i, trigger.Trigger) for i in responses)


E           assert False

E            +  where False = all(<generator object test_list_triggers_async_pager.. at 0x7f61806c16d0>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:1245: AssertionError

Warning: a recent release failed

The following release PRs may have failed:

• #195 - The release job was triggered, but has not reported back success.

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_providers_async_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

@pytest.mark.asyncio
    async def test_list_providers_async_pager():
        client = EventarcAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )
    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_providers), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                    discovery.Provider(),
                    discovery.Provider(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListProvidersResponse(
                providers=[],
                next_page_token="def",
            ),
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                    discovery.Provider(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_providers(
            request={},
        )
        assert async_pager.next_page_token == "abc"
        responses = []
        async for response in async_pager:  # pragma: no branch
            responses.append(response)

        assert len(responses) == 6


      assert all(isinstance(i, discovery.Provider) for i in responses)


E           assert False

E            +  where False = all(<generator object test_list_providers_async_pager.. at 0x7f61806c17d0>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:4006: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_providers_async_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

@pytest.mark.asyncio
    async def test_list_providers_async_pager():
        client = EventarcAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )
    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_providers), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                    discovery.Provider(),
                    discovery.Provider(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListProvidersResponse(
                providers=[],
                next_page_token="def",
            ),
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                    discovery.Provider(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_providers(
            request={},
        )
        assert async_pager.next_page_token == "abc"
        responses = []
        async for response in async_pager:  # pragma: no branch
            responses.append(response)

        assert len(responses) == 6


      assert all(isinstance(i, discovery.Provider) for i in responses)


E           assert False

E            +  where False = all(<generator object test_list_providers_async_pager.. at 0x7f2ba83f90e0>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:4006: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_channels_async_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

@pytest.mark.asyncio
    async def test_list_channels_async_pager():
        client = EventarcAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )
    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_channels), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                    channel.Channel(),
                    channel.Channel(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListChannelsResponse(
                channels=[],
                next_page_token="def",
            ),
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                    channel.Channel(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_channels(
            request={},
        )
        assert async_pager.next_page_token == "abc"
        responses = []
        async for response in async_pager:  # pragma: no branch
            responses.append(response)

        assert len(responses) == 6


      assert all(isinstance(i, channel.Channel) for i in responses)


E           assert False

E            +  where False = all(<generator object test_list_channels_async_pager.. at 0x7f61802c2050>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:2642: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_channels_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

transport_name = 'grpc'
def test_list_channels_pager(transport_name: str = "grpc"):
    client = EventarcClient(
        credentials=ga_credentials.AnonymousCredentials,
        transport=transport_name,
    )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(type(client.transport.list_channels), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                    channel.Channel(),
                    channel.Channel(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListChannelsResponse(
                channels=[],
                next_page_token="def",
            ),
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                    channel.Channel(),
                ],
            ),
            RuntimeError,
        )

        metadata = ()
        metadata = tuple(metadata) + (
            gapic_v1.routing_header.to_grpc_metadata((("parent", ""),)),
        )
        pager = client.list_channels(request={})

        assert pager._metadata == metadata

        results = list(pager)
        assert len(results) == 6


      assert all(isinstance(i, channel.Channel) for i in results)


E           assert False

E            +  where False = all(<generator object test_list_channels_pager.. at 0x7fac0b66a510>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:2551: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_triggers_async_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

@pytest.mark.asyncio
    async def test_list_triggers_async_pager():
        client = EventarcAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )
    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_triggers), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListTriggersResponse(
                triggers=[
                    trigger.Trigger(),
                    trigger.Trigger(),
                    trigger.Trigger(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListTriggersResponse(
                triggers=[],
                next_page_token="def",
            ),
            eventarc.ListTriggersResponse(
                triggers=[
                    trigger.Trigger(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListTriggersResponse(
                triggers=[
                    trigger.Trigger(),
                    trigger.Trigger(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_triggers(
            request={},
        )
        assert async_pager.next_page_token == "abc"
        responses = []
        async for response in async_pager:  # pragma: no branch
            responses.append(response)

        assert len(responses) == 6


      assert all(isinstance(i, trigger.Trigger) for i in responses)


E           assert False

E            +  where False = all(<generator object test_list_triggers_async_pager.. at 0x7f2ba861e260>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:1245: AssertionError

Release as GA

GA release template

Required

• 28 days elapsed since last beta release with new API surface. See release history.
• Server API is GA. See API Release Notes.
• Package API is stable, and we can commit to backward compatibility
• All dependencies are GA

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_providers_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

transport_name = 'grpc'
def test_list_providers_pager(transport_name: str = "grpc"):
    client = EventarcClient(
        credentials=ga_credentials.AnonymousCredentials,
        transport=transport_name,
    )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(type(client.transport.list_providers), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                    discovery.Provider(),
                    discovery.Provider(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListProvidersResponse(
                providers=[],
                next_page_token="def",
            ),
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListProvidersResponse(
                providers=[
                    discovery.Provider(),
                    discovery.Provider(),
                ],
            ),
            RuntimeError,
        )

        metadata = ()
        metadata = tuple(metadata) + (
            gapic_v1.routing_header.to_grpc_metadata((("parent", ""),)),
        )
        pager = client.list_providers(request={})

        assert pager._metadata == metadata

        results = list(pager)
        assert len(results) == 6


      assert all(isinstance(i, discovery.Provider) for i in results)


E           assert False

E            +  where False = all(<generator object test_list_providers_pager.. at 0x7fac0b5ae6d0>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:3915: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_triggers_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

transport_name = 'grpc'
def test_list_triggers_pager(transport_name: str = "grpc"):
    client = EventarcClient(
        credentials=ga_credentials.AnonymousCredentials,
        transport=transport_name,
    )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(type(client.transport.list_triggers), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListTriggersResponse(
                triggers=[
                    trigger.Trigger(),
                    trigger.Trigger(),
                    trigger.Trigger(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListTriggersResponse(
                triggers=[],
                next_page_token="def",
            ),
            eventarc.ListTriggersResponse(
                triggers=[
                    trigger.Trigger(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListTriggersResponse(
                triggers=[
                    trigger.Trigger(),
                    trigger.Trigger(),
                ],
            ),
            RuntimeError,
        )

        metadata = ()
        metadata = tuple(metadata) + (
            gapic_v1.routing_header.to_grpc_metadata((("parent", ""),)),
        )
        pager = client.list_triggers(request={})

        assert pager._metadata == metadata

        results = list(pager)
        assert len(results) == 6


      assert all(isinstance(i, trigger.Trigger) for i in results)


E           assert False

E            +  where False = all(<generator object test_list_triggers_pager.. at 0x7fac1ac7dba0>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:1154: AssertionError

Dependency Dashboard

This issue provides visibility into Renovate updates and their statuses. Learn more

This repository currently has no open or pending branches.

---

• Check this box to trigger a request for Renovate to run again on this repository

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_channel_connections_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

transport_name = 'grpc'
def test_list_channel_connections_pager(transport_name: str = "grpc"):
    client = EventarcClient(
        credentials=ga_credentials.AnonymousCredentials,
        transport=transport_name,
    )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_channel_connections), "__call__"
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[],
                next_page_token="def",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                ],
            ),
            RuntimeError,
        )

        metadata = ()
        metadata = tuple(metadata) + (
            gapic_v1.routing_header.to_grpc_metadata((("parent", ""),)),
        )
        pager = client.list_channel_connections(request={})

        assert pager._metadata == metadata

        results = list(pager)
        assert len(results) == 6


      assert all(isinstance(i, channel_connection.ChannelConnection) for i in results)


E           assert False

E            +  where False = all(<generator object test_list_channel_connections_pager.. at 0x7fac0b5aed60>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:4613: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_channel_connections_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

transport_name = 'grpc'
def test_list_channel_connections_pager(transport_name: str = "grpc"):
    client = EventarcClient(
        credentials=ga_credentials.AnonymousCredentials,
        transport=transport_name,
    )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_channel_connections), "__call__"
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[],
                next_page_token="def",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                ],
            ),
            RuntimeError,
        )

        metadata = ()
        metadata = tuple(metadata) + (
            gapic_v1.routing_header.to_grpc_metadata((("parent", ""),)),
        )
        pager = client.list_channel_connections(request={})

        assert pager._metadata == metadata

        results = list(pager)
        assert len(results) == 6


      assert all(isinstance(i, channel_connection.ChannelConnection) for i in results)


E           assert False

E            +  where False = all(<generator object test_list_channel_connections_pager.. at 0x7f49967f00b0>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:4613: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_channels_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

transport_name = 'grpc'
def test_list_channels_pager(transport_name: str = "grpc"):
    client = EventarcClient(
        credentials=ga_credentials.AnonymousCredentials,
        transport=transport_name,
    )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(type(client.transport.list_channels), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                    channel.Channel(),
                    channel.Channel(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListChannelsResponse(
                channels=[],
                next_page_token="def",
            ),
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                    channel.Channel(),
                ],
            ),
            RuntimeError,
        )

        metadata = ()
        metadata = tuple(metadata) + (
            gapic_v1.routing_header.to_grpc_metadata((("parent", ""),)),
        )
        pager = client.list_channels(request={})

        assert pager._metadata == metadata

        results = list(pager)
        assert len(results) == 6


      assert all(isinstance(i, channel.Channel) for i in results)


E           assert False

E            +  where False = all(<generator object test_list_channels_pager.. at 0x7f499687edd0>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:2551: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_channel_connections_async_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

@pytest.mark.asyncio
    async def test_list_channel_connections_async_pager():
        client = EventarcAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )
    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_channel_connections),
        "__call__",
        new_callable=mock.AsyncMock,
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[],
                next_page_token="def",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_channel_connections(
            request={},
        )
        assert async_pager.next_page_token == "abc"
        responses = []
        async for response in async_pager:  # pragma: no branch
            responses.append(response)

        assert len(responses) == 6


      assert all(


            isinstance(i, channel_connection.ChannelConnection) for i in responses
        )

E           assert False

E            +  where False = all(<generator object test_list_channel_connections_async_pager.. at 0x7f2ba83fb450>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:4708: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_channels_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

transport_name = 'grpc'
def test_list_channels_pager(transport_name: str = "grpc"):
    client = EventarcClient(
        credentials=ga_credentials.AnonymousCredentials,
        transport=transport_name,
    )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(type(client.transport.list_channels), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                    channel.Channel(),
                    channel.Channel(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListChannelsResponse(
                channels=[],
                next_page_token="def",
            ),
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                    channel.Channel(),
                ],
            ),
            RuntimeError,
        )

        metadata = ()
        metadata = tuple(metadata) + (
            gapic_v1.routing_header.to_grpc_metadata((("parent", ""),)),
        )
        pager = client.list_channels(request={})

        assert pager._metadata == metadata

        results = list(pager)
        assert len(results) == 6


      assert all(isinstance(i, channel.Channel) for i in results)


E           assert False

E            +  where False = all(<generator object test_list_channels_pager.. at 0x7f2ba861d380>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:2551: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_channel_connections_async_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

@pytest.mark.asyncio
    async def test_list_channel_connections_async_pager():
        client = EventarcAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )
    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_channel_connections),
        "__call__",
        new_callable=mock.AsyncMock,
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[],
                next_page_token="def",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_channel_connections(
            request={},
        )
        assert async_pager.next_page_token == "abc"
        responses = []
        async for response in async_pager:  # pragma: no branch
            responses.append(response)

        assert len(responses) == 6


      assert all(


            isinstance(i, channel_connection.ChannelConnection) for i in responses
        )

E           assert False

E            +  where False = all(<generator object test_list_channel_connections_async_pager.. at 0x7f61806c1b50>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:4708: AssertionError

Warning: a recent release failed

The following release PRs may have failed:

• #160 - The release job was triggered, but has not reported back success.

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_channels_async_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

@pytest.mark.asyncio
    async def test_list_channels_async_pager():
        client = EventarcAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )
    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_channels), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                    channel.Channel(),
                    channel.Channel(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListChannelsResponse(
                channels=[],
                next_page_token="def",
            ),
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListChannelsResponse(
                channels=[
                    channel.Channel(),
                    channel.Channel(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_channels(
            request={},
        )
        assert async_pager.next_page_token == "abc"
        responses = []
        async for response in async_pager:  # pragma: no branch
            responses.append(response)

        assert len(responses) == 6


      assert all(isinstance(i, channel.Channel) for i in responses)


E           assert False

E            +  where False = all(<generator object test_list_channels_async_pager.. at 0x7f4999865740>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:2642: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_channel_connections_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

transport_name = 'grpc'
def test_list_channel_connections_pager(transport_name: str = "grpc"):
    client = EventarcClient(
        credentials=ga_credentials.AnonymousCredentials,
        transport=transport_name,
    )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_channel_connections), "__call__"
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[],
                next_page_token="def",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                ],
            ),
            RuntimeError,
        )

        metadata = ()
        metadata = tuple(metadata) + (
            gapic_v1.routing_header.to_grpc_metadata((("parent", ""),)),
        )
        pager = client.list_channel_connections(request={})

        assert pager._metadata == metadata

        results = list(pager)
        assert len(results) == 6


      assert all(isinstance(i, channel_connection.ChannelConnection) for i in results)


E           assert False

E            +  where False = all(<generator object test_list_channel_connections_pager.. at 0x7f61802c2e50>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:4613: AssertionError

tests.unit.gapic.eventarc_v1.test_eventarc: test_list_channel_connections_pager failed

This test failed!

To configure my behavior, see the Flaky Bot documentation.

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

---

commit: ecbea90
buildURL: Build Status, Sponge
status: failed

Test output

transport_name = 'grpc'
def test_list_channel_connections_pager(transport_name: str = "grpc"):
    client = EventarcClient(
        credentials=ga_credentials.AnonymousCredentials,
        transport=transport_name,
    )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_channel_connections), "__call__"
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                ],
                next_page_token="abc",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[],
                next_page_token="def",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                ],
                next_page_token="ghi",
            ),
            eventarc.ListChannelConnectionsResponse(
                channel_connections=[
                    channel_connection.ChannelConnection(),
                    channel_connection.ChannelConnection(),
                ],
            ),
            RuntimeError,
        )

        metadata = ()
        metadata = tuple(metadata) + (
            gapic_v1.routing_header.to_grpc_metadata((("parent", ""),)),
        )
        pager = client.list_channel_connections(request={})

        assert pager._metadata == metadata

        results = list(pager)
        assert len(results) == 6


      assert all(isinstance(i, channel_connection.ChannelConnection) for i in results)


E           assert False

E            +  where False = all(<generator object test_list_channel_connections_pager.. at 0x7f2ba83fa730>)
tests/unit/gapic/eventarc_v1/test_eventarc.py:4613: AssertionError