From 4f752b977822bf43e81eb6b71d35aa202ac670ed Mon Sep 17 00:00:00 2001 From: mahdikhashan Date: Fri, 29 Nov 2024 13:51:58 +0100 Subject: [PATCH 1/2] replace lakefs_client with lakefs-sdk --- test/spark/requirements.txt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/test/spark/requirements.txt b/test/spark/requirements.txt index acb3ea4b8f3..c863e4387ea 100644 --- a/test/spark/requirements.txt +++ b/test/spark/requirements.txt @@ -1,3 +1,3 @@ -lakefs_client==0.104.0 +lakefs-sdk==1.43.0 python-on-whales==0.62.0 tenacity==8.2.2 From ff99bb6d0edd7c2162307af4ed2faf767bf8aed7 Mon Sep 17 00:00:00 2001 From: mahdikhashan Date: Fri, 29 Nov 2024 14:50:44 +0100 Subject: [PATCH 2/2] use lakefs-sdk object and methods --- test/spark/run-test.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/test/spark/run-test.py b/test/spark/run-test.py index 00745731fe8..d5d41674258 100644 --- a/test/spark/run-test.py +++ b/test/spark/run-test.py @@ -1,9 +1,9 @@ import argparse import sys -import lakefs_client -from lakefs_client import models -from lakefs_client.client import LakeFSClient +import lakefs_sdk +from lakefs_sdk import models +from lakefs_sdk.client import LakeFSClient from python_on_whales import docker from tenacity import retry, stop_after_attempt, wait_fixed @@ -48,7 +48,7 @@ def main(): submit_flags = ["--jars", "/target/client.jar"] lfs_client = LakeFSClient( - lakefs_client.Configuration(username=lakefs_access_key, + lakefs_sdk.Configuration(username=lakefs_access_key, password=lakefs_secret_key, host='http://localhost:8000')) wait_for_setup(lfs_client)