summaryrefslogtreecommitdiff
path: root/taskflow/examples
diff options
context:
space:
mode:
authorJoshua Harlow <harlowja@yahoo-inc.com>2015-07-06 15:31:29 -0700
committerJoshua Harlow <jxharlow@godaddy.com>2016-05-10 15:26:57 -0700
commitafbfe77a7f7bad87c3e95b4f0c94cab84258a5bb (patch)
tree2f27418e05a99cbfd2bad76977152d07067d37f8 /taskflow/examples
parent3321b22ca81bd0e1d8923abc62db014d07fed9ce (diff)
downloadtaskflow-afbfe77a7f7bad87c3e95b4f0c94cab84258a5bb.tar.gz
Remove deprecated things for 2.0 release
Change-Id: Id9adbc50bd51adc77ce88f698ad0ea2ee63fc5e2
Diffstat (limited to 'taskflow/examples')
-rw-r--r--taskflow/examples/99_bottles.py8
-rw-r--r--taskflow/examples/delayed_return.py2
2 files changed, 5 insertions, 5 deletions
diff --git a/taskflow/examples/99_bottles.py b/taskflow/examples/99_bottles.py
index b0588e1..d4255b6 100644
--- a/taskflow/examples/99_bottles.py
+++ b/taskflow/examples/99_bottles.py
@@ -35,7 +35,7 @@ from taskflow.jobs import backends as job_backends
from taskflow import logging as taskflow_logging
from taskflow.patterns import linear_flow as lf
from taskflow.persistence import backends as persistence_backends
-from taskflow.persistence import logbook
+from taskflow.persistence import models
from taskflow import task
from taskflow.types import timing
@@ -176,9 +176,9 @@ def run_poster():
# unit of work we want to complete and the factory that
# can be called to create the tasks that the work unit needs
# to be done.
- lb = logbook.LogBook("post-from-%s" % my_name)
- fd = logbook.FlowDetail("song-from-%s" % my_name,
- uuidutils.generate_uuid())
+ lb = models.LogBook("post-from-%s" % my_name)
+ fd = models.FlowDetail("song-from-%s" % my_name,
+ uuidutils.generate_uuid())
lb.add(fd)
with contextlib.closing(persist_backend.get_connection()) as conn:
conn.save_logbook(lb)
diff --git a/taskflow/examples/delayed_return.py b/taskflow/examples/delayed_return.py
index 5ca7007..d4bf659 100644
--- a/taskflow/examples/delayed_return.py
+++ b/taskflow/examples/delayed_return.py
@@ -42,7 +42,7 @@ from taskflow import task
from taskflow.types import notifier
-class PokeFutureListener(base.ListenerBase):
+class PokeFutureListener(base.Listener):
def __init__(self, engine, future, task_name):
super(PokeFutureListener, self).__init__(
engine,