chore(spark): add SparkClient API delegation coverage - #658
Conversation
|
[APPROVALNOTIFIER] This PR is NOT APPROVED This pull-request has been approved by: The full list of commands accepted by this bot can be found here. DetailsNeeds approval from an approver in each of these files:Approvers can indicate their approval by writing |
|
🎉 Welcome to the Kubeflow SDK! 🎉 Thanks for opening your first PR! We're happy to have you as part of our community 🚀 Here's what happens next:
Join the community:
Feel free to ask questions in the comments if you need any help or clarification! |
4c14d46 to
3c24d48
Compare
Signed-off-by: Loi Nguyen <1948922+lntutor@users.noreply.github.com>
3c24d48 to
f5d9337
Compare
|
Current head |
Summary
SparkClient.connect()against existing Spark Connect servers, including URL validation and token propagationdelete_session()returningNoneandget_session_logs()forwardingfollowby keywordPart of #609. This is intentionally limited to the Spark API layer; it does not overlap with #610, #614, or #621.
Validation
uv run pytest -q kubeflow/spark/api/spark_client_test.py— 15 passeduv run ruff check kubeflow/spark/api/spark_client_test.pyuv run ruff format --check kubeflow/spark/api/spark_client_test.pymake verifyI also ran
make test-python; it entered the unrelated Trainer container-backend test section and did not complete locally, so I stopped that single runner rather than leave it consuming resources. The focused Spark suite is clean and CI will run the repository gate.