feast-dev
diff --git a/‎sdk/python/feast/pyspark/launchers/aws/emr_utils.py‎
Lines changed: 1 addition & 3 deletions b/‎sdk/python/feast/pyspark/launchers/aws/emr_utils.py‎
Lines changed: 1 addition & 3 deletions
diff --git a/‎sdk/python/feast/pyspark/launchers/k8s/k8s.py‎
Lines changed: 5 additions & 1 deletion b/‎sdk/python/feast/pyspark/launchers/k8s/k8s.py‎
Lines changed: 5 additions & 1 deletion
@@ -86,9 +86,7 @@ def _upload_jar(jar_s3_prefix: str, jar_path: str) -> str:
     with open(jar_path, "rb") as f:
         uri = urlparse(os.path.join(jar_s3_prefix, os.path.basename(jar_path)))
         return urlunparse(
-            get_staging_client(uri.scheme).upload_fileobj(
-                f, jar_path, remote_uri=uri,
-            )
+            get_staging_client(uri.scheme).upload_fileobj(f, jar_path, remote_uri=uri)
         )
 
 
 
@@ -276,7 +276,11 @@ def historical_feature_retrieval(
         return cast(RetrievalJob, self._job_from_job_info(job_info))
 
     def _upload_jar(self, jar_path: str) -> str:
-        if jar_path.startswith("s3://") or jar_path.startswith("s3a://") or jar_path.startswith("https://"):
+        if (
+            jar_path.startswith("s3://")
+            or jar_path.startswith("s3a://")
+            or jar_path.startswith("https://")
+        ):
             return jar_path
         elif jar_path.startswith("file://"):
             local_jar_path = urlparse(jar_path).path
Original file line number	Diff line number	Diff line change
`@@ -86,9 +86,7 @@ def _upload_jar(jar_s3_prefix: str, jar_path: str) -> str:`
`86`	`86`	`with open(jar_path, "rb") as f:`
`87`	`87`	`uri = urlparse(os.path.join(jar_s3_prefix, os.path.basename(jar_path)))`
`88`	`88`	`return urlunparse(`
`89`		`- get_staging_client(uri.scheme).upload_fileobj(`
`90`		`- f, jar_path, remote_uri=uri,`
`91`		`- )`
	`89`	`+ get_staging_client(uri.scheme).upload_fileobj(f, jar_path, remote_uri=uri)`
`92`	`90`	`)`
`93`	`91`
`94`	`92`