Merge branch 'self-signed-jwt' of github.com:googleapis/gapic-generator-python into self-signed-jwt

Author: busunkim96

.github/workflows/pypi-upload.yaml

@@ -0,0 +1,25 @@
+name: Upload Python Package to PyPI
+
+on:
+  release:
+    types: [created]
+
+jobs:
+  publish:
+    runs-on: ubuntu-latest
+    environment: PyPI
+    steps:
+    - uses: actions/checkout@v2
+    - name: Set up Python
+      uses: actions/setup-python@v2
+      with:
+        python-version: '3.x'
+    - name: Install dependencies
+      run: python -m pip install twine wheel
+    - name: Package and upload modulee
+      env:
+        TWINE_USERNAME: ${{ secrets.PYPI_USERNAME }}
+        TWINE_PASSWORD: ${{ secrets.PYPI_PASSWORD }}
+      run: |
+        python setup.py sdist bdist_wheel
+        twine upload dist/*

CHANGELOG.md

@@ -1,5 +1,19 @@
 # Changelog
 
+### [0.40.12](https://www.github.com/googleapis/gapic-generator-python/compare/v0.40.11...v0.40.12) (2021-02-26)
+
+
+### Bug Fixes
+
+* exclude 'input' from reserved names list ([#788](https://www.github.com/googleapis/gapic-generator-python/issues/788)) ([da2ff71](https://www.github.com/googleapis/gapic-generator-python/commit/da2ff717b82357359baeeafad9a3e48a70e194cb))
+
+### [0.40.11](https://www.github.com/googleapis/gapic-generator-python/compare/v0.40.10...v0.40.11) (2021-02-24)
+
+
+### Bug Fixes
+
+* remove duplicate field entries ([#786](https://www.github.com/googleapis/gapic-generator-python/issues/786)) ([9f4dfa4](https://www.github.com/googleapis/gapic-generator-python/commit/9f4dfa46cb6a67081563ce096452fedd9e35051d))
+
 ### [0.40.10](https://www.github.com/googleapis/gapic-generator-python/compare/v0.40.9...v0.40.10) (2021-02-17)
 
 

gapic/templates/%namespace/%name_%version/%sub/services/%service/client.py.j2

@@ -365,7 +365,7 @@ class {{ service.client_name }}(metaclass={{ service.client_name }}Meta):
             request = {{ method.input.ident }}(**request)
         {% if method.flattened_fields -%}{# Cross-package req and flattened fields #}
         elif not request:
-            request = {{ method.input.ident }}({% if method.input.ident.package != method.ident.package %}{% for f in method.flattened_fields.values() %}{{ f.name }}={{ f.name }}, {% endfor %}{% endif %})
+            request = {{ method.input.ident }}()
         {% endif -%}{# Cross-package req and flattened fields #}
         {%- else %}
         # Minor optimization to avoid making a copy if the user passes

gapic/templates/tests/unit/gapic/%name_%version/%sub/test_%service.py.j2

@@ -498,6 +498,30 @@ def test_{{ method.name|snake_case }}_from_dict():
     test_{{ method.name|snake_case }}(request_type=dict)
 
 
+{% if not method.client_streaming -%}
+def test_{{ method.name|snake_case }}_empty_call():
+    # This test is a coverage failsafe to make sure that totally empty calls,
+    # i.e. request == None and no flattened fields passed, work.
+    client = {{ service.client_name }}(
+        credentials=credentials.AnonymousCredentials(),
+        transport='grpc',
+    )
+
+    # Mock the actual call within the gRPC stub, and fake the request.
+    with mock.patch.object(
+            type(client.transport.{{ method.name|snake_case }}),
+            '__call__') as call:
+        client.{{ method.name|snake_case }}()
+        call.assert_called()
+        _, args, _ = call.mock_calls[0]
+        {% if method.client_streaming %}
+        assert next(args[0]) == request
+        {% else %}
+        assert args[0] == {{ method.input.ident }}()
+        {% endif %}
+{% endif -%}
+
+
 @pytest.mark.asyncio
 async def test_{{ method.name|snake_case }}_async(transport: str = 'grpc_asyncio', request_type={{ method.input.ident }}):
     client = {{ service.async_client_name }}(
@@ -1303,7 +1327,7 @@ def test_{{ method.name|snake_case }}_pager():
         for result in results:
             assert isinstance(result, tuple)
             assert tuple(type(t) for t in result) == (str, {{ method.paged_result_field.type.fields.get('value').ident }})
-        
+
         assert pager.get('a') is None
         assert isinstance(pager.get('h'), {{ method.paged_result_field.type.fields.get('value').ident }})
         {% else %}
@@ -1315,7 +1339,7 @@ def test_{{ method.name|snake_case }}_pager():
         for page_, token in zip(pages, ['abc','def','ghi', '']):
             assert page_.raw_page.next_page_token == token
 
-        
+
 {% endif %} {# paged methods #}
 {% endfor -%} {#- method in methods for rest #}
 def test_credentials_transport_error():
@@ -1771,7 +1795,7 @@ def test_{{ service.name|snake_case }}_grpc_transport_client_cert_source_for_mtl
                 ("grpc.max_receive_message_length", -1),
             ],
         )
-        
+
     # Check if ssl_channel_credentials is not provided, then client_cert_source_for_mtls
     # is used.
     with mock.patch.object(transport_class, "create_channel", return_value=mock.Mock()):

gapic/utils/reserved_names.py

@@ -22,6 +22,6 @@
 RESERVED_NAMES = frozenset(
     itertools.chain(
         keyword.kwlist,
-        set(dir(builtins)) - {"filter", "map", "id", "property"},
+        set(dir(builtins)) - {"filter", "map", "id", "input", "property"},
     )
 )

requirements.txt

@@ -1,9 +1,9 @@
 click==7.1.2
 google-api-core==1.26.0
-googleapis-common-protos==1.52.0
+googleapis-common-protos==1.53.0
 jinja2==2.11.3
 MarkupSafe==1.1.1
-protobuf==3.15.0
+protobuf==3.15.3
 pypandoc==1.5
 PyYAML==5.4.1
 dataclasses==0.6  # TODO(busunkim) remove when 3.6 support is dropped