Utilisation du module python wfcatalog

amqpWorker.py

@@ -145,12 +145,11 @@ def seedtree(content):
 
 def wfcatalog(content):
     # launch wfcatalog updates, 100 files for each run
-    wfcollector = WFCatalogCollector()
+    wfcollector = WFCatalogCollector(to_stdout=True)
     for chunk in grouper(content.splitlines(), 50):
         logger.info("launching WFCatalog collector on : %s" % str(chunk))
         files = json.dumps(chunk)
-        wfcollector.process({'update': True, 'force': True, 'stdout': True, 'csegs': True, 'flags': True, 'list': files})
-
+        wfcollector.process({'update': True, 'force': True, 'csegs': True, 'flags': True, 'list': files})
 
 if __name__ == "__main__":