webhdfs: introduce additional temp variable

gdiepen · gdiepen · commit 1506cdc7858d · 2023-11-08T20:29:34.000+01:00
diff --git a/dvc_webhdfs/__init__.py b/dvc_webhdfs/__init__.py
@@ -56,8 +56,9 @@ def fs(self):
 
             protocol = "https" if self.fs_args.get("use_https") else "http"
 
+            source_url = f"{protocol}://{host}:{port}/webhdfs/v1"
             self.fs_args["data_proxy"] = {
-                f"{protocol}://{host}:{port}/webhdfs/v1":self.fs_args["data_proxy_target"]
+                source_url: self.fs_args["data_proxy_target"]
             }
 
         fs = WebHDFS(**self.fs_args)

Original file line number	Diff line number	Diff line change
`@@ -56,8 +56,9 @@ def fs(self):`
`56`	`56`
`57`	`57`	`protocol = "https" if self.fs_args.get("use_https") else "http"`
`58`	`58`
	`59`	`+ source_url = f"{protocol}://{host}:{port}/webhdfs/v1"`
`59`	`60`	`self.fs_args["data_proxy"] = {`
`60`		`- f"{protocol}://{host}:{port}/webhdfs/v1":self.fs_args["data_proxy_target"]`
	`61`	`+ source_url: self.fs_args["data_proxy_target"]`
`61`	`62`	`}`
`62`	`63`
`63`	`64`	`fs = WebHDFS(**self.fs_args)`