From 826246862138738ab2521ebcdf13102b3b02ae25 Mon Sep 17 00:00:00 2001 From: Lynn Rozen Date: Tue, 7 Nov 2023 16:24:15 +0200 Subject: [PATCH] cr changes --- test/conftest.py | 5 ++--- test/test_iceberg.py | 2 +- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/test/conftest.py b/test/conftest.py index da9e383..2f7ab59 100644 --- a/test/conftest.py +++ b/test/conftest.py @@ -1,7 +1,6 @@ import pyspark from pyspark.sql import SparkSession from pyspark.conf import SparkConf - import pytest import lakefs_sdk @@ -57,8 +56,8 @@ def lfs_client(pytestconfig): repo_name = pytestconfig.getoption('--repository') storage_namespace = pytestconfig.getoption('--storage_namespace') lfs_client.internal_api.setup_comm_prefs(CommPrefsInput(feature_updates=False, security_updates=False, email=MOCK_EMAIL)) - lfs_client.internal_api.setup(Setup(username="lynn", + lfs_client.internal_api.setup(Setup(username="admin", key=AccessKeyCredentials(access_key_id=LAKEFS_ACCESS_KEY, secret_access_key=LAKEFS_SECRET_KEY))) lfs_client.repositories_api.create_repository( RepositoryCreation(name=repo_name, storage_namespace=storage_namespace)) - return lfs_client \ No newline at end of file + return lfs_client diff --git a/test/test_iceberg.py b/test/test_iceberg.py index b52a952..ad12e5a 100644 --- a/test/test_iceberg.py +++ b/test/test_iceberg.py @@ -56,4 +56,4 @@ def test_multiple_changes_and_merge(spark, lfs_client: lakefs_sdk.client.LakeFSC lfs_client.refs_api.merge_into_branch(lakefs_repo, "test4", "test3") df_source = spark.read.table("lakefs.test3.company.workers") df_dest = spark.read.table("lakefs.test4.company.workers") - assert (df_source.schema == df_dest.schema) and (set(df_source.collect()) == set(df_dest.collect())), "test3 and test4 tables should be equal" \ No newline at end of file + assert (df_source.schema == df_dest.schema) and (set(df_source.collect()) == set(df_dest.collect())), "test3 and test4 tables should be equal"