Git Product home page Git Product logo

python-dataplex's Introduction

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

Python Client for Cloud Dataplex API

stable pypi versions

Cloud Dataplex API: provides intelligent data fabric that enables organizations to centrally manage, monitor, and govern their data across data lakes, data warehouses, and data marts with consistent controls, providing access to trusted data and powering analytics at scale.

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 Cloud Dataplex 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-dataplex
Windows
pip install virtualenv
virtualenv <your-env>
<your-env>\Scripts\activate
<your-env>\Scripts\pip.exe install google-cloud-dataplex

Next Steps

python-dataplex's People

Contributors

dandhlee avatar gcf-owl-bot[bot] avatar parthea avatar release-please[bot] avatar

Stargazers

avatar avatar avatar avatar avatar avatar avatar

Watchers

avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar avatar

Forkers

renovate-bot classicvalues isabella232 qpc-github quantum-platinum-cloud saurabh-net

python-dataplex's Issues

tests.unit.gapic.dataplex_v1.test_metadata_service: test_list_partitions_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
transport_name = 'grpc'

def test_list_partitions_pager(transport_name: str = "grpc"):
    client = MetadataServiceClient(
        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_partitions), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                    metadata_.Partition(),
                    metadata_.Partition(),
                ],
                next_page_token="abc",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[],
                next_page_token="def",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                ],
                next_page_token="ghi",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                    metadata_.Partition(),
                ],
            ),
            RuntimeError,
        )

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

        assert pager._metadata == metadata

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





      assert all(isinstance(i, metadata_.Partition) for i in results)





E           assert False

E            +  where False = all(<generator object test_list_partitions_pager.. at 0x7f3b6ff79460>)


tests/unit/gapic/dataplex_v1/test_metadata_service.py:3024: AssertionError

tests.unit.gapic.dataplex_v1.test_metadata_service: test_list_entities_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
@pytest.mark.asyncio
    async def test_list_entities_async_pager():
        client = MetadataServiceAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_entities), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                    metadata_.Entity(),
                    metadata_.Entity(),
                ],
                next_page_token="abc",
            ),
            metadata_.ListEntitiesResponse(
                entities=[],
                next_page_token="def",
            ),
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                ],
                next_page_token="ghi",
            ),
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                    metadata_.Entity(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_entities(
            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, metadata_.Entity) for i in responses)





E           assert False

E            +  where False = all(<generator object test_list_entities_async_pager.. at 0x7fb497d00f90>)


tests/unit/gapic/dataplex_v1/test_metadata_service.py:1985: AssertionError

tests.unit.gapic.dataplex_v1.test_metadata_service: test_list_partitions_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
@pytest.mark.asyncio
    async def test_list_partitions_async_pager():
        client = MetadataServiceAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_partitions), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                    metadata_.Partition(),
                    metadata_.Partition(),
                ],
                next_page_token="abc",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[],
                next_page_token="def",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                ],
                next_page_token="ghi",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                    metadata_.Partition(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_partitions(
            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, metadata_.Partition) for i in responses)





E           assert False

E            +  where False = all(<generator object test_list_partitions_async_pager.. at 0x7f75febb6750>)


tests/unit/gapic/dataplex_v1/test_metadata_service.py:3115: AssertionError

tests.unit.gapic.dataplex_v1.test_metadata_service: test_list_entities_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
@pytest.mark.asyncio
    async def test_list_entities_async_pager():
        client = MetadataServiceAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_entities), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                    metadata_.Entity(),
                    metadata_.Entity(),
                ],
                next_page_token="abc",
            ),
            metadata_.ListEntitiesResponse(
                entities=[],
                next_page_token="def",
            ),
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                ],
                next_page_token="ghi",
            ),
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                    metadata_.Entity(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_entities(
            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, metadata_.Entity) for i in responses)





E           assert False

E            +  where False = all(<generator object test_list_entities_async_pager.. at 0x7fed69a3f2e0>)


tests/unit/gapic/dataplex_v1/test_metadata_service.py:1985: AssertionError

