Commit af5a6015 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Insert node only if it doesn't exist. 



Signed-off-by: default avatarCristiano Urban <cristiano.urban@inaf.it>
parent dd87f8b9

transfer_service/store_preprocessor.py

+4 −2
Original line number Diff line number Diff line
@@ -160,6 +160,7 @@ class StorePreprocessor(TaskExecutor): 
                cnode.setParentPath(basePath)

                cnode.setOwnerID(self.userId)

                cnode.setCreatorID(self.userId)

                if not self.dbConn.nodeExists(cnode):

                    self.dbConn.insertNode(cnode)



        out.write("\n\n")
@@ -184,6 +185,7 @@ class StorePreprocessor(TaskExecutor): 
                    dnode.setOwnerID(self.userId)

                    dnode.setCreatorID(self.userId)

                    dnode.setContentMD5(self.md5calc.getMD5(file))

                    if not self.dbConn.nodeExists(dnode):

                        self.dbConn.insertNode(dnode)



        out.write("\n")