diff --git a/deconvolution/dgraph/AbstractDGFactory.py b/deconvolution/dgraph/AbstractDGFactory.py index 0e1a42544438920aa5b9c1f0800f2819040fd898..7c560bdefd8c135dfae6b456add6b40d7c421297 100644 --- a/deconvolution/dgraph/AbstractDGFactory.py +++ b/deconvolution/dgraph/AbstractDGFactory.py @@ -1,4 +1,5 @@ import networkx as nx +import sys from abc import abstractmethod from multiprocessing import Pool, Value @@ -13,6 +14,7 @@ def process_node(factory, node): if factory.verbose: print(f"{my_value}: Generating d-graphs") + sys.stdout.flush() # udg generation neighbors = list(factory.graph.neighbors(node)) @@ -22,12 +24,14 @@ def process_node(factory, node): if factory.verbose: print(f"{my_value}: d-graphs generated, starting filtering") print(f"{my_value}: {len(dgs)} graphs to filter") + sys.stdout.flush() # udg domination filtering dgs = AbstractDGIndex.filter_entry(dgs) if factory.verbose: print(f"{my_value}({factory.nb_nodes}) terminated") + sys.stdout.flush() return node, dgs