Antalya 26.1 - tests test_storage_iceberg_with_spark/test_async_metadata_refresh.py are unstable

[ianton-ru]

Sometimes tests

test_storage_iceberg_with_spark/test_async_metadata_refresh.py::test_selecting_with_stale_vs_latest_metadata[s3]
test_storage_iceberg_with_spark/test_async_metadata_refresh.py::test_default_async_metadata_refresh[s3]
test_storage_iceberg_with_spark/test_async_metadata_refresh.py::test_async_metadata_refresh[s3]

failed with

  FAIL [test_storage_iceberg_with_spark/test_async_metadata_refresh.py::test_selecting_with_stale_vs_latest_metadata[s3]]
    | File: test_storage_iceberg_with_spark/test_async_metadata_refresh.py:61 - in test_selecting_with_stale_vs_latest_metadata
    |     assert int(instance.query(f"SELECT count() FROM {TABLE_NAME}", settings={
    | E   AssertionError: assert 200 == 100
    | E    +  where 200 = int('200\n')
    | E    +    where '200\n' = query('SELECT count() FROM test_selecting_with_stale_vs_latest_metadata_s3_07f77f61_b65f_462f_afd6_1473ff9b06c0', settings={'iceberg_metadata_staleness_ms': 600000, 'log_comment': 'test_selecting_with_stale_vs_latest_metadata_s3_07f77f61_b65f_462f_afd6_1473ff9b06c0_01'})
    | E    +      where query = <helpers.cluster.ClickHouseInstance object at 0x737fcee06680>.query
  FAIL [test_storage_iceberg_with_spark/test_async_metadata_refresh.py::test_default_async_metadata_refresh[s3]]
    | File: test_storage_iceberg_with_spark/test_async_metadata_refresh.py:219 - in test_default_async_metadata_refresh
    |     assert int(instance.query(f"SELECT count() FROM {TABLE_NAME} SETTINGS iceberg_metadata_staleness_ms=600000")) == 100
    | E   AssertionError: assert 200 == 100
    | E    +  where 200 = int('200\n')
    | E    +    where '200\n' = query('SELECT count() FROM test_default_async_metadata_refresh_s3_88c17387_0e4a_44b5_97f0_603474aa1c30 SETTINGS iceberg_metadata_staleness_ms=600000')
    | E    +      where query = <helpers.cluster.ClickHouseInstance object at 0x737fcee06680>.query
  FAIL [test_storage_iceberg_with_spark/test_async_metadata_refresh.py::test_async_metadata_refresh[s3]]
    | File: test_storage_iceberg_with_spark/test_async_metadata_refresh.py:276 - in test_async_metadata_refresh
    |     assert int(instance.query(f"SELECT count() FROM {TABLE_NAME} SETTINGS iceberg_metadata_staleness_ms=600000")) == 100
    | E   AssertionError: assert 200 == 100
    | E    +  where 200 = int('200\n')
    | E    +    where '200\n' = query('SELECT count() FROM test_async_metadata_refresh_s3_903a4610_fd1d_4340_a4b5_ed304069a160 SETTINGS iceberg_metadata_staleness_ms=600000')
    | E    +      where query = <helpers.cluster.ClickHouseInstance object at 0x737fcee06680>.query

Checked on commit 9ab63c5926c70ee0b0fd3b5415a172c75cb0b96d