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

Added 'setAsyncTrans()' method. 



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

transfer_service/db_connector.py

+11 −0
Original line number Diff line number Diff line
@@ -89,6 +89,17 @@ class DbConnector(object): 
                 node.contentMD5,))

            self.conn.commit()

            

    def setAsyncTrans(self, nodeOSPath, value):

        if self.conn:

            self.cursor.execute("""

                UPDATE Node SET async_trans = %s 

                WHERE node_id IN 

                (SELECT node_id FROM node_os_path 

                WHERE os_path = %s);

                """, 

                (value, nodeOSPath,))

            self.conn.commit()



    def selectNode(self):

        pass