Commit 0373a992 authored by Yoann Dufresne's avatar Yoann Dufresne

verbose: add stdout flushing for cluster usages

parent 419b3ecc
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
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment