Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[PBM-1187] Add --wait option to pbm config --force-resync #883

Merged
merged 1 commit into from
Oct 15, 2023

[PBM-1187] add --wait option to pbm config --force-resync

61422f9
Select commit
Loading
Failed to load commit list.
Sign in for the full log view
Merged

[PBM-1187] Add --wait option to pbm config --force-resync #883

[PBM-1187] add --wait option to pbm config --force-resync
61422f9
Select commit
Loading
Failed to load commit list.
This check has been archived and is scheduled for deletion. Learn more about checks retention
GitHub Actions / JUnit Test Report failed Oct 5, 2023 in 0s

13 tests run, 12 passed, 0 skipped, 1 failed.

Annotations

Check failure on line 89 in psmdb-testing/pbm-functional/pytest/test_upgrade.py

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

test_upgrade.test_incremental

Failed: Timeout >300.0s
Raw output
start_cluster = True, cluster = <cluster.Cluster object at 0x7fbd107e3650>

    @pytest.mark.timeout(300,func_only=True)
    def test_incremental(start_cluster,cluster):
        cluster.check_pbm_status()
        cluster.make_backup("incremental --base")
        pymongo.MongoClient(cluster.connection)["test"]["test"].insert_many(documents)
        backup = cluster.make_backup("incremental")
        result=pymongo.MongoClient(cluster.connection)["test"]["test"].delete_many({})
        assert int(result.deleted_count) == len(documents)
        cluster.upgrade()
        cluster.check_pbm_status()
        try:
            cluster.make_restore(backup,restart_cluster=True, check_pbm_status=True)
>           assert pymongo.MongoClient(cluster.connection)["test"]["test"].count_documents({}) == len(documents)

test_upgrade.py:89: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
/usr/lib/python3.11/site-packages/pymongo/collection.py:1915: in count_documents
    return self._retryable_non_cursor_read(_cmd, session)
/usr/lib/python3.11/site-packages/pymongo/collection.py:1925: in _retryable_non_cursor_read
    return client._retryable_read(func, self._read_preference_for(s), s)
/usr/lib/python3.11/site-packages/pymongo/_csot.py:108: in csot_wrapper
    return func(self, *args, **kwargs)
/usr/lib/python3.11/site-packages/pymongo/mongo_client.py:1535: in _retryable_read
    return func(session, server, conn, read_pref)
/usr/lib/python3.11/site-packages/pymongo/collection.py:1910: in _cmd
    result = self._aggregate_one_result(conn, read_preference, cmd, collation, session)
/usr/lib/python3.11/site-packages/pymongo/collection.py:1766: in _aggregate_one_result
    result = self._command(
/usr/lib/python3.11/site-packages/pymongo/collection.py:310: in _command
    return conn.command(
/usr/lib/python3.11/site-packages/pymongo/helpers.py:315: in inner
    return func(*args, **kwargs)
/usr/lib/python3.11/site-packages/pymongo/pool.py:960: in command
    self._raise_connection_failure(error)
/usr/lib/python3.11/site-packages/pymongo/pool.py:932: in command
    return command(
/usr/lib/python3.11/site-packages/pymongo/network.py:181: in command
    reply = receive_message(conn, request_id)
/usr/lib/python3.11/site-packages/pymongo/network.py:247: in receive_message
    length, _, response_to, op_code = _UNPACK_HEADER(_receive_data_on_socket(conn, 16, deadline))
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

conn = Connection(<socket.socket [closed] fd=-1, family=2, type=1, proto=6>) CLOSED at 140450002673424
length = 16, deadline = None

    def _receive_data_on_socket(conn: Connection, length: int, deadline: Optional[float]) -> memoryview:
        buf = bytearray(length)
        mv = memoryview(buf)
        bytes_read = 0
        while bytes_read < length:
            try:
                wait_for_read(conn, deadline)
                # CSOT: Update timeout. When the timeout has expired perform one
                # final non-blocking recv. This helps avoid spurious timeouts when
                # the response is actually already buffered on the client.
                if _csot.get_timeout() and deadline is not None:
                    conn.set_conn_timeout(max(deadline - time.monotonic(), 0))
>               chunk_length = conn.conn.recv_into(mv[bytes_read:])
E               Failed: Timeout >300.0s

/usr/lib/python3.11/site-packages/pymongo/network.py:328: Failed