openstack/deb-python-taskflow
Code Issues Proposed changes

Fix two minor bugs in docs/examples

Browse Source 
+ taskflow path in sys.path

+ listener => notifier

Change-Id: I0a657540571f9862e2adea5a40d03dfa3ce90e2b
This commit is contained in:
Changbin Liu
2013-07-29 15:05:28 -04:00
parent 7b72e46e51
commit 3e5d91584a
3 changed files with 11 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
docs/examples/reverting_linear.py
View File

@@ -4,13 +4,11 @@ import sys
logging.basicConfig(level=logging.ERROR)
if not os.path.isfile(os.path.join(os.getcwd(), "taskflow", '__init__.py')):
sys.path.insert(0, os.path.join(os.path.abspath(os.getcwd()), os.pardir))
else:
sys.path.insert(0, os.path.abspath(os.getcwd()))
my_dir_path = os.path.dirname(os.path.abspath(__file__))
sys.path.insert(0, os.path.join(os.path.join(my_dir_path, os.pardir),
os.pardir))
from taskflow import decorators
from taskflow.patterns import linear_flow as lf

7
docs/examples/simple_linear.py
View File

@@ -4,10 +4,9 @@ import sys
logging.basicConfig(level=logging.ERROR)
if not os.path.isfile(os.path.join(os.getcwd(), "taskflow", '__init__.py')):
sys.path.insert(0, os.path.join(os.path.abspath(os.getcwd()), os.pardir))
else:
sys.path.insert(0, os.path.abspath(os.getcwd()))
my_dir_path = os.path.dirname(os.path.abspath(__file__))
sys.path.insert(0, os.path.join(os.path.join(my_dir_path, os.pardir),
os.pardir))
from taskflow.patterns import linear_flow as lf

11
docs/examples/simple_linear_listening.py
View File

@@ -4,10 +4,9 @@ import sys
logging.basicConfig(level=logging.ERROR)
if not os.path.isfile(os.path.join(os.getcwd(), "taskflow", '__init__.py')):
sys.path.insert(0, os.path.join(os.path.abspath(os.getcwd()), os.pardir))
else:
sys.path.insert(0, os.path.abspath(os.getcwd()))
my_dir_path = os.path.dirname(os.path.abspath(__file__))
sys.path.insert(0, os.path.join(os.path.join(my_dir_path, os.pardir),
os.pardir))
from taskflow.patterns import linear_flow as lf
@@ -33,8 +32,8 @@ def task_watch(context, state, flow, task, result=None):
flow = lf.Flow("call-them")
flow.add(call_jim)
flow.add(call_joe)
flow.task_listeners.append(task_watch)
flow.listeners.append(flow_watch)
flow.task_notifier.register('*', task_watch)
flow.notifier.register('*', flow_watch)
context = {
"joe_number": 444,