tests.unit.gapic.dataplex_v1.test_metadata_service: test_list_partitions_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
@pytest.mark.asyncio
    async def test_list_partitions_async_pager():
        client = MetadataServiceAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_partitions), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                    metadata_.Partition(),
                    metadata_.Partition(),
                ],
                next_page_token="abc",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[],
                next_page_token="def",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                ],
                next_page_token="ghi",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                    metadata_.Partition(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_partitions(
            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, metadata_.Partition) for i in responses)





E           assert False

E            +  where False = all(<generator object test_list_partitions_async_pager.. at 0x7fed6ac5d0b0>)


tests/unit/gapic/dataplex_v1/test_metadata_service.py:3115: AssertionError

tests.unit.gapic.dataplex_v1.test_content_service: test_list_content_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
@pytest.mark.asyncio
    async def test_list_content_async_pager():
        client = ContentServiceAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_content), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            content.ListContentResponse(
                content=[
                    analyze.Content(),
                    analyze.Content(),
                    analyze.Content(),
                ],
                next_page_token="abc",
            ),
            content.ListContentResponse(
                content=[],
                next_page_token="def",
            ),
            content.ListContentResponse(
                content=[
                    analyze.Content(),
                ],
                next_page_token="ghi",
            ),
            content.ListContentResponse(
                content=[
                    analyze.Content(),
                    analyze.Content(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_content(
            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, analyze.Content) for i in responses)





E           assert False

E            +  where False = all(<generator object test_list_content_async_pager.. at 0x7fed6945b9e0>)


tests/unit/gapic/dataplex_v1/test_content_service.py:1992: AssertionError

tests.unit.gapic.dataplex_v1.test_metadata_service: test_list_entities_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
@pytest.mark.asyncio
    async def test_list_entities_async_pager():
        client = MetadataServiceAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_entities), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                    metadata_.Entity(),
                    metadata_.Entity(),
                ],
                next_page_token="abc",
            ),
            metadata_.ListEntitiesResponse(
                entities=[],
                next_page_token="def",
            ),
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                ],
                next_page_token="ghi",
            ),
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                    metadata_.Entity(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_entities(
            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, metadata_.Entity) for i in responses)





E           assert False

E            +  where False = all(<generator object test_list_entities_async_pager.. at 0x7f75febd00d0>)


tests/unit/gapic/dataplex_v1/test_metadata_service.py:1985: AssertionError

tests.unit.gapic.dataplex_v1.test_metadata_service: test_list_entities_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
@pytest.mark.asyncio
    async def test_list_entities_async_pager():
        client = MetadataServiceAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_entities), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                    metadata_.Entity(),
                    metadata_.Entity(),
                ],
                next_page_token="abc",
            ),
            metadata_.ListEntitiesResponse(
                entities=[],
                next_page_token="def",
            ),
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                ],
                next_page_token="ghi",
            ),
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                    metadata_.Entity(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_entities(
            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, metadata_.Entity) for i in responses)





E           assert False

E            +  where False = all(<generator object test_list_entities_async_pager.. at 0x7f3b7006ece0>)


tests/unit/gapic/dataplex_v1/test_metadata_service.py:1985: AssertionError

tests.unit.gapic.dataplex_v1.test_content_service: test_list_content_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
transport_name = 'grpc'

def test_list_content_pager(transport_name: str = "grpc"):
    client = ContentServiceClient(
        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_content), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            content.ListContentResponse(
                content=[
                    analyze.Content(),
                    analyze.Content(),
                    analyze.Content(),
                ],
                next_page_token="abc",
            ),
            content.ListContentResponse(
                content=[],
                next_page_token="def",
            ),
            content.ListContentResponse(
                content=[
                    analyze.Content(),
                ],
                next_page_token="ghi",
            ),
            content.ListContentResponse(
                content=[
                    analyze.Content(),
                    analyze.Content(),
                ],
            ),
            RuntimeError,
        )

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

        assert pager._metadata == metadata

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





      assert all(isinstance(i, analyze.Content) for i in results)





E           assert False

E            +  where False = all(<generator object test_list_content_pager.. at 0x7f75ff921d50>)


