update

alibaba · May 17, 2024 · f35b99c · f35b99c
1 parent 127b5d0
commit f35b99c
Show file tree

Hide file tree

Showing 7 changed files with 281 additions and 264 deletions.
diff --git a/flex/coordinator/gs_flex_coordinator/core/interactive/hqps.py b/flex/coordinator/gs_flex_coordinator/core/interactive/hqps.py
@@ -93,6 +93,12 @@ def list_graphs(self) -> List[dict]:
             )
             graphs = [g.to_dict() for g in api_instance.list_graphs()]
             for g in graphs:
+                g["creation_time"] = encode_datetime(
+                    datetime.datetime.fromtimestamp(g["creation_time"] / 1000)
+                )
+                g["data_update_time"] = encode_datetime(
+                    datetime.datetime.fromtimestamp(g["data_update_time"] / 1000)
+                )
                 # `schema_update_time` is same to `creation_time` in Interactive
                 g["schema_update_time"] = g["creation_time"]
                 # we do not have edge's primary key in Interactive
@@ -138,6 +144,12 @@ def get_graph_by_id(self, graph_id: str) -> dict:
                 api_client
             )
             g = api_instance.get_graph(graph_id).to_dict()
+            g["creation_time"] = encode_datetime(
+                datetime.datetime.fromtimestamp(g["creation_time"] / 1000)
+            )
+            g["data_update_time"] = encode_datetime(
+                datetime.datetime.fromtimestamp(g["data_update_time"] / 1000)
+            )
             # `schema_update_time` is same to `creation_time` in Interactive
             g["schema_update_time"] = g["creation_time"]
             # we do not have edge's primary key in Interactive
@@ -242,10 +254,16 @@ def get_service_status(self) -> dict:
                     },
                 }
                 if response.graph is not None:
-                    graph = response.graph.to_dict()
+                    g = response.graph.to_dict()
+                    g["creation_time"] = encode_datetime(
+                        datetime.datetime.fromtimestamp(g["creation_time"] / 1000)
+                    )
+                    g["data_update_time"] = encode_datetime(
+                        datetime.datetime.fromtimestamp(g["data_update_time"] / 1000)
+                    )
                     # `schema_update_time` is same to `creation_time` in Interactive
-                    graph["schema_update_time"] = graph["creation_time"]
-                    status["graph"] = graph
+                    g["schema_update_time"] = g["creation_time"]
+                    status["graph"] = g
                 return status
 
     def stop_service(self) -> str: