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":"Note: #959 was also for this test, but it was closed more than 10 days ago. So, I didn't mark it flaky.\n\n----\n\ncommit: 5d91a2874e056d73b32526c40fdbc942d602efc5\nbuildURL: [Build Status](https://source.cloud.google.com/results/invocations/53165163-edb8-4e57-b33e-d670fefdc264), [Sponge](http://sponge2/53165163-edb8-4e57-b33e-d670fefdc264)\nstatus: failed\n\u003cdetails\u003e\u003csummary\u003eTest output\u003c/summary\u003e\u003cbr\u003e\u003cpre\u003eargs = (session: \"projects/precise-truck-742/instances/google-cloud-1691643863048/databases/test_sessions_1691644077777/sessi...8ExdWveZCKww9sP6K59fGQqV_Q\"\ntransaction_id: \"AH67Lq5fE94ayY0EETbrFr0sAVy6J6VsWYfcjRCxzHTapE2RTA\"\nrequest_options {\n}\n,)\nkwargs = {'metadata': [('google-cloud-resource-prefix', 'projects/precise-truck-742/instances/google-cloud-1691643863048/databa...K59fGQqV_Q'), ('x-goog-api-client', 'gl-python/3.8.13 grpc/1.57.0rc1 gax/2.12.0.dev0 gccl/3.40.0')], 'timeout': 3600.0}\n\n    @functools.wraps(callable_)\n    def error_remapped_callable(*args, **kwargs):\n        try:\n\u003e           return callable_(*args, **kwargs)\n\n.nox/prerelease_deps-3-8-database_dialect-postgresql/lib/python3.8/site-packages/google/api_core/grpc_helpers.py:72: \n_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ \n.nox/prerelease_deps-3-8-database_dialect-postgresql/lib/python3.8/site-packages/grpc/_channel.py:1161: in __call__\n    return _end_unary_response_blocking(state, call, False, None)\n_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ \n\nstate = \u003cgrpc._channel._RPCState object at 0x7f4a877b76a0\u003e\ncall = \u003cgrpc._cython.cygrpc.SegregatedCall object at 0x7f4a877b9500\u003e\nwith_call = False, deadline = None\n\n    def _end_unary_response_blocking(\n        state: _RPCState,\n        call: cygrpc.SegregatedCall,\n        with_call: bool,\n        deadline: Optional[float],\n    ) -\u003e Union[ResponseType, Tuple[ResponseType, grpc.Call]]:\n        if state.code is grpc.StatusCode.OK:\n            if with_call:\n                rendezvous = _MultiThreadedRendezvous(state, call, None, deadline)\n                return state.response, rendezvous\n            else:\n                return state.response\n        else:\n\u003e           raise _InactiveRpcError(state)  # pytype: disable=not-instantiable\nE           grpc._channel._InactiveRpcError: \u003c_InactiveRpcError 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.197.95:443 {grpc_message:\"Transaction was aborted.\", grpc_status:10, created_time:\"2023-08-10T05:08:35.45655307+00:00\"}\"\nE           \u003e\n\n.nox/prerelease_deps-3-8-database_dialect-postgresql/lib/python3.8/site-packages/grpc/_channel.py:1004: _InactiveRpcError\n\nThe above exception was the direct cause of the following exception:\n\nsessions_database = \u003cgoogle.cloud.spanner_v1.database.Database object at 0x7f4a877dcc70\u003e\nsessions_to_delete = [\u003cgoogle.cloud.spanner_v1.session.Session object at 0x7f4a877ae640\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            during_rows = list(transaction.read(sd.TABLE, sd.COLUMNS, sd.ALL))\n\u003e           sd._check_rows_data(during_rows)\n\ntests/system/test_session_api.py:747: \n_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ \ngoogle/cloud/spanner_v1/transaction.py:528: in __exit__\n    self.commit()\ngoogle/cloud/spanner_v1/transaction.py:239: in commit\n    response = _retry(\ngoogle/cloud/spanner_v1/_helpers.py:334: in _retry\n    raise exc\ngoogle/cloud/spanner_v1/_helpers.py:320: in _retry\n    return func()\ngoogle/cloud/spanner_v1/services/spanner/client.py:1805: in commit\n    response = rpc(\n.nox/prerelease_deps-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/prerelease_deps-3-8-database_dialect-postgresql/lib/python3.8/site-packages/google/api_core/retry.py:365: in retry_wrapped_func\n    return retry_func(\n.nox/prerelease_deps-3-8-database_dialect-postgresql/lib/python3.8/site-packages/google/api_core/retry.py:192: in retry_target\n    return target()\n.nox/prerelease_deps-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-1691643863048/databases/test_sessions_1691644077777/sessi...8ExdWveZCKww9sP6K59fGQqV_Q\"\ntransaction_id: \"AH67Lq5fE94ayY0EETbrFr0sAVy6J6VsWYfcjRCxzHTapE2RTA\"\nrequest_options {\n}\n,)\nkwargs = {'metadata': [('google-cloud-resource-prefix', 'projects/precise-truck-742/instances/google-cloud-1691643863048/databa...K59fGQqV_Q'), ('x-goog-api-client', 'gl-python/3.8.13 grpc/1.57.0rc1 gax/2.12.0.dev0 gccl/3.40.0')], 'timeout': 3600.0}\n\n    @functools.wraps(callable_)\n    def error_remapped_callable(*args, **kwargs):\n        try:\n            return callable_(*args, **kwargs)\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: 27868319\nE           }\nE           ]\n\n.nox/prerelease_deps-3-8-database_dialect-postgresql/lib/python3.8/site-packages/google/api_core/grpc_helpers.py:74: Aborted\u003c/pre\u003e\u003c/details\u003e","author":{"url":"https://github.com/flaky-bot[bot]","@type":"Person","name":"flaky-bot[bot]"},"datePublished":"2023-08-10T05:09:44.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":1},"url":"https://github.com/999/python-spanner/issues/999"}