tests/unit/gapic/dataplex_v1/test_content_service.py:1901: AssertionError

Release as stable

GA release template

Required

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

tests.unit.gapic.dataplex_v1.test_metadata_service: test_list_partitions_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
transport_name = 'grpc'

def test_list_partitions_pager(transport_name: str = "grpc"):
    client = MetadataServiceClient(
        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_partitions), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                    metadata_.Partition(),
                    metadata_.Partition(),
                ],
                next_page_token="abc",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[],
                next_page_token="def",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                ],
                next_page_token="ghi",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                    metadata_.Partition(),
                ],
            ),
            RuntimeError,
        )

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

        assert pager._metadata == metadata

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





      assert all(isinstance(i, metadata_.Partition) for i in results)





E           assert False

E            +  where False = all(<generator object test_list_partitions_pager.. at 0x7fb49772f7b0>)


tests/unit/gapic/dataplex_v1/test_metadata_service.py:3024: AssertionError

tests.unit.gapic.dataplex_v1.test_content_service: test_list_content_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
@pytest.mark.asyncio
    async def test_list_content_async_pager():
        client = ContentServiceAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_content), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            content.ListContentResponse(
                content=[
                    analyze.Content(),
                    analyze.Content(),
                    analyze.Content(),
                ],
                next_page_token="abc",
            ),
            content.ListContentResponse(
                content=[],
                next_page_token="def",
            ),
            content.ListContentResponse(
                content=[
                    analyze.Content(),
                ],
                next_page_token="ghi",
            ),
            content.ListContentResponse(
                content=[
                    analyze.Content(),
                    analyze.Content(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_content(
            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, analyze.Content) for i in responses)





E           assert False

E            +  where False = all(<generator object test_list_content_async_pager.. at 0x7f75ff0c6350>)


tests/unit/gapic/dataplex_v1/test_content_service.py:1992: AssertionError

tests.unit.gapic.dataplex_v1.test_content_service: test_list_content_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
@pytest.mark.asyncio
    async def test_list_content_async_pager():
        client = ContentServiceAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_content), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            content.ListContentResponse(
                content=[
                    analyze.Content(),
                    analyze.Content(),
                    analyze.Content(),
                ],
                next_page_token="abc",
            ),
            content.ListContentResponse(
                content=[],
                next_page_token="def",
            ),
            content.ListContentResponse(
                content=[
                    analyze.Content(),
                ],
                next_page_token="ghi",
            ),
            content.ListContentResponse(
                content=[
                    analyze.Content(),
                    analyze.Content(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_content(
            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, analyze.Content) for i in responses)





E           assert False

E            +  where False = all(<generator object test_list_content_async_pager.. at 0x7fb4968d8f20>)


tests/unit/gapic/dataplex_v1/test_content_service.py:1992: AssertionError

tests.unit.gapic.dataplex_v1.test_dataplex_service: many tests failed

Many tests failed at the same time in this package.

  • I will close this issue when there are no more failures in this package and
    there is at least one pass.
  • No new issues will be filed for this package until this issue is closed.
  • If there are already issues for individual test cases, I will close them when
    the corresponding test passes. You can close them earlier, if you prefer, and
    I won't reopen them while this issue is still open.

Here are the tests that failed:

  • test_list_lakes_pager
  • test_list_lakes_async_pager
  • test_list_lake_actions_pager
  • test_list_lake_actions_async_pager
  • test_list_zones_pager
  • test_list_zones_async_pager
  • test_list_zone_actions_pager
  • test_list_zone_actions_async_pager
  • test_list_assets_pager
  • test_list_assets_async_pager
  • test_list_asset_actions_pager
  • test_list_asset_actions_async_pager
  • test_list_tasks_pager
  • test_list_tasks_async_pager
  • test_list_jobs_pager
  • test_list_jobs_async_pager
  • test_list_environments_pager
  • test_list_environments_async_pager
  • test_list_sessions_pager
  • test_list_sessions_async_pager

commit: 4e00aed
buildURL: Build Status, Sponge
status: failed

tests.unit.gapic.dataplex_v1.test_metadata_service: test_list_entities_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
transport_name = 'grpc'

def test_list_entities_pager(transport_name: str = "grpc"):
    client = MetadataServiceClient(
        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_entities), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                    metadata_.Entity(),
                    metadata_.Entity(),
                ],
                next_page_token="abc",
            ),
            metadata_.ListEntitiesResponse(
                entities=[],
                next_page_token="def",
            ),
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                ],
                next_page_token="ghi",
            ),
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                    metadata_.Entity(),
                ],
            ),
            RuntimeError,
        )

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

        assert pager._metadata == metadata

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





      assert all(isinstance(i, metadata_.Entity) for i in results)





E           assert False

E            +  where False = all(<generator object test_list_entities_pager.. at 0x7f3b701067a0>)


tests/unit/gapic/dataplex_v1/test_metadata_service.py:1894: AssertionError

tests.unit.gapic.dataplex_v1.test_metadata_service: test_list_partitions_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
@pytest.mark.asyncio
    async def test_list_partitions_async_pager():
        client = MetadataServiceAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_partitions), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                    metadata_.Partition(),
                    metadata_.Partition(),
                ],
                next_page_token="abc",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[],
                next_page_token="def",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                ],
                next_page_token="ghi",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                    metadata_.Partition(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_partitions(
            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, metadata_.Partition) for i in responses)





E           assert False

E            +  where False = all(<generator object test_list_partitions_async_pager.. at 0x7f3b70918e40>)


tests/unit/gapic/dataplex_v1/test_metadata_service.py:3115: AssertionError

tests.unit.gapic.dataplex_v1.test_metadata_service: test_list_entities_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
transport_name = 'grpc'

def test_list_entities_pager(transport_name: str = "grpc"):
    client = MetadataServiceClient(
        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_entities), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                    metadata_.Entity(),
                    metadata_.Entity(),
                ],
                next_page_token="abc",
            ),
            metadata_.ListEntitiesResponse(
                entities=[],
                next_page_token="def",
            ),
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                ],
                next_page_token="ghi",
            ),
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                    metadata_.Entity(),
                ],
            ),
            RuntimeError,
        )

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

        assert pager._metadata == metadata

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





      assert all(isinstance(i, metadata_.Entity) for i in results)





E           assert False

E            +  where False = all(<generator object test_list_entities_pager.. at 0x7fb49764ee40>)


tests/unit/gapic/dataplex_v1/test_metadata_service.py:1894: AssertionError

tests.unit.gapic.dataplex_v1.test_dataplex_service: many tests failed

Many tests failed at the same time in this package.

  • I will close this issue when there are no more failures in this package and
    there is at least one pass.
  • No new issues will be filed for this package until this issue is closed.
  • If there are already issues for individual test cases, I will close them when
    the corresponding test passes. You can close them earlier, if you prefer, and
    I won't reopen them while this issue is still open.

Here are the tests that failed:

  • test_list_lakes_pager
  • test_list_lakes_async_pager
  • test_list_lake_actions_pager
  • test_list_lake_actions_async_pager
  • test_list_zones_pager
  • test_list_zones_async_pager
  • test_list_zone_actions_pager
  • test_list_zone_actions_async_pager
  • test_list_assets_pager
  • test_list_assets_async_pager
  • test_list_asset_actions_pager
  • test_list_asset_actions_async_pager
  • test_list_tasks_pager
  • test_list_tasks_async_pager
  • test_list_jobs_pager
  • test_list_jobs_async_pager
  • test_list_environments_pager
  • test_list_environments_async_pager
  • test_list_sessions_pager
  • test_list_sessions_async_pager

commit: 4e00aed
buildURL: Build Status, Sponge
status: failed

tests.unit.gapic.dataplex_v1.test_metadata_service: test_list_entities_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
transport_name = 'grpc'

