Remove fastpath related code

Author: orazve

examples/FastPathExamples.ipynb

@@ -11,7 +11,6 @@
 from .call_builder import IndirectCallBuilder
 from .endpoints import AlphaEndpoints, BetaEndpoints, DirectEndpoints
 from .error.uncallable_namespace import UncallableNamespace
-from .model.fastpath_runner import FastPathRunner
 from .model.kge_runner import KgeRunner
 from .query_runner.arrow_query_runner import ArrowQueryRunner
 from .query_runner.neo4j_query_runner import Neo4jQueryRunner
@@ -125,23 +124,6 @@ def alpha(self) -> AlphaEndpoints:
     def beta(self) -> BetaEndpoints:
         return BetaEndpoints(self._query_runner, "gds.beta", self._server_version)
 
-    @property
-    def fastpath(self) -> FastPathRunner:
-        if not isinstance(self._query_runner, ArrowQueryRunner):
-            raise ValueError("Running FastPath requires GDS with the Arrow server enabled")
-        if self._compute_cluster_ip is None:
-            raise ValueError(
-                "You must set a valid computer cluster ip with the method `set_compute_cluster_ip` to use this feature"
-            )
-        return FastPathRunner(
-            self._query_runner,
-            "gds.fastpath",
-            self._server_version,
-            self._compute_cluster_ip,
-            self._encrypted_db_password,
-            self._query_runner.uri,
-        )
-
     @property
     def kge(self) -> KgeRunner:
         if not isinstance(self._query_runner, ArrowQueryRunner):

graphdatascience/graph_data_science.py

@@ -137,7 +137,7 @@ def _stream_results(self, user_name: str, model_name: str, job_id: str) -> DataF
         )
         res.raise_for_status()
 
-        res_file_name = f'res_{job_id}.json'
+        res_file_name = f"res_{job_id}.json"
         with open(res_file_name, mode="wb+") as f:
             f.write(res.content)
 

graphdatascience/model/fastpath_runner.py

@@ -92,12 +92,6 @@ def __init__(
         if tls_root_certs:
             client_options["tls_root_certs"] = tls_root_certs
 
-        print("location:")
-        print(location)
-        print("client_options:")
-        print(client_options)
-        print("auth:")
-        print(auth)
         self._flight_client = flight.FlightClient(location, **client_options)
 
     def connection_info(self) -> Tuple[str, int]:
@@ -134,10 +128,6 @@ def get_property(
             }
 
         ticket = flight.Ticket(json.dumps(payload).encode("utf-8"))
-        print("ticket:")
-        print(ticket)
-        print("_flight_client")
-        print(self._flight_client)
         get = self._flight_client.do_get(ticket)
         arrow_table = get.read_all()
 

graphdatascience/model/kge_runner.py

@@ -1,4 +1,3 @@
 -----BEGIN RSA PUBLIC KEY-----
-MEgCQQDNfbk2/PGneqZO6Vx9VbPe6ZnQJ/F5kOOW07jGDU34NFfUI06Nw0HmwT2h
-c9s3nZTUUlAVi/aUCl3b4NcB8vThAgMBAAE=
+WRONGKEY
 -----END RSA PUBLIC KEY-----

graphdatascience/query_runner/gds_arrow_client.py

@@ -558,10 +558,3 @@ def test_graph_alpha_construct_backward_compat_with_arrow(gds: GraphDataScience)
 
     with pytest.warns(DeprecationWarning):
         gds.alpha.graph.construct("hello", nodes, relationships)
-
-
-@pytest.mark.compatible_with(min_inclusive=ServerVersion(2, 2, 0))
-def test_drop_list_warning_reproduction(gds: GraphDataScience) -> None:
-    G, _ = gds.graph.project(GRAPH_NAME, {"Node": {"properties": ["x", "y"]}}, {"REL": {"properties": "relX"}})
-    res = gds.graph.list()
-    assert res["graphName"].tolist() == ["g"]

graphdatascience/resources/field-testing/pub.pem

@@ -854,7 +854,7 @@ def test_graph_relationships_stream_without_arrow(gds_without_arrow: GraphDataSc
 
 @pytest.mark.compatible_with(min_inclusive=ServerVersion(2, 2, 0))
 def test_graph_relationships_stream_with_arrow(gds: GraphDataScience) -> None:
-    G, _ = gds.graph.project(GRAPH_NAME, "*", ["REL_0", "REL2"])
+    G, _ = gds.graph.project(GRAPH_NAME, "*", ["REL", "REL2"])
 
     if gds.server_version() >= ServerVersion(2, 5, 0):
         result = gds.graph.relationships.stream(G, ["REL", "REL2"])