@@ -1412,7 +1412,7 @@ def index(self, local_loc, remote_loc, isVerbose=False):
14121412 st_dict ['created_time' ] = []
14131413 st_dict ['accessed_time' ] = []
14141414 st_dict ['mode' ] = []
1415- st_dict ['inode' ] = []
1415+ # st_dict['inode'] = []
14161416 st_dict ['device' ] = []
14171417 st_dict ['n_links' ] = []
14181418 st_dict ['uid' ] = []
@@ -1433,7 +1433,7 @@ def index(self, local_loc, remote_loc, isVerbose=False):
14331433 st_dict ['created_time' ].append (st .st_ctime )
14341434 st_dict ['accessed_time' ].append (st .st_atime )
14351435 st_dict ['mode' ].append (st .st_mode )
1436- st_dict ['inode' ].append (st .st_ino )
1436+ # st_dict['inode'].append(st.st_ino)
14371437 st_dict ['device' ].append (st .st_dev )
14381438 st_dict ['n_links' ].append (st .st_nlink )
14391439 st_dict ['uid' ].append (st .st_uid )
@@ -1485,7 +1485,7 @@ def index(self, local_loc, remote_loc, isVerbose=False):
14851485
14861486 fnull = open (os .devnull , 'w' )
14871487 with redirect_stdout (fnull ):
1488- t .load_module ('plugin' , "Dict" , "reader" , collection = st_dict )
1488+ t .load_module ('plugin' , "Dict" , "reader" , collection = st_dict , table_name = "filesystem" )
14891489 t .artifact_handler (interaction_type = 'ingest' )
14901490
14911491 # # Create new filesystem collection with origin and remote locations
@@ -1526,7 +1526,11 @@ def copy(self, tool="copy", isVerbose=False, **kwargs):
15261526 # See if FS table has been created
15271527 t = Terminal ()
15281528
1529- f = self .project_name + ".db"
1529+ f = self .project_name
1530+ if ".db" not in f :
1531+ f = self .project_name + ".db"
1532+
1533+
15301534 try :
15311535 #f = os.path.join((local_loc, str(self.project_name+".db") ))
15321536 #f = self.local_location+"/"+self.project_name+".db"
@@ -1615,8 +1619,8 @@ def copy(self, tool="copy", isVerbose=False, **kwargs):
16151619
16161620 # File Movement
16171621 if isVerbose :
1618- print ( "conduit cp -r " + os . path . join ( self .local_location , self . project_name ) + " " + os .path .join (self .remote_location , self .project_name ) )
1619- cmd = ['/usr/projects/systems/conduit/bin/conduit-cmd' ,'--config' ,'/usr/projects/systems/conduit/conf/conduit-cmd-config.yaml' ,'cp' ,'-r' ,os . path . join ( self .local_location , self . project_name ) , os .path .join (self .remote_location , self .project_name )]
1622+ print ( "conduit cp -r " + self .local_location + " " + os .path .join (self .remote_location , self .project_name ) )
1623+ cmd = ['/usr/projects/systems/conduit/bin/conduit-cmd' ,'--config' ,'/usr/projects/systems/conduit/conf/conduit-cmd-config.yaml' ,'cp' ,'-r' ,self .local_location , os .path .join (self .remote_location , self .project_name )]
16201624 process = subprocess .Popen (cmd , stdin = subprocess .DEVNULL , stdout = subprocess .PIPE , stderr = subprocess .PIPE , text = True , encoding = 'latin-1' )
16211625
16221626 stdout , stderr = process .communicate ()
0 commit comments