drop YT user parameters from python APIs

ytsaurus · Oct 15, 2024 · 7ea4686 · 7ea4686
1 parent e8f8b8c
commit 7ea4686
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/e2e-test/common/cluster.py b/e2e-test/common/cluster.py
@@ -102,7 +102,7 @@ def __exit__(self, exc_type, exc_val, exc_tb):
     @contextmanager
     def submission_client(self):
         with java_gateway(java_home=self.java_home) as gw:
-            yield SparkSubmissionClient(gw, self.proxy, self.discovery_path, self.user, self.token)
+            yield SparkSubmissionClient(gw, self.proxy, self.discovery_path, self.token)
 
     def submit_cluster_job(self, job_path, conf={}, args=[], py_files=[]):
         with self.submission_client() as client:

diff --git a/python-examples/yamake_sample/main.py b/python-examples/yamake_sample/main.py
@@ -12,7 +12,7 @@ def run_job(proxy, discovery_path):
         logging.info("Gateway created")
 
         submission_client = submit.SparkSubmissionClient(gateway, proxy, discovery_path,
-                                                         utils.default_user(), utils.default_token())
+                                                         utils.default_token())
         logging.info("Submission client created")
 
         launcher = submission_client.new_launcher()

diff --git a/spyt-package/src/main/python/spyt/submit.py b/spyt-package/src/main/python/spyt/submit.py
@@ -148,8 +148,8 @@ def __new__(cls, *args, **kwargs):
         instance = super(SparkSubmissionClient, cls).__new__(cls)
         return instance
 
-    def __init__(self, gateway, proxy, discovery_path, user, token):
-        self._jclient = gateway.jvm.tech.ytsaurus.spyt.submit.SubmissionClient(proxy, discovery_path, user, token)
+    def __init__(self, gateway, proxy, discovery_path, token):
+        self._jclient = gateway.jvm.tech.ytsaurus.spyt.submit.SubmissionClient(proxy, discovery_path, token)
         self.gateway = gateway
 
     def new_launcher(self):