summaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorJim McCusker <jmccusker@5amsolutions.com>2014-11-21 09:27:08 -0500
committerJim McCusker <jmccusker@5amsolutions.com>2014-11-21 09:27:08 -0500
commitc3ede71f458adb0deffc201305c7d89bc05a1cb6 (patch)
tree5231895b12be60020514335334e4bfd0090fbaa4 /examples
parent0f8adec29eb27be3eb35dc6bd1c899c79b178eca (diff)
downloadrdflib-c3ede71f458adb0deffc201305c7d89bc05a1cb6.tar.gz
Forgot to actually put the finished tasks back out of the queue.
Diffstat (limited to 'examples')
-rw-r--r--examples/graph_digest_benchmark.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/examples/graph_digest_benchmark.py b/examples/graph_digest_benchmark.py
index 4368a44d..3f8f694c 100644
--- a/examples/graph_digest_benchmark.py
+++ b/examples/graph_digest_benchmark.py
@@ -72,12 +72,12 @@ def bioportal_benchmark(apikey, output_file, threads):
og.load(stats['download_url']+"?apikey=%s"%apikey)
finally:
dl_lock.release()
- print stats['ontology'], stats['download_url']
+ print stats['ontology'], stats['id']
ig = to_isomorphic(og)
graph_digest = ig.graph_digest(stats)
finished_tasks.put(stats)
except Exception as e:
- print 'ERROR' id, e
+ print 'ERROR', stats['id'], e
stats['error'] = str(e)
finished_tasks.put(stats)
except Empty:
@@ -99,7 +99,7 @@ def bioportal_benchmark(apikey, output_file, threads):
written_tasks = 0
while written_tasks < task_count:
stats = finished_tasks.get()
- print "Writing", stats['ontology']
+ #print "Writing", stats['ontology']
writer.writerow(stats)
w.flush()
written_tasks += 1