dangunter

"""
Task graph
==========
Some toy code to play with the aspects
of the task-graph problem. Note that this is
all in-memory, but really want to implement so it
can directly manipulate mongodb data.

Initial problem statement
--------------------------

dangunter

gp-0.stampede.db

method,time
get_condor_q_time,0.000005
get_descendant_workflow_ids,0.001646
get_failed_job_instances,0.000004
get_invocation_by_time,2.845388
get_invocation_by_time_per_host,4.467101
get_invocation_info,0.000007

dangunter

import sys, time
from netlogger.analysis.workflow.stampede_statistics import *
st = StampedeStatistics("sqlite:///gp-0.stampede.db")
w="89a25dd1-e8ae-4f15-9dea-367bbf598779"
st.initialize(w)
sys.stdout.write("method,time\n")
for fn in filter(lambda s: s.startswith('get_'), dir(st)):
    sys.stdout.write("{},".format(fn))
    sys.stdout.flush()
    t = time.time()