From 8f43c157c1e06d033bf060dc286de7b72dfb000a Mon Sep 17 00:00:00 2001 From: timotheyca Date: Wed, 13 Jul 2022 04:05:00 +0300 Subject: [PATCH] flow trace minor change --- trace_common.py | 2 +- trace_flow.py | 4 +--- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/trace_common.py b/trace_common.py index ec52630..4d59d27 100644 --- a/trace_common.py +++ b/trace_common.py @@ -14,7 +14,7 @@ __all__ = ('get_dr', 'target_str', 'jsonify', 'get_fn', 'jsonify_list', 'dump', def get_dr() -> ExtendableResolver: dr = DictResolver() dr = DelayedResolver(dr, lambda: random.uniform(0.200, 0.500)) - # dr = CachingResolver(dr) + dr = CachingResolver(dr) return dr diff --git a/trace_flow.py b/trace_flow.py index 9f75fda..4255daf 100644 --- a/trace_flow.py +++ b/trace_flow.py @@ -6,7 +6,6 @@ from nacl.signing import SigningKey from plot import * from rainbowadn.collection.trees.binary import * -from rainbowadn.collection.trees.binary.actions import * from rainbowadn.core import * from rainbowadn.flow13 import * from rainbowadn.instrument import * @@ -21,7 +20,6 @@ def get_instrumentations() -> list[Instrumentation]: sleep_cc, Concurrency(ActiveBinaryTree, 'add'), Concurrency(ActiveBinaryTree, 'contains'), - Concurrency(BinaryAction, 'on'), ] @@ -75,7 +73,7 @@ async def _trace(): set_gather_linear() bank = await _generate( 16, - 8, 15, + 32, 63, 8, 15, ) # bank = await _generate(