19def pool_insert(files, catalog_name="xmlcatalog_file:PoolFileCatalog.xml"):
20 print (":: inserting [%i] files into pool catalog... (%s)"%(
21 len (files),
22 catalog_name
23 ))
24 import os
25 import subprocess
26 sc,exe = subprocess.getstatusoutput ('which pool_insertFileToCatalog')
27 if sc != 0:
28 print (":: could not find 'pool_insertFileToCatalog' !")
29 print (exe)
30 return 1
31
32 os.environ['POOL_CATALOG'] = catalog_name
33 cmd = "%s %s" % (exe, " ".join(files))
34 sc, out = subprocess.getstatusoutput (cmd)
35
36 out = os.linesep.join(
37 [o for o in out.splitlines()
38 if not (o.startswith("Warning in <TClass::TClass>: no dictionary for class ") or
39 o.startswith('Warning in <TEnvRec::ChangeValue>: duplicate entry'))]
40 )
41
42 if sc != 0:
43 print (":: problem running pool_insertFileToCatalog:")
44 print (out)
45 return 2
46
47 print (out)
48 print (":: inserting [%i] files into pool catalog... [done]"%len(files))
49 return sc
50