Module Expr Str Import alias Import alias Import alias ImportFrom alias ImportFrom alias ImportFrom alias alias ImportFrom alias TryExcept body Import alias handlers ExceptHandler type NameLoad body Assign NameStore NameLoad Import alias ImportFrom alias alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias alias alias alias alias alias alias ImportFrom alias ImportFrom alias alias ImportFrom alias ImportFrom alias alias ImportFrom alias FunctionDef arguments args NameParam NameParam defaults vararg kwarg body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr NameLoad NameLoad Return Call NameLoad NameLoad NameLoad NameLoad decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call NameLoad NameLoad Return Call NameLoad Num BinOpSub NameLoad Num decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return Num decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call NameLoad NameLoad Assign NameStore Call NameLoad Num BinOpSub NameLoad Num Assign NameStore Call NameLoad Num BinOpSub NameLoad Num Return Call NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore BinOpDiv Num BinOpAdd Num Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore SubscriptLoad NameLoad Index Num Assign NameStore BinOpMult Call NameLoad NameLoad Assign NameStore BinOpMult Call NameLoad NameLoad Assign NameStore Num Assign NameStore Num While CompareLt SubscriptLoad NameLoad Index NameLoad NameLoad body AugAssignAdd NameStore Num While CompareLt SubscriptLoad NameLoad Index NameLoad NameLoad body AugAssignAdd NameStore Num If CompareGt SubscriptLoad NameLoad Index NameLoad SubscriptLoad NameLoad Index NameLoad body Return NameLoad orelse Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr Call NameLoad NameLoad decorator_list Assign NameStore Call NameLoad ListLoad ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr Call NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return CompareLt AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Return Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr decorator_list NameLoad decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore Call NameLoad Num keyword NameLoad keyword Str Assign NameStore Call NameLoad TupleLoad Str Str Str Str Str Str Str keyword NameLoad keyword Str FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad Assign AttributeStore NameLoad attr SubscriptLoad Call NameLoad Index NameLoad decorator_list Assign NameStore Call NameLoad NameLoad FunctionDef arguments args NameParam defaults body Return NameLoad decorator_list Assign NameStore Call NameLoad AttributeLoad NameLoad attr keyword NameLoad Assign NameStore Call NameLoad AttributeLoad NameLoad attr keyword NameLoad Assign NameStore Call NameLoad AttributeLoad NameLoad attr keyword NameLoad Assign NameStore Call NameLoad AttributeLoad NameLoad attr keyword NameLoad Assign NameStore Call NameLoad AttributeLoad NameLoad attr keyword NameLoad Assign NameStore Call NameLoad NameLoad FunctionDef arguments args NameParam defaults body Return Call NameLoad decorator_list Assign NameStore Call NameLoad Assign NameStore Call NameLoad Assign NameStore Call NameLoad Assign NameStore Call NameLoad Assign NameStore Call NameLoad Assign NameStore Call NameLoad Assign NameStore Call NameLoad Assign NameStore Call NameLoad Assign NameStore Call NameLoad Assign NameStore Call NameLoad Assign NameStore Call NameLoad Assign NameStore Call NameLoad Assign NameStore Call NameLoad Assign NameStore Call NameLoad Assign NameStore Call NameLoad FunctionDef arguments args NameParam defaults body Return AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Str Dict Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr keyword NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr keyword NameLoad Assign AttributeStore NameLoad attr Call NameLoad keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str TryExcept body Assign TupleStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad handlers ExceptHandler type NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str NameLoad Return TryExcept body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad handlers ExceptHandler type NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad Return Assign NameStore SubscriptLoad NameLoad Index Str For NameStore Call AttributeLoad Call AttributeLoad NameLoad attr Str Dict attr body Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str TryExcept body Assign TupleStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad handlers ExceptHandler type NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str NameLoad Return TryExcept body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad handlers ExceptHandler type NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad Return Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Str Index Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad If CompareIs NameLoad NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad orelse TryExcept body Expr Call NameLoad Call NameLoad SubscriptLoad SubscriptLoad NameLoad Index Str Index Str handlers ExceptHandler type NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str NameLoad keyword NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr Num NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Num Num Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad Call NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad Call NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad Dict Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str If CompareEq Call NameLoad AttributeLoad NameLoad attr Num body Pass Expr Call AttributeLoad AttributeLoad NameLoad attr attr Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad If SubscriptLoad AttributeLoad NameLoad attr Index NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpAdd Call AttributeLoad AttributeLoad NameLoad attr attr Num Lambda arguments args defaults Call AttributeLoad NameLoad attr NameLoad orelse Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad For NameStore Call AttributeLoad NameLoad attr body If CompareNotIn NameLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad body Continue Assign NameStore AttributeLoad SubscriptLoad NameLoad Index NameLoad attr Assign TupleStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad SubscriptLoad NameLoad Index Num attr Assign NameStore ListLoad NameLoad SubscriptLoad NameLoad Index Num TryExcept body Raise Call AttributeLoad NameLoad attr BinOpMod Str TupleLoad NameLoad NameLoad handlers ExceptHandler body Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad keyword Str keyword Call AttributeLoad NameLoad attr Str keyword Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str NameLoad keyword NameLoad keyword NameLoad Assign NameStore Call NameLoad Call NameLoad AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr TryExcept body Assign TupleStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad keyword NameLoad handlers ExceptHandler type NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad keyword NameLoad Return Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpAdd ListLoad Str NameLoad keyword NameLoad Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore SubscriptLoad NameLoad Index Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr Str ListLoad Assign NameStore Call NameLoad Call NameLoad NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr Str Num Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr Str NameLoad If NameLoad body Assign NameStore Call NameLoad NameLoad If AttributeLoad NameLoad attr body If AttributeLoad NameLoad attr body Assign NameStore Call NameLoad Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr If AttributeLoad NameLoad attr body Assign NameStore Call NameLoad Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr If Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Assign NameStore NameLoad orelse Assign NameStore NameLoad Assign NameStore Call NameLoad Call AttributeLoad NameLoad attr Str ListLoad Assign NameStore Call AttributeLoad NameLoad attr Str NameLoad If NameLoad body Assign NameStore Call NameLoad NameLoad Assign NameStore Call NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad For NameStore TupleLoad NameLoad NameLoad body If UnaryOpNot NameLoad body Continue If BoolOpOr CompareIn NameLoad NameLoad Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad Return Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr If Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad Return Call AttributeLoad NameLoad attr NameLoad If Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr body If UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body If CompareNotIn NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad orelse Expr Call AttributeLoad NameLoad attr NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str If CompareNotEq AttributeLoad NameLoad attr NameLoad body Return Assign NameStore Call AttributeLoad NameLoad attr If CompareGtE AttributeLoad NameLoad attr BinOpAdd NameLoad Num body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad If CompareIn AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults AttributeLoad NameLoad attr body Expr Str If CompareNotIn NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str NameLoad Return Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign AttributeStore NameLoad attr NameLoad For NameStore AttributeLoad NameLoad attr body If CompareIn NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr NameLoad TryExcept body Raise Call NameLoad handlers ExceptHandler body Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str NameLoad SubscriptLoad NameLoad Index Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Str NameLoad keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad keyword BinOpAdd ListLoad Str AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str If UnaryOpNot AttributeLoad NameLoad attr body Return Call NameLoad Call NameLoad Call NameLoad AttributeLoad NameLoad attr Assign NameStore ListLoad For NameStore Call NameLoad Call NameLoad AttributeLoad NameLoad attr body If CompareLt SubscriptLoad AttributeLoad NameLoad attr Index NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr If UnaryOpNot NameLoad body Return NameLoad If BoolOpOr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr body FunctionDef arguments args NameParam defaults body If BoolOpAnd AttributeLoad NameLoad attr CompareEq SubscriptLoad AttributeLoad NameLoad attr Index NameLoad AttributeLoad NameLoad attr body Return NameLoad Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad If CompareIn NameLoad AttributeLoad NameLoad attr body Return NameLoad If BoolOpAnd AttributeLoad NameLoad attr CompareNotIn NameLoad AttributeLoad NameLoad attr body Return NameLoad Return Call AttributeLoad AttributeLoad NameLoad attr attr SubscriptLoad AttributeLoad NameLoad attr Index NameLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad decorator_list Assign NameStore Call NameLoad Call NameLoad NameLoad NameLoad If UnaryOpNot NameLoad body If AttributeLoad AttributeLoad NameLoad attr attr body Assign NameStore Call NameLoad Assign NameStore Call NameLoad If AttributeLoad AttributeLoad NameLoad attr attr body Assign NameStore AttributeLoad NameLoad attr If AttributeLoad AttributeLoad NameLoad attr attr body Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr For NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad body Expr Call AttributeLoad NameLoad attr SubscriptLoad AttributeLoad NameLoad attr Index NameLoad If CompareGt Call NameLoad NameLoad Num body Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Return NameLoad If AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr If BoolOpOr UnaryOpNot AttributeLoad NameLoad attr UnaryOpNot Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr body Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Return NameLoad Return NameLoad orelse Assign NameStore NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad For NameStore Call AttributeLoad Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr body If CompareNotIn NameLoad AttributeLoad NameLoad attr body Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad Call NameLoad Expr Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr NameLoad If AttributeLoad NameLoad attr body Assign NameStore AttributeStore NameLoad attr BinOpAdd AttributeLoad NameLoad attr Num Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpAdd Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Lambda arguments args defaults Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Expr Str If NameLoad body Assign NameStore ListComp SubscriptLoad AttributeLoad NameLoad attr Index NameLoad comprehension NameStore NameLoad orelse Assign NameStore AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad If NameLoad body Assign NameStore SubscriptLoad NameLoad Index NameLoad Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword AttributeLoad NameLoad attr keyword NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr keyword NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Assign SubscriptStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index AttributeLoad NameLoad attr NameLoad Assign NameStore Call NameLoad keyword AttributeLoad NameLoad attr keyword Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Str keyword NameLoad keyword ListLoad Str AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str TryExcept body Assign TupleStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad keyword NameLoad Assign NameStore SubscriptLoad NameLoad Index Num TryExcept body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad handlers ExceptHandler type NameLoad body Pass orelse Expr Call AttributeLoad NameLoad attr NameLoad handlers ExceptHandler type NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str NameLoad keyword NameLoad Return Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore SubscriptLoad NameLoad Index Str If Call AttributeLoad NameLoad attr Str NameLoad body Assign NameStore CompareEq SubscriptLoad NameLoad Index Str Str Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad If BoolOpAnd UnaryOpNot NameLoad CompareGt NameLoad Num body Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad BinOpSub NameLoad Num Expr Call AttributeLoad NameLoad attr NameLoad NameLoad orelse Delete SubscriptDel AttributeLoad NameLoad attr Index NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpAdd ListLoad Str NameLoad keyword NameLoad orelse Expr Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad body Expr Str Assign NameStore SubscriptLoad NameLoad Index Num Assign NameStore SubscriptLoad NameLoad Index Num Assign SubscriptStore NameLoad Slice Num ListLoad NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad Assign NameStore SubscriptLoad NameLoad Index Str Expr Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr NameLoad If NameLoad body Expr Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad orelse Expr Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign NameStore SubscriptLoad NameLoad Index Num Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad If CompareEq AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad orelse If UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body If CompareNotIn NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad If AttributeLoad NameLoad attr body TryExcept body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad handlers ExceptHandler type NameLoad body Pass orelse If CompareEq SubscriptLoad AttributeLoad NameLoad attr Index NameLoad BinOpSub AttributeLoad NameLoad attr Num body Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad NameLoad body Expr Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad ListLoad If BoolOpOr CompareIs NameLoad NameLoad BoolOpAnd AttributeLoad NameLoad attr Call NameLoad ListComp CompareEq NameLoad BinOpSub AttributeLoad NameLoad attr Num comprehension NameStore AttributeLoad NameLoad attr body Assign NameStore AttributeLoad NameLoad attr Assign NameStore NameLoad orelse Assign NameStore NameLoad Assign NameStore Call NameLoad Call NameLoad GeneratorExp SubscriptLoad AttributeLoad NameLoad attr Index NameLoad comprehension NameStore NameLoad Assign NameStore ListLoad While NameLoad body Assign NameStore Call AttributeLoad NameLoad attr If AttributeLoad NameLoad attr body Continue Assign NameStore AttributeLoad NameLoad attr Assign NameStore NameLoad If BoolOpOr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore NameLoad orelse If Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr body If Call AttributeLoad NameLoad attr NameLoad body Assign NameStore NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad For NameStore AttributeLoad NameLoad attr body If CompareIn NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr NameLoad If UnaryOpNot Call AttributeLoad NameLoad attr body Break If BoolOpAnd NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad If NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str AugAssignAdd SubscriptStore AttributeLoad NameLoad attr Index NameLoad Num For NameStore TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str AugAssignSub SubscriptStore AttributeLoad NameLoad attr Index NameLoad Num decorator_list decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad Str NameLoad AttributeLoad NameLoad attr Str NameLoad body Assign NameStore AttributeLoad NameLoad attr If NameLoad body Assign NameStore Call NameLoad NameLoad If NameLoad body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr orelse Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Num Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr BinOpAdd NameLoad Str Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call NameLoad Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Num Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr BinOpAdd NameLoad Str Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Num Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Str Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call NameLoad Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad If NameLoad body Assign NameStore AttributeLoad Call AttributeLoad NameLoad attr attr orelse If NameLoad body Assign NameStore Call NameLoad NameLoad NameLoad NameLoad keyword Str keyword NameLoad orelse Assign NameStore Call NameLoad NameLoad NameLoad Assign NameStore Call NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr If UnaryOpNot NameLoad body TryExcept body Expr Call AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str decorator_list
N/A N/A The Python scheduler for rich scheduling.

