This is an automated email from the ASF dual-hosted git repository.
JingsongLi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new e644212609 [python] Run native commit tests only in the Rust Plan CI
job (#10139)
e644212609 is described below
commit e6442126099be5c2e4ad54dc3309b848e7ac9e3d
Author: jackylee <[email protected]>
AuthorDate: Thu Sep 24 10:43:15 2026 +0800
[python] Run native commit tests only in the Rust Plan CI job (#10139)
---
paimon-python/pypaimon/tests/native_commit_test.py | 13 +++++++++----
1 file changed, 9 insertions(+), 4 deletions(-)
diff --git a/paimon-python/pypaimon/tests/native_commit_test.py
b/paimon-python/pypaimon/tests/native_commit_test.py
index e4936ae447..8dcf130fd5 100644
--- a/paimon-python/pypaimon/tests/native_commit_test.py
+++ b/paimon-python/pypaimon/tests/native_commit_test.py
@@ -33,8 +33,13 @@ from pypaimon.write.native_commit import (
from pypaimon.write.table_write import StreamTableWrite
-requires_native = pytest.mark.skipif(
- not native_commit_available(), reason='pypaimon-rust runtime required')
+def requires_native(test):
+ # Native commit needs the from-source paimon-rust runtime built in the Rust
+ # Plan CI job; the PyPI pypaimon-rust wheel used by the standard test job
+ # predates the commit bridge. Route these like the other native_plan tests.
+ test = pytest.mark.native_plan(test)
+ return pytest.mark.skipif(
+ not native_commit_available(), reason='pypaimon-rust runtime
required')(test)
def _table(tmp_path, mode='append', backend='filesystem'):
@@ -223,7 +228,7 @@ def
test_native_overwrite_normalizes_python_boolean_option(tmp_path, value):
commit.close()
[email protected]('native', [False, True])
[email protected]('native', [False, pytest.param(True,
marks=pytest.mark.native_plan)])
@pytest.mark.parametrize('case', ['unpartitioned', 'static-empty',
'static-missing', 'dynamic-empty'])
def test_empty_overwrite_records_java_snapshot(tmp_path, native, case):
if native and not native_commit_available():
@@ -393,7 +398,7 @@ def
test_snapshot_properties_select_python_before_native(tmp_path, properties, o
commit.close()
[email protected]('warmup', [False, True])
[email protected]('warmup', [False, pytest.param(True,
marks=pytest.mark.native_plan)])
def test_callbacks_added_after_construction_select_python(tmp_path, warmup):
if warmup and not native_commit_available():
pytest.skip('native warmup requires the commit bindings')
