Skip to content

Commit 70157d7

Browse files
GCS file issue fixed
1 parent dc3f98b commit 70157d7

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

backend/src/graphDB_dataAccess.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ def get_source_list(self):
7474
sorting the list by the last updated date.
7575
"""
7676
logging.info("Get existing files list from graph")
77-
query = "MATCH(d:Document) RETURN d ORDER BY d.updatedAt DESC"
77+
query = "MATCH(d:Document) WHERE d.fileName IS NOT NULL RETURN d ORDER BY d.updatedAt DESC"
7878
result = self.graph.query(query)
7979
list_of_json_objects = [entry['d'] for entry in result]
8080
return list_of_json_objects

backend/src/main.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -190,8 +190,9 @@ def create_source_node_graph_url(uri, userName, password ,model, source_url=None
190190
obj_source_node.file_name = file_metadata['fileName']
191191
obj_source_node.file_size = file_metadata['fileSize']
192192
obj_source_node.url = file_metadata['url']
193-
obj_source_node.gcs_bucket = file_metadata['gcsBucket']
194-
obj_source_node.gcs_bucket_folder = file_metadata['gcsBucketFolder']
193+
obj_source_node.file_source = 'GCS'
194+
obj_source_node.gcs_bucket = gcs_bucket_name
195+
obj_source_node.gcs_bucket_folder = gcs_bucket_folder
195196
obj_source_node.created_at = datetime.now()
196197

197198
graphDb_data_Access = graphDBdataAccess(graph)

0 commit comments

Comments
 (0)