fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-09-15 13:37:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

Small typo

Browse Source 
and rephrasing of the stop procedure
This commit is contained in:
Ilan Steemers
2015-07-06 11:17:06 +02:00
parent d06aa40a38
commit aaeadeaa6b
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
docs/cluster.rst
View File

@@ -121,15 +121,16 @@ Stop procedure
When a stop signal is given, the sentinel exits the guard loop and instructs the pusher to stop pushing.
Once this is confirmed, the sentinel pushes poison pills onto the task queue and will wait for all the workers to die.
This ensure that the queue is emptied before the workers exit.
Afterwards the sentinel waits for the monitor to empty the result queue before the stop procedure is complete.
This ensures that the queue is emptied before the workers exit.
Afterwards the sentinel waits for the monitor to empty the result and then the stop procedure is complete.
- Send stop event to pusher
- Wait for pusher to exit
- Put poison pills in the Task Queue
- Wait for all the workers to clear the queue and stop
- Put a poison pill on the Result Queue
- Wait for monitor to stop
- Wait for monitor to process remaining results
- Signal that we have stopped
.. warning::
If you force the cluster to terminate before the stop procedure has completed, you can lose tasks and their results.