Merge pull request #754 from Point72/tkp/httpx

Migrate from httpx to httpx2

Author: timkpaine

conda/dev-environment-unix.yml

@@ -17,7 +17,7 @@ dependencies:
  - flex
  - graphviz
  - gtest
- - httpx>=0.20,<1
+ - httpx2>=2,<3
  - libarrow<24
  - libboost>=1.80.0
  - libboost-headers>=1.80.0

conda/dev-environment-win.yml

@@ -17,7 +17,7 @@ dependencies:
 #  - flex  # not available on windows
  - graphviz
  - gtest
- - httpx>=0.20,<1
+ - httpx2>=2,<3
  - libarrow<24
  - libboost>=1.80.0
  - libboost-headers>=1.80.0

csp/tests/adapters/kafka_utils.py

@@ -1,12 +1,12 @@
-import httpx
+import httpx2
 
 
 def _precreate_topic(topic):
     """Since we test against confluent kafka, just use the kafka rest addon"""
     rest_broker = "http://localhost:8082"
-    cluster_info = httpx.get(f"{rest_broker}/v3/clusters")
+    cluster_info = httpx2.get(f"{rest_broker}/v3/clusters")
     cluster_id = cluster_info.json()["data"][0]["cluster_id"]
-    resp = httpx.post(f"{rest_broker}/v3/clusters/{cluster_id}/topics", json={"topic_name": topic})
+    resp = httpx2.post(f"{rest_broker}/v3/clusters/{cluster_id}/topics", json={"topic_name": topic})
     if resp.status_code != 201 and "already exists" not in resp.content.decode("utf8"):
         raise Exception(
             f"Could not create topic {topic} on cluster {rest_broker}/v3/clusters/{cluster_id}/topics - received {resp.content}"

pyproject.toml

@@ -81,7 +81,7 @@ develop = [
     "graphviz",
     "pillow",
     # adapters
-    "httpx>=0.20,<1",  # kafka
+    "httpx2>=2,<3",  # kafka
     "perspective-python>=2",  # perspective
     "anywidget",  # perspective
     "polars",  # parquet
@@ -102,7 +102,7 @@ test = [
     "pytest-asyncio",
     "pytest-cov",
     "pytest-sugar",
-    "httpx>=0.20,<1",
+    "httpx2>=2,<3",
     "perspective-python",
     "polars",
     "psutil",