def test_list_entities_pager(transport_name: str = "grpc"):
    client = MetadataServiceClient(
        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_entities), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                    metadata_.Entity(),
                    metadata_.Entity(),
                ],
                next_page_token="abc",
            ),
            metadata_.ListEntitiesResponse(
                entities=[],
                next_page_token="def",
            ),
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                ],
                next_page_token="ghi",
            ),
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                    metadata_.Entity(),
                ],
            ),
            RuntimeError,
        )

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

        assert pager._metadata == metadata

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





      assert all(isinstance(i, metadata_.Entity) for i in results)





E           assert False

E            +  where False = all(<generator object test_list_entities_pager.. at 0x7fed699e62e0>)


tests/unit/gapic/dataplex_v1/test_metadata_service.py:1894: AssertionError

tests.unit.gapic.dataplex_v1.test_metadata_service: test_list_partitions_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
transport_name = 'grpc'

def test_list_partitions_pager(transport_name: str = "grpc"):
    client = MetadataServiceClient(
        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_partitions), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                    metadata_.Partition(),
                    metadata_.Partition(),
                ],
                next_page_token="abc",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[],
                next_page_token="def",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                ],
                next_page_token="ghi",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                    metadata_.Partition(),
                ],
            ),
            RuntimeError,
        )

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

        assert pager._metadata == metadata

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





      assert all(isinstance(i, metadata_.Partition) for i in results)





E           assert False

E            +  where False = all(<generator object test_list_partitions_pager.. at 0x7f75febd0f50>)


tests/unit/gapic/dataplex_v1/test_metadata_service.py:3024: AssertionError

tests.unit.gapic.dataplex_v1.test_metadata_service: test_list_partitions_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
transport_name = 'grpc'

def test_list_partitions_pager(transport_name: str = "grpc"):
    client = MetadataServiceClient(
        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_partitions), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                    metadata_.Partition(),
                    metadata_.Partition(),
                ],
                next_page_token="abc",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[],
                next_page_token="def",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                ],
                next_page_token="ghi",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                    metadata_.Partition(),
                ],
            ),
            RuntimeError,
        )

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

        assert pager._metadata == metadata

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





      assert all(isinstance(i, metadata_.Partition) for i in results)





E           assert False

E            +  where False = all(<generator object test_list_partitions_pager.. at 0x7fed6a4e5a50>)


tests/unit/gapic/dataplex_v1/test_metadata_service.py:3024: AssertionError

tests.unit.gapic.dataplex_v1.test_metadata_service: test_list_entities_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
transport_name = 'grpc'

def test_list_entities_pager(transport_name: str = "grpc"):
    client = MetadataServiceClient(
        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_entities), "__call__") as call:
        # Set the response to a series of pages.
        call.side_effect = (
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                    metadata_.Entity(),
                    metadata_.Entity(),
                ],
                next_page_token="abc",
            ),
            metadata_.ListEntitiesResponse(
                entities=[],
                next_page_token="def",
            ),
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                ],
                next_page_token="ghi",
            ),
            metadata_.ListEntitiesResponse(
                entities=[
                    metadata_.Entity(),
                    metadata_.Entity(),
                ],
            ),
            RuntimeError,
        )

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

        assert pager._metadata == metadata

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





      assert all(isinstance(i, metadata_.Entity) for i in results)





E           assert False

E            +  where False = all(<generator object test_list_entities_pager.. at 0x7f75fecaf6d0>)


tests/unit/gapic/dataplex_v1/test_metadata_service.py:1894: AssertionError

tests.unit.gapic.dataplex_v1.test_dataplex_service: many tests failed

Many tests failed at the same time in this package.

  • I will close this issue when there are no more failures in this package and
    there is at least one pass.
  • No new issues will be filed for this package until this issue is closed.
  • If there are already issues for individual test cases, I will close them when
    the corresponding test passes. You can close them earlier, if you prefer, and
    I won't reopen them while this issue is still open.

