move an integration test without docker dependencies into unit suite (#9620)

GitOrigin-RevId: 71df6a244bc17c848c2d8a49eb6ecd1579e64a05

Author: zxqfd555

integration_tests/webserver/test_rest_connector.py

@@ -203,23 +203,6 @@ def target() -> None:
     t.join()
 
 
-def test_server_fail_on_duplicate_port(tmp_path: pathlib.Path, port: int) -> None:
-    class InputSchema(pw.Schema):
-        k: int
-        v: int
-
-    webserver = pw.io.http.PathwayWebserver(host="127.0.0.1", port=port)
-    queries, response_writer = pw.io.http.rest_connector(
-        webserver=webserver, schema=InputSchema, delete_completed_queries=False
-    )
-    response_writer(queries.select(query_id=queries.id, result=pw.this.v))
-
-    with pytest.raises(RuntimeError, match="Added route will never be executed"):
-        queries_dup, response_writer_dup = pw.io.http.rest_connector(
-            webserver=webserver, schema=InputSchema, delete_completed_queries=False
-        )
-
-
 def _test_server_two_endpoints(
     tmp_path: pathlib.Path, port: int, with_cors: bool
 ) -> None:

python/pathway/tests/test_io.py

@@ -5458,3 +5458,20 @@ class InputSchema(pw.Schema):
             "./a.txt",
             schema=InputSchema,
         )
+
+
+def test_server_fail_on_duplicate_port(port: int) -> None:
+    class InputSchema(pw.Schema):
+        k: int
+        v: int
+
+    webserver = pw.io.http.PathwayWebserver(host="127.0.0.1", port=port)
+    queries, response_writer = pw.io.http.rest_connector(
+        webserver=webserver, schema=InputSchema, delete_completed_queries=False
+    )
+    response_writer(queries.select(query_id=queries.id, result=pw.this.v))
+
+    with pytest.raises(RuntimeError, match="Added route will never be executed"):
+        _, _ = pw.io.http.rest_connector(
+            webserver=webserver, schema=InputSchema, delete_completed_queries=False
+        )