Module Import alias Import alias Import alias Import alias Import alias Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Num NameLoad ImportFrom alias identifier ImportFrom alias ImportFrom alias ImportFrom alias identifier ImportFrom alias ImportFrom alias ImportFrom alias Assign NameStore AttributeLoad AttributeLoad NameLoad attr attr FunctionDef arguments args NameParam NameParam defaults body Expr Str Print BinOpMod Str NameLoad Print BinOpMod Str NameLoad decorator_list ClassDef bases AttributeLoad NameLoad attr body Expr Str Assign NameStore Call NameLoad AttributeLoad NameLoad attr Assign NameStore Num FunctionDef arguments args NameParam defaults body For TupleStore NameStore NameStore Call NameLoad AttributeLoad NameLoad attr body Assign NameStore Dict Str SubscriptLoad AttributeLoad NameLoad attr Slice NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list decorator_list Assign NameStore Dict Str Str Str Str Str Dict Str Num Assign NameStore Num Assign NameStore Dict Str ListLoad BinOpMod Str NameLoad FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Assign NameStore Call AttributeLoad Call AttributeLoad NameLoad attr Str attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad keyword Str NameLoad Expr Call AttributeLoad NameLoad attr decorator_list If CompareEq NameLoad Str body Expr Call AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Assign NameStore Call NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call NameLoad NameLoad Assign NameStore ListLoad Assign NameStore ListLoad TryFinally body Print BinOpMod Str NameLoad For NameStore Call NameLoad Num NameLoad body Assign SubscriptStore NameLoad Index Str BinOpMod Str BinOpAdd NameLoad Num Expr Call AttributeLoad NameLoad attr SubscriptLoad NameLoad Index Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr TupleLoad NameLoad AttributeLoad NameLoad attr Print Str Assign SubscriptStore NameLoad Index Str NameLoad Assign NameStore Call NameLoad NameLoad Print Str finalbody Print Str While NameLoad body Assign TupleStore NameStore NameStore Call AttributeLoad NameLoad attr Expr Call NameLoad Expr Call AttributeLoad NameLoad attr
N/A N/A logging N/A os N/A string N/A sys N/A time N/A top_dir N/A N/A N/A os path abspath N/A N/A N/A os path join N/A N/A N/A os path dirname __file__ N/A os pardir N/A os pardir N/A N/A N/A N/A sys path insert 0 top_dir six.moves range compat_range taskflow engines taskflow.engines.worker_based worker taskflow.patterns linear_flow lf taskflow task taskflow.types notifier taskflow.utils threading_utils N/A ANY N/A N/A notifier Notifier ANY event_receiver N/A N/A event_type details N/A N/A N/A This is the callback that (in this example) doesn't do much... N/A N/A Recieved event '%s' event_type N/A N/A Details = %s details N/A EventReporter N/A N/A task Task N/A N/A This is the task that will be running 'remotely' (not really remote). N/A EVENTS N/A tuple N/A string ascii_uppercase N/A EVENT_DELAY 0.1 execute N/A N/A self N/A N/A N/A N/A i e N/A enumerate N/A self EVENTS N/A N/A details N/A leftover N/A N/A self EVENTS N/A i N/A N/A N/A N/A self notifier notify e details N/A N/A N/A time sleep N/A self EVENT_DELAY N/A N/A N/A BASE_SHARED_CONF N/A exchange transport transport_options taskflow memory N/A polling_interval 0.1 N/A MEMORY_WORKERS 1 N/A WORKER_CONF N/A tasks N/A N/A %s:EventReporter __name__ run N/A N/A engine_options N/A N/A N/A reporter N/A EventReporter N/A N/A N/A N/A reporter notifier register ANY event_receiver N/A flow N/A N/A N/A N/A lf Flow event-reporter add reporter N/A eng N/A N/A engines load flow engine worker-based engine_options N/A N/A N/A eng run N/A N/A N/A __name__ __main__ N/A N/A N/A N/A logging basicConfig level N/A logging ERROR N/A worker_conf N/A dict WORKER_CONF N/A N/A N/A worker_conf update BASE_SHARED_CONF N/A engine_options N/A dict BASE_SHARED_CONF N/A workers N/A N/A worker_topics N/A N/A N/A N/A N/A Running %s workers. MEMORY_WORKERS N/A i N/A compat_range 0 MEMORY_WORKERS N/A N/A N/A worker_conf N/A topic N/A worker-%s N/A i 1 N/A N/A N/A worker_topics append N/A worker_conf N/A topic N/A w N/A N/A worker Worker worker_conf N/A runner N/A N/A threading_utils daemon_thread N/A w run N/A N/A N/A runner start N/A N/A N/A w wait N/A N/A N/A workers append N/A runner N/A w stop N/A Executing some work. N/A N/A engine_options N/A topics worker_topics N/A result N/A run engine_options N/A Execution finished. N/A N/A Stopping workers. N/A workers N/A N/A N/A r stopper N/A N/A workers pop N/A N/A stopper N/A N/A N/A r join