The Pure ZMQ scheduler does not allow routing schemes other than LRU,
nor does it check msg_id DAG dependencies. For those, a slightly slower
Python Scheduler exists.
 N/A logging N/A sys N/A time collections deque datetime datetime random randint random types FunctionType N/A N/A N/A numpy N/A N/A N/A ImportError N/A N/A numpy None N/A zmq zmq.eventloop ioloop zmqstream decorator decorator traitlets.config.application Application traitlets.config.loader Config traitlets Instance Dict List Set Integer Enum CBytes ipython_genutils.py3compat cast_bytes ipyparallel error util ipyparallel.factory SessionFactory ipyparallel.util connect_logger local_logger dependency Dependency logged N/A N/A f self N/A args kwargs N/A N/A N/A N/A N/A self log debug scheduler::%s(*%s,**%s) N/A f __name__ args kwargs N/A N/A f self args kwargs N/A decorator plainrandom N/A N/A loads N/A N/A N/A Plain random pick. N/A n N/A len loads N/A N/A randint 0 N/A n 1 N/A lru N/A N/A loads N/A N/A N/A Always pick the front of the line.

    The content of `loads` is ignored.

    Assumes LRU ordering of loads, with oldest first.
     N/A 0 N/A twobin N/A N/A loads N/A N/A N/A Pick two at random, use the LRU of the two.

    The content of loads is ignored.

    Assumes LRU ordering of loads, with oldest first.
     N/A n N/A len loads N/A a N/A randint 0 N/A n 1 N/A b N/A randint 0 N/A n 1 N/A N/A min a b N/A weighted N/A N/A loads N/A N/A N/A Pick two at random using inverse load as weight.

    Return the less loaded of the two.
     N/A weights N/A 1.0 N/A 1e-06 N/A N/A numpy array loads N/A sums N/A N/A weights cumsum N/A t N/A sums N/A -1 N/A x N/A N/A random t N/A y N/A N/A random t N/A idx 0 N/A idy 0 N/A N/A N/A sums N/A idx x N/A N/A idx 1 N/A N/A N/A sums N/A idy y N/A N/A idy 1 N/A N/A N/A weights N/A idy N/A weights N/A idx N/A N/A idy N/A N/A idx N/A leastload N/A N/A loads N/A N/A N/A Always choose the lowest load.

    If the lowest load occurs more than once, the first
    occurance will be used.  If loads has LRU ordering, this means
    the LRU of those with the lowest load is chosen.
     N/A N/A N/A loads index N/A min loads N/A N/A MET N/A Dependency N/A Job N/A object N/A N/A Simple container for a job __init__ N/A N/A self msg_id raw_msg idents msg header metadata targets after follow timeout N/A N/A N/A N/A self msg_id msg_id N/A N/A self raw_msg raw_msg N/A N/A self idents idents N/A N/A self msg msg N/A N/A self header header N/A N/A self metadata metadata N/A N/A self targets targets N/A N/A self after after N/A N/A self follow follow N/A N/A self timeout timeout N/A N/A self removed False N/A N/A self timestamp N/A N/A time time N/A N/A self timeout_id 0 N/A N/A self blacklist N/A set N/A __lt__ N/A N/A self other N/A N/A N/A N/A N/A self timestamp N/A other timestamp N/A __cmp__ N/A N/A self other N/A N/A N/A N/A cmp N/A self timestamp N/A other timestamp N/A dependents N/A N/A self N/A N/A N/A N/A N/A N/A self follow union N/A self after N/A property N/A TaskScheduler N/A SessionFactory N/A N/A Python TaskScheduler object.

    This is the simplest object that supports msg_id based
    DAG dependencies. *Only* task msg_ids are checked, not
    msg_ids of jobs submitted via the MUX queue.

     N/A hwm N/A Integer 1 config True help specify the High Water Mark (HWM) for the downstream
        socket in the Task scheduler. This is the maximum number
        of allowed outstanding tasks on each engine.
        
        The default (1) means that only one task can be outstanding on each
        engine.  Setting TaskScheduler.hwm=0 means there is no limit, and the
        engines continue to be assigned tasks while they are working,
        effectively hiding network latency behind computation, but can result
        in an imbalance of work when submitting many heterogenous tasks all at
        once.  Any positive value greater than one is a compromise between the
        two.

         N/A scheme_name N/A Enum N/A leastload pure lru plainrandom weighted twobin leastload config True help select the task scheduler scheme  [default: Python LRU]
        Options are: 'pure', 'lru', 'plainrandom', 'weighted', 'twobin','leastload' _scheme_name_changed N/A N/A self old new N/A N/A N/A N/A N/A N/A self log debug N/A Using scheme %r new N/A N/A self scheme N/A N/A globals N/A new N/A N/A scheme N/A Instance FunctionType _scheme_default N/A N/A self N/A N/A N/A leastload N/A N/A client_stream N/A Instance N/A zmqstream ZMQStream allow_none True N/A engine_stream N/A Instance N/A zmqstream ZMQStream allow_none True N/A notifier_stream N/A Instance N/A zmqstream ZMQStream allow_none True N/A mon_stream N/A Instance N/A zmqstream ZMQStream allow_none True N/A query_stream N/A Instance N/A zmqstream ZMQStream allow_none True N/A queue N/A Instance deque _queue_default N/A N/A self N/A N/A N/A N/A deque N/A N/A queue_map N/A Dict N/A graph N/A Dict N/A retries N/A Dict N/A pending N/A Dict N/A completed N/A Dict N/A failed N/A Dict N/A destinations N/A Dict N/A clients N/A Dict N/A targets N/A List N/A loads N/A List N/A all_completed N/A Set N/A all_failed N/A Set N/A all_done N/A Set N/A all_ids N/A Set N/A ident N/A CBytes _ident_default N/A N/A self N/A N/A N/A N/A N/A self session bsession N/A start N/A N/A self N/A N/A N/A N/A N/A N/A self query_stream on_recv N/A self dispatch_query_reply N/A N/A N/A N/A self session send N/A self query_stream connection_request N/A N/A N/A N/A N/A self engine_stream on_recv N/A self dispatch_result copy False N/A N/A N/A N/A self client_stream on_recv N/A self dispatch_submission copy False N/A N/A self _notification_handlers N/A dict registration_notification N/A self _register_engine unregistration_notification N/A self _unregister_engine N/A N/A N/A N/A self notifier_stream on_recv N/A self dispatch_notification N/A N/A N/A N/A self log info N/A Scheduler started [%s] N/A self scheme_name N/A resume_receiving N/A N/A self N/A N/A N/A Resume accepting jobs. N/A N/A N/A N/A self client_stream on_recv N/A self dispatch_submission copy False N/A stop_receiving N/A N/A self N/A N/A N/A Stop accepting jobs while there are no engines.
        Leave them in the ZMQ queue. N/A N/A N/A N/A self client_stream on_recv None N/A dispatch_query_reply N/A N/A self msg N/A N/A N/A handle reply to our initial connection request N/A N/A N/A N/A idents msg N/A N/A N/A self session feed_identities msg N/A N/A N/A ValueError N/A N/A N/A N/A N/A self log warn task::Invalid Message: %r msg N/A N/A N/A N/A msg N/A N/A N/A self session deserialize msg N/A N/A N/A ValueError N/A N/A N/A N/A N/A self log warn N/A task::Unauthorized message from: %r idents N/A N/A content N/A msg N/A content N/A uuid N/A N/A N/A N/A content get engines N/A values N/A N/A N/A N/A self _register_engine N/A cast_bytes uuid N/A dispatch_notification N/A N/A self msg N/A N/A N/A dispatch register/unregister events. N/A N/A N/A N/A idents msg N/A N/A N/A self session feed_identities msg N/A N/A N/A ValueError N/A N/A N/A N/A N/A self log warn task::Invalid Message: %r msg N/A N/A N/A N/A msg N/A N/A N/A self session deserialize msg N/A N/A N/A ValueError N/A N/A N/A N/A N/A self log warn N/A task::Unauthorized message from: %r idents N/A N/A msg_type N/A N/A msg N/A header N/A msg_type N/A handler N/A N/A N/A self _notification_handlers get msg_type None N/A N/A handler None N/A N/A N/A N/A N/A self log error N/A Unhandled message type: %r msg_type N/A N/A N/A N/A N/A handler N/A cast_bytes N/A N/A msg N/A content N/A uuid N/A N/A N/A Exception N/A N/A N/A N/A N/A self log error task::Invalid notification msg: %r msg exc_info True N/A N/A util log_errors _register_engine N/A N/A self uid N/A N/A N/A New engine with ident `uid` became available. N/A N/A N/A N/A self targets insert 0 uid N/A N/A N/A N/A self loads insert 0 0 N/A N/A N/A self completed N/A uid N/A set N/A N/A N/A self failed N/A uid N/A set N/A N/A N/A self pending N/A uid N/A N/A N/A N/A self update_graph None N/A _unregister_engine N/A N/A self uid N/A N/A N/A Existing engine with ident `uid` became unavailable. N/A N/A N/A len N/A self targets 1 N/A N/A N/A N/A N/A N/A self engine_stream flush N/A idx N/A N/A N/A self targets index uid N/A N/A N/A N/A self targets pop idx N/A N/A N/A N/A self loads pop idx N/A N/A N/A self pending N/A uid N/A N/A N/A N/A N/A self loop add_timeout N/A N/A N/A N/A self loop time 5 N/A N/A N/A N/A N/A N/A self handle_stranded_tasks uid N/A N/A N/A N/A N/A self completed pop uid N/A N/A N/A N/A self failed pop uid N/A handle_stranded_tasks N/A N/A self engine N/A N/A N/A Deal with jobs resident in an engine that died. N/A lost N/A N/A self pending N/A engine N/A msg_id N/A N/A lost keys N/A N/A N/A msg_id N/A N/A self pending N/A engine N/A N/A N/A raw_msg N/A N/A lost N/A msg_id raw_msg N/A N/A idents msg N/A N/A N/A self session feed_identities raw_msg copy False N/A parent N/A N/A N/A self session unpack N/A N/A msg N/A 1 bytes N/A idents N/A engine N/A idents N/A 0 N/A N/A N/A N/A N/A error EngineError N/A Engine %r died while running task %r N/A engine msg_id N/A N/A N/A N/A content N/A N/A error wrap_exception N/A md N/A dict status error engine N/A N/A engine decode ascii date N/A N/A datetime now N/A msg N/A N/A N/A self session msg apply_reply content parent parent metadata md N/A raw_reply N/A list N/A map N/A zmq Message N/A N/A N/A self session serialize msg ident idents N/A N/A N/A self dispatch_result raw_reply N/A N/A N/A N/A self completed pop engine N/A N/A N/A N/A self failed pop engine N/A dispatch_submission N/A N/A self raw_msg N/A N/A N/A Dispatch job submission to appropriate handlers. N/A N/A N/A N/A self notifier_stream flush N/A N/A N/A N/A idents msg N/A N/A N/A self session feed_identities raw_msg copy False N/A msg N/A N/A N/A self session deserialize msg content False copy False N/A N/A N/A Exception N/A N/A N/A N/A N/A self log error N/A task::Invaid task msg: %r raw_msg exc_info True N/A N/A N/A N/A N/A self mon_stream send_multipart N/A N/A intask raw_msg copy False N/A header N/A msg N/A header N/A md N/A msg N/A metadata N/A msg_id N/A header N/A msg_id N/A N/A N/A N/A self all_ids add msg_id N/A targets N/A N/A md get targets N/A N/A targets N/A set N/A map cast_bytes targets N/A retries N/A N/A md get retries 0 N/A N/A N/A self retries N/A msg_id retries N/A after N/A N/A md get after None N/A after N/A N/A after N/A Dependency after N/A N/A after all N/A N/A N/A after success N/A N/A after N/A Dependency N/A N/A after difference N/A self all_completed success N/A after success failure N/A after failure all N/A after all N/A N/A after failure N/A N/A after N/A Dependency N/A N/A after difference N/A self all_failed success N/A after success failure N/A after failure all N/A after all N/A N/A N/A after check N/A self all_completed N/A self all_failed N/A N/A after MET N/A N/A after MET N/A follow N/A Dependency N/A N/A md get follow N/A N/A timeout N/A N/A md get timeout None N/A timeout N/A N/A timeout N/A float timeout N/A job N/A Job msg_id msg_id raw_msg raw_msg idents idents msg msg header header targets targets after after follow follow timeout timeout metadata md N/A dep N/A after follow N/A N/A N/A dep N/A N/A N/A N/A N/A msg_id dep N/A N/A dep difference N/A self all_ids N/A N/A N/A N/A self queue_map N/A msg_id job N/A N/A N/A self fail_unreachable msg_id N/A error InvalidDependency N/A N/A N/A dep unreachable N/A self all_completed N/A self all_failed N/A N/A N/A N/A self queue_map N/A msg_id job N/A N/A N/A self fail_unreachable msg_id N/A N/A N/A after check N/A self all_completed N/A self all_failed N/A N/A N/A N/A N/A self maybe_run job N/A N/A N/A msg_id N/A self all_failed N/A N/A N/A N/A self save_unmet job N/A N/A N/A N/A self save_unmet job N/A N/A util log_errors job_timeout N/A N/A self job timeout_id N/A N/A N/A callback for a job's timeout.
        
        The job may or may not have been run at this point.
         N/A N/A N/A job timeout_id timeout_id N/A N/A N/A now N/A N/A time time N/A N/A N/A job timeout N/A now 1 N/A N/A N/A N/A N/A self log warn task %s timeout fired prematurely: %s > %s N/A job msg_id N/A job timeout now N/A N/A N/A job msg_id N/A self queue_map N/A N/A N/A N/A N/A self log info task %r timed out N/A job msg_id N/A N/A N/A self fail_unreachable N/A job msg_id N/A error TaskTimeout N/A fail_unreachable N/A N/A self msg_id why N/A N/A error ImpossibleDependency N/A N/A a task has become unreachable, send a reply with an ImpossibleDependency
        error. N/A N/A msg_id N/A self queue_map N/A N/A N/A N/A N/A self log error task %r already failed! msg_id N/A N/A job N/A N/A N/A self queue_map pop msg_id N/A N/A job removed True N/A mid N/A job dependents N/A N/A N/A mid N/A self graph N/A N/A N/A N/A N/A N/A self graph N/A mid remove msg_id N/A N/A N/A N/A why N/A N/A N/A N/A content N/A N/A error wrap_exception N/A N/A N/A N/A self log debug task %r failing as unreachable with: %s msg_id N/A content N/A ename N/A N/A N/A N/A self all_done add msg_id N/A N/A N/A N/A self all_failed add msg_id N/A msg N/A N/A N/A self session send N/A self client_stream apply_reply content parent N/A job header ident N/A job idents N/A N/A N/A N/A self session send N/A self mon_stream msg ident N/A N/A outtask N/A job idents N/A N/A N/A self update_graph msg_id success False N/A available_engines N/A N/A self N/A N/A N/A return a list of available engine indices based on HWM N/A N/A N/A self hwm N/A N/A N/A list N/A range N/A len N/A self targets N/A available N/A N/A idx N/A range N/A len N/A self targets N/A N/A N/A N/A N/A self loads N/A idx N/A self hwm N/A N/A N/A N/A available append idx N/A available N/A maybe_run N/A N/A self job N/A N/A N/A check location dependencies, and run if they are met. N/A msg_id N/A job msg_id N/A N/A N/A N/A self log debug Attempting to assign task %s msg_id N/A available N/A N/A self available_engines N/A N/A available N/A N/A False N/A N/A N/A job follow N/A job targets N/A job blacklist N/A self hwm N/A can_run N/A N/A idx N/A N/A N/A N/A N/A self hwm N/A N/A N/A self loads N/A idx N/A self hwm N/A N/A False N/A target N/A N/A self targets N/A idx N/A N/A target N/A job blacklist N/A N/A False N/A N/A N/A job targets N/A target N/A job targets N/A N/A False N/A N/A N/A N/A job follow check N/A N/A self completed N/A target N/A N/A self failed N/A target N/A N/A indices N/A list N/A filter can_run available N/A N/A indices N/A N/A N/A N/A job follow all N/A N/A dests N/A set N/A relevant N/A set N/A N/A N/A job follow success N/A N/A relevant N/A self all_completed N/A N/A N/A job follow failure N/A N/A relevant N/A N/A relevant union N/A self all_failed N/A m N/A N/A N/A job follow intersection relevant N/A N/A N/A N/A dests add N/A N/A self destinations N/A m N/A N/A N/A len dests 1 N/A N/A N/A N/A self queue_map N/A msg_id job N/A N/A N/A self fail_unreachable msg_id N/A False N/A N/A job targets N/A N/A N/A N/A N/A job targets difference_update N/A job blacklist N/A N/A N/A N/A job targets N/A N/A N/A N/A job targets intersection N/A self targets N/A N/A N/A N/A self queue_map N/A msg_id job N/A N/A N/A self fail_unreachable msg_id N/A False N/A False N/A N/A indices None N/A N/A N/A self submit_task job indices N/A True N/A save_unmet N/A N/A self job N/A N/A N/A Save a message for later submission when its dependencies are met. N/A msg_id N/A job msg_id N/A N/A N/A N/A self log debug Adding task %s to the queue msg_id N/A N/A N/A self queue_map N/A msg_id job N/A N/A N/A N/A self queue append job N/A dep_id N/A N/A N/A N/A N/A job after union N/A job follow difference N/A self all_done N/A N/A N/A dep_id N/A self graph N/A N/A N/A N/A self graph N/A dep_id N/A set N/A N/A N/A N/A N/A self graph N/A dep_id add msg_id N/A N/A job timeout N/A N/A timeout_id N/A job timeout_id N/A N/A job timeout_id 1 N/A N/A N/A N/A self loop add_timeout N/A N/A N/A time time N/A job timeout N/A N/A N/A N/A N/A N/A self job_timeout job timeout_id N/A submit_task N/A N/A self job indices N/A None N/A N/A Submit a task to any of a subset of our targets. N/A indices N/A N/A loads N/A N/A N/A self loads N/A i N/A i indices N/A N/A loads N/A self loads N/A idx N/A N/A self scheme loads N/A indices N/A N/A idx N/A indices N/A idx N/A target N/A N/A self targets N/A idx N/A N/A N/A N/A self engine_stream send target flags N/A zmq SNDMORE copy False N/A N/A N/A N/A self engine_stream send_multipart N/A job raw_msg copy False N/A N/A N/A self add_job idx N/A N/A N/A N/A self pending N/A target N/A N/A job msg_id job N/A content N/A dict msg_id N/A job msg_id engine_id N/A N/A target decode ascii N/A N/A N/A N/A self session send N/A self mon_stream task_destination content content ident N/A tracktask N/A self ident N/A dispatch_result N/A N/A self raw_msg N/A N/A N/A dispatch method for result replies N/A N/A N/A N/A idents msg N/A N/A N/A self session feed_identities raw_msg copy False N/A msg N/A N/A N/A self session deserialize msg content False copy False N/A engine N/A idents N/A 0 N/A N/A N/A idx N/A N/A N/A self targets index engine N/A N/A N/A ValueError N/A N/A N/A N/A N/A N/A self finish_job idx N/A N/A N/A Exception N/A N/A N/A N/A N/A self log error task::Invalid result: %r raw_msg exc_info True N/A N/A md N/A msg N/A metadata N/A parent N/A msg N/A parent_header N/A N/A N/A md get dependencies_met True N/A N/A success N/A N/A md N/A status ok N/A msg_id N/A parent N/A msg_id N/A retries N/A N/A self retries N/A msg_id N/A N/A N/A success N/A retries 0 N/A N/A N/A N/A self retries N/A msg_id N/A retries 1 N/A N/A N/A self handle_unmet_dependency idents parent N/A N/A N/A N/A self retries N/A msg_id N/A N/A N/A self handle_result idents parent raw_msg success N/A N/A N/A N/A self mon_stream send_multipart N/A N/A outtask raw_msg copy False N/A N/A N/A N/A self handle_unmet_dependency idents parent N/A N/A util log_errors handle_result N/A N/A self idents parent raw_msg success N/A True N/A N/A handle a real task result, either success or failure N/A engine N/A idents N/A 0 N/A client N/A idents N/A 1 N/A N/A raw_msg N/A 2 N/A client engine N/A N/A N/A N/A self client_stream send_multipart raw_msg copy False N/A msg_id N/A parent N/A msg_id N/A N/A N/A N/A N/A self pending N/A engine pop msg_id N/A success N/A N/A N/A N/A N/A N/A self completed N/A engine add msg_id N/A N/A N/A N/A self all_completed add msg_id N/A N/A N/A N/A N/A N/A self failed N/A engine add msg_id N/A N/A N/A N/A self all_failed add msg_id N/A N/A N/A N/A self all_done add msg_id N/A N/A N/A self destinations N/A msg_id engine N/A N/A N/A self update_graph msg_id success N/A handle_unmet_dependency N/A N/A self idents parent N/A N/A N/A handle an unmet dependency N/A engine N/A idents N/A 0 N/A msg_id N/A parent N/A msg_id N/A job N/A N/A N/A N/A self pending N/A engine pop msg_id N/A N/A N/A N/A job blacklist add engine N/A N/A N/A job blacklist N/A job targets N/A N/A N/A N/A self queue_map N/A msg_id job N/A N/A N/A self fail_unreachable msg_id N/A N/A N/A N/A N/A self maybe_run job N/A N/A N/A msg_id N/A self all_failed N/A N/A N/A N/A self save_unmet job N/A N/A self hwm N/A N/A N/A N/A idx N/A N/A N/A self targets index engine N/A N/A N/A ValueError N/A N/A N/A N/A N/A N/A N/A self loads N/A idx N/A N/A self hwm 1 N/A N/A N/A N/A self update_graph None N/A update_graph N/A N/A self dep_id success N/A None True N/A N/A dep_id just finished. Update our dependency
        graph and submit any jobs that just became runnable.

        Called with dep_id=None to update entire graph for hwm, but without finishing a task.
         N/A msg_ids N/A N/A N/A self graph pop dep_id N/A N/A N/A N/A dep_id None N/A N/A self hwm N/A any N/A N/A load N/A N/A self hwm 1 N/A load N/A self loads N/A N/A jobs N/A self queue N/A using_queue True N/A N/A using_queue False N/A jobs N/A deque N/A sorted N/A N/A N/A self queue_map N/A msg_id N/A msg_id msg_ids N/A to_restore N/A N/A jobs N/A N/A job N/A N/A jobs popleft N/A N/A job removed N/A N/A N/A msg_id N/A job msg_id N/A put_it_back True N/A N/A N/A N/A N/A job after unreachable N/A self all_completed N/A self all_failed N/A N/A N/A job follow unreachable N/A self all_completed N/A self all_failed N/A N/A N/A N/A self fail_unreachable msg_id N/A put_it_back False N/A N/A N/A N/A N/A job after check N/A self all_completed N/A self all_failed N/A N/A N/A N/A self maybe_run job N/A N/A put_it_back False N/A N/A N/A N/A self queue_map pop msg_id N/A mid N/A job dependents N/A N/A N/A mid N/A self graph N/A N/A N/A N/A N/A N/A self graph N/A mid remove msg_id N/A N/A N/A N/A self available_engines N/A N/A N/A N/A using_queue put_it_back N/A N/A N/A N/A to_restore append job N/A using_queue N/A N/A N/A N/A N/A self queue extendleft to_restore N/A add_job N/A N/A self idx N/A N/A N/A Called after self.targets[idx] just got the job with header.
        Override with subclasses.  The default ordering is simple LRU.
        The default loads are the number of outstanding jobs. N/A N/A N/A self loads N/A idx 1 N/A lis N/A N/A self targets N/A self loads N/A N/A N/A N/A lis append N/A N/A lis pop idx N/A finish_job N/A N/A self idx N/A N/A N/A Called after self.targets[idx] just finished a job.
        Override with subclasses. N/A N/A N/A self loads N/A idx 1 N/A N/A launch_scheduler N/A N/A in_addr out_addr mon_addr not_addr reg_addr config logname log_url loglevel identity in_thread N/A None root None N/A logging DEBUG task False N/A N/A ZMQStream N/A zmqstream ZMQStream N/A config N/A N/A config N/A Config config N/A in_thread N/A N/A ctx N/A N/A N/A zmq Context instance N/A loop N/A N/A N/A ioloop IOLoop instance N/A N/A ctx N/A N/A zmq Context N/A loop N/A N/A ioloop IOLoop N/A ins N/A ZMQStream N/A N/A ctx socket N/A zmq ROUTER loop N/A N/A N/A util set_hwm ins 0 N/A N/A N/A ins setsockopt N/A zmq IDENTITY N/A identity _in N/A N/A N/A ins bind in_addr N/A outs N/A ZMQStream N/A N/A ctx socket N/A zmq ROUTER loop N/A N/A N/A util set_hwm outs 0 N/A N/A N/A outs setsockopt N/A zmq IDENTITY N/A identity _out N/A N/A N/A outs bind out_addr N/A mons N/A N/A zmqstream ZMQStream N/A N/A ctx socket N/A zmq PUB loop N/A N/A N/A util set_hwm mons 0 N/A N/A N/A mons connect mon_addr N/A nots N/A N/A zmqstream ZMQStream N/A N/A ctx socket N/A zmq SUB loop N/A N/A N/A nots setsockopt N/A zmq SUBSCRIBE N/A N/A N/A nots connect not_addr N/A querys N/A ZMQStream N/A N/A ctx socket N/A zmq DEALER loop N/A N/A N/A querys connect reg_addr N/A in_thread N/A N/A log N/A N/A N/A Application instance log N/A N/A log_url N/A N/A log N/A connect_logger logname ctx log_url root scheduler loglevel loglevel N/A N/A log N/A local_logger logname loglevel N/A scheduler N/A TaskScheduler client_stream ins engine_stream outs mon_stream mons notifier_stream nots query_stream querys loop loop log log config config N/A N/A N/A scheduler start N/A N/A in_thread N/A N/A N/A N/A N/A N/A loop start N/A N/A N/A KeyboardInterrupt N/A N/A N/A N/A N/A scheduler log critical Interrupted, exiting... N/A