Update utils.py

utils.py

@@ -92,7 +92,7 @@ def aggregate_data_optimized(df_a, df_b, uuid_col_name, ref_col_name, exclude_co
 
 
 
-def updateStreamAnalysisFast(client, new_data, stream_id, branch_name, geometryGroupPath=None, match_by_id="", return_original=False):
+def updateStreamAnalysisFast(client, new_data, stream_id, branch_name, geometryGroupPath=None, match_by_id="", return_original=False, comm_message=""):
     if geometryGroupPath is None:
         geometryGroupPath = ["@Speckle", "Geometry"]
 
@@ -119,7 +119,7 @@ def updateStreamAnalysisFast(client, new_data, stream_id, branch_name, geometryG
 
     # Send updated objects back to Speckle
     new_objects_raw_speckle_id = operations.send(base=res, transports=[transport])
-    commit_id = client.commit.create(stream_id=stream_id, branch_name=branch_name, object_id=new_objects_raw_speckle_id, message="Updated item in colab")
+    commit_id = client.commit.create(stream_id=stream_id, branch_name=branch_name, object_id=new_objects_raw_speckle_id, message=comm_message + "#+SourceCommit: "+latest_commit.id)
     print("commit created")
     if return_original:
         return objects_raw  # as back-up