Module Import alias identifier ImportFrom alias ImportFrom alias FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad body Import alias identifier Assign NameStore Call AttributeLoad NameLoad attr NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr Num Assign NameStore Num While NameLoad body Assign TupleStore NameStore NameStore Yield Call AttributeLoad NameLoad attr If CompareIs NameLoad NameLoad body Break AugAssignAdd NameStore BinOpSub NameLoad SubscriptLoad NameLoad Index Num Assign NameStore BinOpDiv NameLoad NameLoad If CompareGt NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr TupleLoad NameLoad Str Call NameLoad NameLoad orelse If CompareLt NameLoad UnaryOpUSub NameLoad body Expr Call AttributeLoad NameLoad attr TupleLoad NameLoad Str Call NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad Num Assign SubscriptStore NameLoad Index Num NameLoad Raise Call NameLoad Num decorator_list FunctionDef arguments args NameParam defaults NameLoad body Import alias Import alias With Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr Str Str NameStore body While NameLoad body Assign TupleStore NameStore NameStore Yield Call AttributeLoad NameLoad attr If CompareIs NameLoad NameLoad body Break Expr Call AttributeLoad NameLoad attr BinOpMod Str TupleLoad NameLoad NameLoad Raise Call NameLoad Num decorator_list FunctionDef arguments args NameParam defaults NameLoad body Expr Call AttributeLoad NameLoad attr While NameLoad body Assign NameStore Yield Call AttributeLoad NameLoad attr Print BinOpMod Str TupleLoad SubscriptLoad NameLoad Index Num SubscriptLoad NameLoad Index Num SubscriptLoad NameLoad Index Num decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body If Yield Call AttributeLoad NameLoad attr body Raise Call NameLoad Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign NameStore Yield Call AttributeLoad NameLoad attr NameLoad Num NameLoad Num Assert Call NameLoad NameLoad AttributeLoad NameLoad attr Assign NameStore Yield Call AttributeLoad NameLoad attr NameLoad Assert Call NameLoad NameLoad AttributeLoad NameLoad attr Expr Yield Call AttributeLoad Call AttributeLoad AttributeLoad NameLoad attr attr attr AttributeLoad NameLoad attr keyword NameLoad Expr Yield Call AttributeLoad Call AttributeLoad AttributeLoad NameLoad attr attr attr AttributeLoad NameLoad attr keyword NameLoad For NameStore Call NameLoad Num body Assign NameStore Call AttributeLoad NameLoad attr Num Num Assign NameStore TupleLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Yield Call AttributeLoad NameLoad attr Num Assign NameStore TupleLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Yield Call AttributeLoad NameLoad attr keyword NameLoad decorator_list If CompareEq NameLoad Str body Import alias alias Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call NameLoad Assign NameStore Call NameLoad ListLoad Assign NameStore Call NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad
N/A N/A asyncoro.disasyncoro asyncoro asyncoro.discoro * asyncoro.discoro_schedulers RemoteCoroScheduler rcoro_avg_proc N/A N/A threshold trend_coro window_size coro N/A None N/A N/A numpy np N/A data N/A N/A np empty window_size dtype float N/A N/A N/A data fill 0.0 N/A cumsum 0.0 N/A True N/A N/A N/A i n N/A N/A N/A coro receive N/A N/A n None N/A N/A N/A cumsum N/A n N/A data N/A 0 N/A avg N/A cumsum window_size N/A N/A avg threshold N/A N/A N/A N/A trend_coro send N/A i high N/A float avg N/A N/A N/A avg N/A threshold N/A N/A N/A N/A trend_coro send N/A i low N/A float avg N/A data N/A N/A np roll data -1 N/A N/A data N/A -1 n N/A N/A StopIteration 0 N/A rcoro_save_proc N/A N/A coro N/A None N/A N/A os N/A tempfile N/A N/A open N/A N/A N/A os path join N/A os sep N/A N/A tempfile gettempdir tickdata w fd N/A N/A True N/A N/A N/A i n N/A N/A N/A coro receive N/A N/A n None N/A N/A N/A N/A N/A fd write N/A %s: %s
 N/A i n N/A N/A StopIteration 0 N/A trend_proc N/A N/A coro N/A None N/A N/A N/A N/A coro set_daemon N/A True N/A N/A trend N/A N/A N/A coro receive N/A N/A trend signal at % 4d: %s / %.2f N/A N/A trend N/A 0 N/A trend N/A 1 N/A trend N/A 2 N/A client_proc N/A N/A computation coro N/A None N/A N/A N/A N/A N/A computation schedule N/A N/A N/A Exception schedule failed N/A trend_coro N/A N/A asyncoro Coro trend_proc N/A rcoro_avg N/A N/A N/A rcoro_scheduler schedule rcoro_avg_proc 0.4 trend_coro 10 N/A N/A isinstance rcoro_avg N/A asyncoro Coro N/A rcoro_save N/A N/A N/A rcoro_scheduler schedule rcoro_save_proc N/A N/A isinstance rcoro_save N/A asyncoro Coro N/A N/A N/A N/A N/A N/A N/A asyncoro AsynCoro instance peer N/A rcoro_avg location stream_send True N/A N/A N/A N/A N/A N/A N/A asyncoro AsynCoro instance peer N/A rcoro_save location stream_send True N/A i N/A range 1000 N/A N/A n N/A N/A random uniform -1 1 N/A item N/A i n N/A N/A N/A rcoro_avg send item N/A N/A N/A rcoro_save send item N/A N/A N/A N/A coro sleep 0.01 N/A item N/A i None N/A N/A N/A rcoro_avg send item N/A N/A N/A rcoro_save send item N/A N/A N/A N/A rcoro_scheduler finish close True N/A N/A N/A __name__ __main__ N/A N/A logging random N/A N/A N/A N/A asyncoro logger setLevel N/A logging DEBUG N/A N/A Scheduler N/A computation N/A Computation N/A N/A rcoro_scheduler N/A RemoteCoroScheduler computation N/A N/A N/A asyncoro Coro client_proc computation