From 2fb8785453dd61be19849835dd2190695ff664e3 Mon Sep 17 00:00:00 2001 From: Kyle Harrington Date: Thu, 6 Mar 2025 21:13:55 -0500 Subject: [PATCH 1/3] Fix typo --- fsspec/implementations/http.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fsspec/implementations/http.py b/fsspec/implementations/http.py index 9699523cf..7386d4b80 100644 --- a/fsspec/implementations/http.py +++ b/fsspec/implementations/http.py @@ -541,7 +541,7 @@ async def _pipe_file(self, path, value, mode="overwrite", **kwargs): headers = kwargs.pop("headers", {}) headers["Content-Length"] = str(len(value)) - session = await self.get_session() + session = await self.set_session() async with session.put(url, data=value, headers=headers, **kwargs) as r: r.raise_for_status() From 4d335afaa5b309829d680ab844872618c409188a Mon Sep 17 00:00:00 2001 From: Martin Durant Date: Thu, 6 Mar 2025 22:01:51 -0500 Subject: [PATCH 2/3] fix --- fsspec/tests/conftest.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/fsspec/tests/conftest.py b/fsspec/tests/conftest.py index 31d99faf2..c648da3fb 100644 --- a/fsspec/tests/conftest.py +++ b/fsspec/tests/conftest.py @@ -130,7 +130,7 @@ def do_POST(self): assert self.headers.get("Transfer-Encoding") == "chunked" self.files[file_path] = b"".join(self.read_chunks()) else: - self.files[file_path] = self.rfile.read(length) + self.files[file_path] = self.rfile.read(int(length)) self._respond(200) do_PUT = do_POST @@ -187,7 +187,7 @@ def serve(): th.daemon = True th.start() try: - yield f"http://{httpd.server_name}:{httpd.server_port}" + yield f"http://127.0.0.1:{httpd.server_port}" finally: httpd.socket.close() httpd.shutdown() From 55cbd1c88b82d65b800ab9b793933377522a7086 Mon Sep 17 00:00:00 2001 From: Martin Durant Date: Thu, 6 Mar 2025 22:12:35 -0500 Subject: [PATCH 3/3] fix more --- fsspec/tests/conftest.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fsspec/tests/conftest.py b/fsspec/tests/conftest.py index c648da3fb..ccf7bdccf 100644 --- a/fsspec/tests/conftest.py +++ b/fsspec/tests/conftest.py @@ -73,7 +73,7 @@ def _respond(self, code=200, headers=None, data=b""): self.wfile.write(data) def do_GET(self): - baseurl = f"http://{self.server.server_name}:{self.server.server_port}" + baseurl = f"http://127.0.0.1:{self.server.server_port}" file_path = self.path if file_path.endswith("/") and file_path.rstrip("/") in self.files: file_path = file_path.rstrip("/")