Change name to durable_task

Author: AlanCoding

ansible_base/task/publish.py

@@ -27,6 +27,7 @@ def delay(self, *args, **kwargs):
 
 class TaskDecorator:
     def __init__(self, *args, **kwargs):
+        # TODO: this will process a task timeout, just not yet set up
         self.args = args
         self.kwargs = kwargs
 
@@ -39,5 +40,5 @@ def __call__(self, fn):
         return fn
 
 
-def task():
+def durable_task():
     return TaskDecorator()

ansible_base/task/tasks.py

@@ -29,3 +29,17 @@ def run_task_from_queue():
         logger.traceback(f'Failed to run and complete {task.name}')
 
     task.delete()
+
+
+# TODO: Add a "reaper" fallback task, this is currently blocked on dispatcher issue
+# https://github.com/ansible/dispatcher/issues/6
+# When run_task_from_queue starts the task, the uuid needs to be setup to be discoverable
+# this fallback method will query for tasks that are older than a certain grace period
+# later improvement: look for tasks older that the task timeout plus a grace period
+# these tasks are in arrears
+# For each task in arrears, we will:
+# 1. obtain a row-level lock for that task
+# 2. send a roll-call message looking for its uuid
+# 3. if we get no answer to the roll-call, the task status is changed to lost
+# 4. dependent on policies defined in settings, we may re-submit the task up to a retry count
+# 5. if retry count is exhausted, task is failed

test_app/tasks.py

@@ -1,14 +1,14 @@
 import time
 
-from ansible_base.task.publish import task
+from ansible_base.task.publish import durable_tasktask
 
 
-@task()
+@durable_tasktask()
 def hello_world():
     print('hello world')
 
 
-@task()
+@durable_tasktask()
 def sleep(seconds=2):
     print(f'about to sleep for {seconds} seconds')
     time.sleep(seconds)