Skip to content

Commit ad97eee

Browse files
committed
Fix typo
1 parent acfcc65 commit ad97eee

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

ansible_base/task/publish.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@ def apply_async(self, args=None, kwargs=None):
1919
# this function may allow additional arguments in the future, but not now
2020
Task.objects.create(name=self.task_name)
2121

22+
# pg_notify message (probably) to wake up
2223
transaction.on_commit(run_task_from_queue.delay)
2324

2425
def delay(self, *args, **kwargs):

test_app/tasks.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,14 @@
11
import time
22

3-
from ansible_base.task.publish import durable_tasktask
3+
from ansible_base.task.publish import durable_task
44

55

6-
@durable_tasktask()
6+
@durable_task()
77
def hello_world():
88
print('hello world')
99

1010

11-
@durable_tasktask()
11+
@durable_task()
1212
def sleep(seconds=2):
1313
print(f'about to sleep for {seconds} seconds')
1414
time.sleep(seconds)

0 commit comments

Comments
 (0)