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() diff --git a/fsspec/tests/conftest.py b/fsspec/tests/conftest.py index 31d99faf2..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("/") @@ -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()