MCPcopy Create free account

hub / github.com/NetAngels/celery-tasktree / functions

Functions26 in github.com/NetAngels/celery-tasktree

↓ 11 callersMethodadd_task
(self, func, args=None, kwargs=None)
celery_tasktree.py:13
↓ 4 callersMethodapply_async
(self)
celery_tasktree.py:34
↓ 4 callersMethodpop
(self)
celery_tasktree.py:27
↓ 4 callersMethodpush
(self, func, args=None, kwargs=None)
celery_tasktree.py:23
↓ 3 callersMethodapply_and_join
Execute tasks asynchronously and wait for the latest result. Method can be useful in conjunction with pop()/push() methods. In such
celery_tasktree.py:52
↓ 1 callersFunction_exec_callbacks
Exec the callback or list of callbacks. Return asyncronous results as the TaskSetResult object.
celery_tasktree.py:151
↓ 1 callersMethod_get_child_tasks
(self)
celery_tasktree.py:100
↓ 1 callersFunctionjoin_tree
Join to all async results in the tree
celery_tasktree.py:62
↓ 1 callersFunctionread
(fname)
setup.py:5
↓ 1 callersFunctionrun_with_callbacks
Decorator "run with callbacks" Function is useful as decorator for :meth:`run` method of tasks which are subclasses of generic :class:`celery
celery_tasktree.py:131
↓ 1 callersFunctionsetup
()
tests.py:19
Method__bool__
(self)
test_tasks.py:29
Method__init__
(self)
celery_tasktree.py:9
Method__init__
(self, func, args=None, kwargs=None)
celery_tasktree.py:79
Method__init__
(self, created)
test_tasks.py:27
Method__str__
(self)
test_tasks.py:31
Methodadd_task
(self, func, args=None, kwargs=None)
celery_tasktree.py:90
Functionmkdir
Create directory. We return CreateDirectoryResult object intentionally, so that task_with_callbacks decorator can add async_result attribute
test_tasks.py:8
Methodrun
(self, directory)
test_tasks.py:21
Functiontask_with_callbacks
decorator "task with callbacks" Callback or list of callbacks which go to function in "callbacks" kwarg, will be executed after the function
celery_tasktree.py:117
Functiontest_empty_task_tree
()
tests.py:107
Functiontest_push_and_pop
()
tests.py:98
Functiontest_task_already_contains_callback
()
tests.py:76
Functiontest_task_subclass
()
tests.py:89
Functiontest_task_tree
Check TaskTree execution order. Following tree of tasks is created:: d 0 d 1 - d 1.1 ` d 1.2 - d 1.2.1
tests.py:25
Functionwrapper
(*args, **kwargs)
celery_tasktree.py:139