Here are the tests that failed:

  • test_list_lakes_pager
  • test_list_lakes_async_pager
  • test_list_lake_actions_pager
  • test_list_lake_actions_async_pager
  • test_list_zones_pager
  • test_list_zones_async_pager
  • test_list_zone_actions_pager
  • test_list_zone_actions_async_pager
  • test_list_assets_pager
  • test_list_assets_async_pager
  • test_list_asset_actions_pager
  • test_list_asset_actions_async_pager
  • test_list_tasks_pager
  • test_list_tasks_async_pager
  • test_list_jobs_pager
  • test_list_jobs_async_pager
  • test_list_environments_pager
  • test_list_environments_async_pager
  • test_list_sessions_pager
  • test_list_sessions_async_pager

commit: 4e00aed
buildURL: Build Status, Sponge
status: failed

tests.unit.gapic.dataplex_v1.test_metadata_service: test_list_partitions_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: 4e00aed
buildURL: Build Status, Sponge
status: failed

Test output
@pytest.mark.asyncio
    async def test_list_partitions_async_pager():
        client = MetadataServiceAsyncClient(
            credentials=ga_credentials.AnonymousCredentials,
        )

    # Mock the actual call within the gRPC stub, and fake the request.
    with mock.patch.object(
        type(client.transport.list_partitions), "__call__", new_callable=mock.AsyncMock
    ) as call:
        # Set the response to a series of pages.
        call.side_effect = (
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                    metadata_.Partition(),
                    metadata_.Partition(),
                ],
                next_page_token="abc",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[],
                next_page_token="def",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                ],
                next_page_token="ghi",
            ),
            metadata_.ListPartitionsResponse(
                partitions=[
                    metadata_.Partition(),
                    metadata_.Partition(),
                ],
            ),
            RuntimeError,
        )
        async_pager = await client.list_partitions(
            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, metadata_.Partition) for i in responses)





E           assert False

E            +  where False = all(<generator object test_list_partitions_async_pager.. at 0x7fb4975cfe40>)


tests/unit/gapic/dataplex_v1/test_metadata_service.py:3115: AssertionError

tests.unit.gapic.dataplex_v1.test_dataplex_service: many tests failed

Many tests failed at the same time in this package.

  • I will close this issue when there are no more failures in this package and
    there is at least one pass.
  • No new issues will be filed for this package until this issue is closed.
  • If there are already issues for individual test cases, I will close them when
    the corresponding test passes. You can close them earlier, if you prefer, and
    I won't reopen them while this issue is still open.

Here are the tests that failed:

  • test_list_lakes_pager
  • test_list_lakes_async_pager
  • test_list_lake_actions_pager
  • test_list_lake_actions_async_pager
  • test_list_zones_pager
  • test_list_zones_async_pager
  • test_list_zone_actions_pager
  • test_list_zone_actions_async_pager
  • test_list_assets_pager
  • test_list_assets_async_pager
  • test_list_asset_actions_pager
  • test_list_asset_actions_async_pager
  • test_list_tasks_pager
  • test_list_tasks_async_pager
  • test_list_jobs_pager
  • test_list_jobs_async_pager
  • test_list_environments_pager
  • test_list_environments_async_pager
  • test_list_sessions_pager
  • test_list_sessions_async_pager

commit: 4e00aed
buildURL: Build Status, Sponge
status: failed

Recommend Projects

  • React photo React

    A declarative, efficient, and flexible JavaScript library for building user interfaces.

  • Vue.js photo Vue.js

    🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

  • Typescript photo Typescript

    TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

  • TensorFlow photo TensorFlow

    An Open Source Machine Learning Framework for Everyone

  • Django photo Django

    The Web framework for perfectionists with deadlines.

  • D3 photo D3

    Bring data to life with SVG, Canvas and HTML. 📊📈🎉

Recommend Topics

  • javascript

    JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

  • web

    Some thing interesting about web. New door for the world.

  • server

    A server is a program made to process requests and deliver data to clients.

  • Machine learning

    Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

  • Game

    Some thing interesting about game, make everyone happy.

Recommend Org

  • Facebook photo Facebook

    We are working to build community through open source technology. NB: members must have two-factor auth.

  • Microsoft photo Microsoft

    Open source projects and samples from Microsoft.

  • Google photo Google

    Google ❤️ Open Source for everyone.

  • D3 photo D3

    Data-Driven Documents codes.