Oct 26, 2021 · Oct 25, 2021 · Oct 26, 2021
diff --git a/google/api_core/operation.py b/google/api_core/operation.py
                )
                self.set_exception(exception)
            else:
 # Some APIs set `done: true`, with an empty response.
 # Set the result to an empty message of the expected
 # result type.
 # https://google.aip.dev/151
                self.set_result(self._result_type())
 exception = exceptions.GoogleAPICallError(
    "Unexpected state: Long-running operation had neither "
    "response nor error set."
 )
                self.set_exception(exception)

    def _refresh_and_update(self, retry=polling.DEFAULT_RETRY):
        """Refresh the operation and update the result if needed.
diff --git a/google/api_core/operation_async.py b/google/api_core/operation_async.py
                )
                self.set_exception(exception)
            else:
 # Some APIs set `done: true`, with an empty response.
 # Set the result to an empty message of the expected
 # result type.
 # https://google.aip.dev/151
                self.set_result(self._result_type())
 exception = exceptions.GoogleAPICallError(
    "Unexpected state: Long-running operation had neither "
    "response nor error set."
 )
                self.set_exception(exception)

    async def _refresh_and_update(self, retry=async_future.DEFAULT_RETRY):
        """Refresh the operation and update the result if needed.
diff --git a/tests/asyncio/test_operation_async.py b/tests/asyncio/test_operation_async.py

 @mock.patch("asyncio.sleep", autospec=True)
 @pytest.mark.asyncio
 async deftest_done_with_no_error_or_response(unused_sleep):
 async deftest_unexpected_result(unused_sleep):
    responses = [
        make_operation_proto(),
        # Second operation response is done, but has not error or response.
        make_operation_proto(done=True),
    ]
    future, _, _ = make_operation_future(responses)

 result = await future.result()
 exception = await future.exception()

    assertisinstance(result, struct_pb2.Struct)
    assert"Unexpected state" in "{!r}".format(exception)


 def test_from_gapic():
diff --git a/tests/unit/test_operation.py b/tests/unit/test_operation.py
    assert isinstance(exception, exceptions.NotFound)


 deftest_done_with_no_error_or_response():
 deftest_unexpected_result():
    responses = [
        make_operation_proto(),
        # Second operation response is done, but has not error or response.
        make_operation_proto(done=True),
    ]
    future, _, _ = make_operation_future(responses)

    assert isinstance(future.result(), struct_pb2.Struct)
    exception = future.exception()

    assert "Unexpected state" in "{!r}".format(exception)


 def test__refresh_http():
Original file line number	Diff line number	Diff line change
Expand Up		@@ -140,11 +140,11 @@ def _set_result_from_operation(self):
		)
		self.set_exception(exception)
		else:
		# Some APIs set `done: true`, with an empty response.
		# Set the result to an empty message of the expected
		# result type.
		# https://google.aip.dev/151
		self.set_result(self._result_type())
		exception = exceptions.GoogleAPICallError(
		"Unexpected state: Long-running operation had neither "
		"response nor error set."
		)
		self.set_exception(exception)

		def _refresh_and_update(self, retry=polling.DEFAULT_RETRY):
		"""Refresh the operation and update the result if needed.
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -136,11 +136,11 @@ def _set_result_from_operation(self):
		)
		self.set_exception(exception)
		else:
		# Some APIs set `done: true`, with an empty response.
		# Set the result to an empty message of the expected
		# result type.
		# https://google.aip.dev/151
		self.set_result(self._result_type())
		exception = exceptions.GoogleAPICallError(
		"Unexpected state: Long-running operation had neither "
		"response nor error set."
		)
		self.set_exception(exception)

		async def _refresh_and_update(self, retry=async_future.DEFAULT_RETRY):
		"""Refresh the operation and update the result if needed.
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -158,17 +158,17 @@ async def test_exception():

		@mock.patch("asyncio.sleep", autospec=True)
		@pytest.mark.asyncio
		async deftest_done_with_no_error_or_response(unused_sleep):
		async deftest_unexpected_result(unused_sleep):
		responses = [
		make_operation_proto(),
		# Second operation response is done, but has not error or response.
		make_operation_proto(done=True),
		]
		future, _, _ = make_operation_future(responses)

		result = await future.result()
		exception = await future.exception()

		assertisinstance(result, struct_pb2.Struct)
		assert"Unexpected state" in "{!r}".format(exception)


		def test_from_gapic():
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -169,15 +169,17 @@ def test_exception_with_error_code():
		assert isinstance(exception, exceptions.NotFound)


		deftest_done_with_no_error_or_response():
		deftest_unexpected_result():
		responses = [
		make_operation_proto(),
		# Second operation response is done, but has not error or response.
		make_operation_proto(done=True),
		]
		future, _, _ = make_operation_future(responses)

		assert isinstance(future.result(), struct_pb2.Struct)
		exception = future.exception()

		assert "Unexpected state" in "{!r}".format(exception)


		def test__refresh_http():
Expand Down