Module Import alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias Assign NameStore ListLoad Str ClassDef bases NameLoad body Expr Str Assign NameStore ListLoad FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Dict decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad body Expr Str Expr Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str If CompareIn NameLoad AttributeLoad NameLoad attr body Raise Call NameLoad BinOpMod Str TupleLoad NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults vararg body Expr Str TryExcept body Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad handlers ExceptHandler type NameLoad body Expr Call AttributeLoad NameLoad attr Str TupleLoad NameLoad Return TryExcept body Assign NameStore Call NameLoad NameLoad NameLoad handlers ExceptHandler type NameLoad body Expr Call AttributeLoad NameLoad attr ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad NameLoad attr NameLoad ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad NameLoad attr NameLoad orelse Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad Num body Expr Str If CompareIs NameLoad NameLoad body Assign NameStore AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr If CompareIs NameLoad NameLoad body Assign NameStore Call NameLoad keyword BinOpAdd Num NameLoad Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return Call AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore AttributeLoad AttributeLoad NameLoad attr attr Assign NameStore Num Assign NameStore Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr Assign NameStore BinOpSub Call NameLoad NameLoad NameLoad If CompareGt NameLoad Num body Assign NameStore SubscriptLoad NameLoad Slice NameLoad Return BinOpMod Str TupleLoad NameLoad NameLoad NameLoad Return BinOpMod Str TupleLoad NameLoad NameLoad decorator_list decorator_list
N/A N/A venusian flowy.config Restart flowy.result SuspendTask flowy.result TaskError flowy.utils logger flowy.utils caller_package N/A __all__ N/A Worker Worker N/A object N/A N/A A runner for all registered wrapped functions. N/A categories N/A __init__ N/A N/A self N/A N/A N/A N/A self registry N/A N/A register N/A N/A self config func key N/A None N/A N/A Register a config and a function with a key. N/A N/A N/A config register self key func N/A register_task N/A N/A self key wrapped_func N/A N/A N/A Register a wrapped task and its key.

        This can executed later by calling Worker instances and passing them
        the same key used for registration.
         N/A N/A key N/A self registry N/A N/A N/A ValueError N/A Implementation is already registered: %r N/A key N/A N/A N/A self registry N/A key wrapped_func N/A __call__ N/A N/A self key input_data decision N/A extra_args N/A N/A Execute the wrapped func registered with key passing the input_data.

        Any exra_args are also passed along to the wrapped_key.

        The actual actions are dispatched to the decision object and can be one
        of:
            * flush() - nothing to do, any pending actions should be commited
            * fail(e) - ignore pending actions, fail the execution
            * finish(e) - ignore pending actions, complete the execution
            * restart(serialized_input) - ignore pending actions, restart the execution
         N/A N/A N/A wrapped_func N/A N/A self registry N/A key N/A N/A N/A KeyError N/A N/A N/A N/A logger error Colud not find implementation for key: %r N/A key N/A N/A N/A N/A serialized_result N/A wrapped_func input_data extra_args N/A N/A N/A SuspendTask N/A N/A N/A N/A decision flush N/A N/A TaskError N/A e N/A N/A N/A N/A logger exception Unhandled task error in task: N/A N/A N/A decision fail e N/A N/A Restart N/A e N/A N/A N/A N/A decision restart N/A e input_data N/A N/A Exception N/A e N/A N/A N/A N/A logger exception Unhandled exception in task: N/A N/A N/A decision fail e N/A N/A N/A N/A decision finish serialized_result N/A scan N/A N/A self categories package ignore level N/A None None None 0 N/A N/A Scan for registered implementations and their configs.

        The categories can be used to scan for only a subset of tasks. By
        default it will use the categories property set on the class.

        Use venusian to scan. By default it will scan the package of the caller
        of the scan method but this can be changed using the package and ignore
        arguments. Their semantics is the same with the ones in venusian
        documentation.

        The level represents the additional stack frames to add to the caller
        package identification code. This is useful when this call happens
        inside another function.
         N/A N/A categories None N/A N/A categories N/A self categories N/A scanner N/A N/A self make_scanner N/A N/A package None N/A N/A package N/A caller_package level N/A 2 level N/A N/A N/A scanner scan package categories categories ignore ignore N/A make_scanner N/A N/A self N/A N/A N/A N/A N/A venusian Scanner register_task N/A self register_task N/A __repr__ N/A N/A self N/A N/A N/A klass N/A N/A self __class__ __name__ N/A max_entries 5 N/A entries N/A sorted N/A N/A N/A self registry values N/A more_entries N/A N/A len entries max_entries N/A N/A more_entries 0 N/A N/A entries N/A entries N/A max_entries N/A N/A <%s %r ... and %s more> N/A klass entries more_entries N/A N/A <%s %r> N/A klass entries N/A N/A