Skip to content

Commit 05b8c20

Browse files
committed
remove link to the blog post because github repo already has it in description
1 parent b36ffc0 commit 05b8c20

File tree

2 files changed

+1
-4
lines changed

2 files changed

+1
-4
lines changed

README.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
### About
2-
This project is an example project that complements a [blog post]() about how to implement a job scheduler for traversing DAG of tasks in Python's [Celery](http://celery.readthedocs.io)
2+
This project is an example project that complements a blog post about how to implement a job scheduler for traversing DAG of tasks in Python's [Celery](http://celery.readthedocs.io)
33

44
### How to run
55

dag/task.py

-3
Original file line numberDiff line numberDiff line change
@@ -67,9 +67,6 @@ def run(self, workflow_id, cur_task_id=None):
6767
else:
6868
next_task_ids = find_entry_point(graph)
6969

70-
# Manually set task's state to SUCCESS because when
71-
# we get to the next task the task status may not be updated yet
72-
# to SUCCESS and the workflow may just stuck
7370
self.update_state(state=SUCCESS)
7471

7572
for task_id in next_task_ids:

0 commit comments

Comments
 (0)