René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"tests.system.test_session_api: test_transaction_execute_update_read_commit failed","articleBody":"This test failed!\n\nTo configure my behavior, see [the Flaky Bot documentation](https://github.com/googleapis/repo-automation-bots/tree/main/packages/flakybot).\n\nIf I'm commenting on this issue too often, add the `flakybot: quiet` label and\nI will stop commenting.\n\n---\n\ncommit: 5e50bebdd1d43994b3d83568641d1dff1c419cc8\nbuildURL: [Build Status](https://source.cloud.google.com/results/invocations/73294a29-7049-40a5-a55f-1f42dc96bfc3), [Sponge](http://sponge2/73294a29-7049-40a5-a55f-1f42dc96bfc3)\nstatus: failed\n\u003cdetails\u003e\u003csummary\u003eTest output\u003c/summary\u003e\u003cbr\u003e\u003cpre\u003eargs = (session: \"projects/precise-truck-742/instances/google-cloud-1674211009124/databases/test_sessions_1674211097465/sessi...contact_id\"\ncolumns: \"first_name\"\ncolumns: \"last_name\"\ncolumns: \"email\"\nkey_set {\n  all_: true\n}\nrequest_options {\n}\n,)\nkwargs = {'metadata': [('google-cloud-resource-prefix', 'projects/precise-truck-742/instances/google-cloud-1674211009124/databa...TFdAvqFDdXm6deA'), ('x-goog-api-client', 'gl-python/3.8.13 grpc/1.52.0rc1 gax/2.11.0 gccl/3.27.0')], 'timeout': 3600.0}\nresult = \u003c_MultiThreadedRendezvous of RPC that terminated with:\n\tstatus = StatusCode.ABORTED\n\tdetails = \"Transaction was aborte...95:443 {created_time:\"2023-01-20T10:38:55.191910351+00:00\", grpc_status:10, grpc_message:\"Transaction was aborted.\"}\"\n\u003e\nprefetch_first = True\n\n    @functools.wraps(callable_)\n    def error_remapped_callable(*args, **kwargs):\n        try:\n            result = callable_(*args, **kwargs)\n            # Auto-fetching the first result causes PubSub client's streaming pull\n            # to hang when re-opening the stream, thus we need examine the hacky\n            # hidden flag to see if pre-fetching is disabled.\n            # https://github.com/googleapis/python-pubsub/issues/93#issuecomment-630762257\n            prefetch_first = getattr(callable_, \"_prefetch_first_result_\", True)\n\u003e           return _StreamingResponseIterator(\n                result, prefetch_first_result=prefetch_first\n            )\n\n.nox/system-3-8-database_dialect-postgresql/lib/python3.8/site-packages/google/api_core/grpc_helpers.py:162: \n_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ \n\nself = \u003cgoogle.api_core.grpc_helpers._StreamingResponseIterator object at 0x7f87cb73e7f0\u003e\nwrapped = \u003c_MultiThreadedRendezvous of RPC that terminated with:\n\tstatus = StatusCode.ABORTED\n\tdetails = \"Transaction was aborte...95:443 {created_time:\"2023-01-20T10:38:55.191910351+00:00\", grpc_status:10, grpc_message:\"Transaction was aborted.\"}\"\n\u003e\nprefetch_first_result = True\n\n    def __init__(self, wrapped, prefetch_first_result=True):\n        self._wrapped = wrapped\n    \n        # This iterator is used in a retry context, and returned outside after init.\n        # gRPC will not throw an exception until the stream is consumed, so we need\n        # to retrieve the first result, in order to fail, in order to trigger a retry.\n        try:\n            if prefetch_first_result:\n\u003e               self._stored_first_result = next(self._wrapped)\n\n.nox/system-3-8-database_dialect-postgresql/lib/python3.8/site-packages/google/api_core/grpc_helpers.py:88: \n_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ \n\nself = \u003c_MultiThreadedRendezvous of RPC that terminated with:\n\tstatus = StatusCode.ABORTED\n\tdetails = \"Transaction was aborte...95:443 {created_time:\"2023-01-20T10:38:55.191910351+00:00\", grpc_status:10, grpc_message:\"Transaction was aborted.\"}\"\n\u003e\n\n    def __next__(self):\n\u003e       return self._next()\n\n.nox/system-3-8-database_dialect-postgresql/lib/python3.8/site-packages/grpc/_channel.py:475: \n_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ \n\nself = \u003c_MultiThreadedRendezvous of RPC that terminated with:\n\tstatus = StatusCode.ABORTED\n\tdetails = \"Transaction was aborte...95:443 {created_time:\"2023-01-20T10:38:55.191910351+00:00\", grpc_status:10, grpc_message:\"Transaction was aborted.\"}\"\n\u003e\n\n    def _next(self) -\u003e Any:\n        with self._state.condition:\n            if self._state.code is None:\n                event_handler = _event_handler(self._state,\n                                               self._response_deserializer)\n                self._state.due.add(cygrpc.OperationType.receive_message)\n                operating = self._call.operate(\n                    (cygrpc.ReceiveMessageOperation(_EMPTY_FLAGS),),\n                    event_handler)\n                if not operating:\n                    self._state.due.remove(cygrpc.OperationType.receive_message)\n            elif self._state.code is grpc.StatusCode.OK:\n                raise StopIteration()\n            else:\n                raise self\n    \n            def _response_ready():\n                return (self._state.response is not None or\n                        (cygrpc.OperationType.receive_message\n                         not in self._state.due and\n                         self._state.code is not None))\n    \n            _common.wait(self._state.condition.wait, _response_ready)\n            if self._state.response is not None:\n                response = self._state.response\n                self._state.response = None\n                return response\n            elif cygrpc.OperationType.receive_message not in self._state.due:\n                if self._state.code is grpc.StatusCode.OK:\n                    raise StopIteration()\n                elif self._state.code is not None:\n\u003e                   raise self\nE                   grpc._channel._MultiThreadedRendezvous: \u003c_MultiThreadedRendezvous of RPC that terminated with:\nE                   \tstatus = StatusCode.ABORTED\nE                   \tdetails = \"Transaction was aborted.\"\nE                   \tdebug_error_string = \"UNKNOWN:Error received from peer ipv4:74.125.142.95:443 {created_time:\"2023-01-20T10:38:55.191910351+00:00\", grpc_status:10, grpc_message:\"Transaction was aborted.\"}\"\nE                   \u003e\n\n.nox/system-3-8-database_dialect-postgresql/lib/python3.8/site-packages/grpc/_channel.py:881: _MultiThreadedRendezvous\n\nThe above exception was the direct cause of the following exception:\n\nsessions_database = \u003cgoogle.cloud.spanner_v1.database.Database object at 0x7f87f0071df0\u003e\nsessions_to_delete = [\u003cgoogle.cloud.spanner_v1.session.Session object at 0x7f87cb736850\u003e]\n\n    @_helpers.retry_mabye_conflict\n    def test_transaction_execute_update_read_commit(sessions_database, sessions_to_delete):\n        # [START spanner_test_dml_read_your_writes]\n        sd = _sample_data\n    \n        session = sessions_database.session()\n        session.create()\n        sessions_to_delete.append(session)\n    \n        with session.batch() as batch:\n            batch.delete(sd.TABLE, sd.ALL)\n    \n        with session.transaction() as transaction:\n            rows = list(transaction.read(sd.TABLE, sd.COLUMNS, sd.ALL))\n            assert rows == []\n    \n            for insert_statement in _generate_insert_statements():\n                row_count = transaction.execute_update(insert_statement)\n                assert row_count == 1\n    \n            # Rows inserted via DML *can* be read before commit.\n\u003e           during_rows = list(transaction.read(sd.TABLE, sd.COLUMNS, sd.ALL))\n\ntests/system/test_session_api.py:746: \n_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ \ngoogle/cloud/spanner_v1/streamed.py:145: in __iter__\n    self._consume_next()\ngoogle/cloud/spanner_v1/streamed.py:117: in _consume_next\n    response = next(self._response_iterator)\ngoogle/cloud/spanner_v1/snapshot.py:83: in _restart_on_unavailable\n    iterator = method(request=request)\ngoogle/cloud/spanner_v1/services/spanner/client.py:1529: in streaming_read\n    response = rpc(\n.nox/system-3-8-database_dialect-postgresql/lib/python3.8/site-packages/google/api_core/gapic_v1/method.py:113: in __call__\n    return wrapped_func(*args, **kwargs)\n.nox/system-3-8-database_dialect-postgresql/lib/python3.8/site-packages/google/api_core/timeout.py:120: in func_with_timeout\n    return func(*args, **kwargs)\n_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ \n\nargs = (session: \"projects/precise-truck-742/instances/google-cloud-1674211009124/databases/test_sessions_1674211097465/sessi...contact_id\"\ncolumns: \"first_name\"\ncolumns: \"last_name\"\ncolumns: \"email\"\nkey_set {\n  all_: true\n}\nrequest_options {\n}\n,)\nkwargs = {'metadata': [('google-cloud-resource-prefix', 'projects/precise-truck-742/instances/google-cloud-1674211009124/databa...TFdAvqFDdXm6deA'), ('x-goog-api-client', 'gl-python/3.8.13 grpc/1.52.0rc1 gax/2.11.0 gccl/3.27.0')], 'timeout': 3600.0}\nresult = \u003c_MultiThreadedRendezvous of RPC that terminated with:\n\tstatus = StatusCode.ABORTED\n\tdetails = \"Transaction was aborte...95:443 {created_time:\"2023-01-20T10:38:55.191910351+00:00\", grpc_status:10, grpc_message:\"Transaction was aborted.\"}\"\n\u003e\nprefetch_first = True\n\n    @functools.wraps(callable_)\n    def error_remapped_callable(*args, **kwargs):\n        try:\n            result = callable_(*args, **kwargs)\n            # Auto-fetching the first result causes PubSub client's streaming pull\n            # to hang when re-opening the stream, thus we need examine the hacky\n            # hidden flag to see if pre-fetching is disabled.\n            # https://github.com/googleapis/python-pubsub/issues/93#issuecomment-630762257\n            prefetch_first = getattr(callable_, \"_prefetch_first_result_\", True)\n            return _StreamingResponseIterator(\n                result, prefetch_first_result=prefetch_first\n            )\n        except grpc.RpcError as exc:\n\u003e           raise exceptions.from_grpc_error(exc) from exc\nE           google.api_core.exceptions.Aborted: 409 Transaction was aborted. [retry_delay {\nE             nanos: 10179537\nE           }\nE           ]\n\n.nox/system-3-8-database_dialect-postgresql/lib/python3.8/site-packages/google/api_core/grpc_helpers.py:166: Aborted\u003c/pre\u003e\u003c/details\u003e","author":{"url":"https://github.com/flaky-bot[bot]","@type":"Person","name":"flaky-bot[bot]"},"datePublished":"2023-01-20T10:41:10.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":1},"url":"https://github.com/887/python-spanner/issues/887"}