feat(taskqueue): migrate to cloudtasks v2beta2 (#13)

talkiq · Jan 12, 2018 · d15540f · d15540f
1 parent 811303e
commit d15540f
Show file tree

Hide file tree

Showing 13 changed files with 425 additions and 845 deletions.
diff --git a/taskqueue/gcloud/aio/taskqueue/__init__.py b/taskqueue/gcloud/aio/taskqueue/__init__.py
@@ -1,12 +1,12 @@
 from pkg_resources import get_distribution
 __version__ = get_distribution('gcloud-aio-taskqueue').version
 
-from gcloud.aio.taskqueue.taskmanager import deserialize_task
 from gcloud.aio.taskqueue.taskmanager import FailFastError
 from gcloud.aio.taskqueue.taskmanager import TaskManager
-from gcloud.aio.taskqueue.taskqueue import LocalTaskQueue
 from gcloud.aio.taskqueue.taskqueue import TaskQueue
+from gcloud.aio.taskqueue.utils import decode
+from gcloud.aio.taskqueue.utils import encode
 
 
-__all__ = ['__version__', 'deserialize_task', 'FailFastError', 'TaskManager',
-           'LocalTaskQueue', 'TaskQueue']
+__all__ = ['__version__', 'decode', 'encode', 'FailFastError', 'TaskManager',
+           'TaskQueue']
diff --git a/taskqueue/gcloud/aio/taskqueue/error.py b/taskqueue/gcloud/aio/taskqueue/error.py
@@ -0,0 +1,2 @@
+class FailFastError(Exception):
+    pass