mirror of
https://github.com/django-q2/django-q2.git
synced 2026-09-17 14:37:54 +08:00
Compare commits
1 Commits
v1.5.3
...
post-spawn
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
35bea76ec3 |
@@ -2,14 +2,6 @@
|
|||||||
|
|
||||||
## [Unreleased](https://github.com/GDay/django-q2/tree/HEAD)
|
## [Unreleased](https://github.com/GDay/django-q2/tree/HEAD)
|
||||||
|
|
||||||
## [v1.5.3](https://github.com/GDay/django-q2/tree/v1.5.3) (2023-05-14)
|
|
||||||
|
|
||||||
**Merged pull requests:**
|
|
||||||
|
|
||||||
- Add post_spawn signal. https://github.com/django-q2/django-q2/pull/93
|
|
||||||
- Post spawn docs https://github.com/django-q2/django-q2/pull/95
|
|
||||||
- Make processes identifiable with uuid4 https://github.com/django-q2/django-q2/pull/91
|
|
||||||
|
|
||||||
## [v1.5.2](https://github.com/GDay/django-q2/tree/v1.5.2) (2023-04-13)
|
## [v1.5.2](https://github.com/GDay/django-q2/tree/v1.5.2) (2023-04-13)
|
||||||
|
|
||||||
**Merged pull requests:**
|
**Merged pull requests:**
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
import django
|
import django
|
||||||
|
|
||||||
VERSION = (1, 5, 3)
|
VERSION = (1, 5, 2)
|
||||||
|
|
||||||
if django.VERSION < (3, 2):
|
if django.VERSION < (3, 2):
|
||||||
default_app_config = "django_q.apps.DjangoQConfig"
|
default_app_config = "django_q.apps.DjangoQConfig"
|
||||||
|
|||||||
@@ -69,7 +69,6 @@ class Cluster:
|
|||||||
self.start_event = Event()
|
self.start_event = Event()
|
||||||
self.sentinel = Process(
|
self.sentinel = Process(
|
||||||
target=Sentinel,
|
target=Sentinel,
|
||||||
name=f"Process-{uuid.uuid4().hex}",
|
|
||||||
args=(
|
args=(
|
||||||
self.stop_event,
|
self.stop_event,
|
||||||
self.start_event,
|
self.start_event,
|
||||||
@@ -197,7 +196,7 @@ class Sentinel:
|
|||||||
"""
|
"""
|
||||||
:type target: function or class
|
:type target: function or class
|
||||||
"""
|
"""
|
||||||
p = Process(target=target, args=args, name=f"Process-{uuid.uuid4().hex}")
|
p = Process(target=target, args=args)
|
||||||
p.daemon = True
|
p.daemon = True
|
||||||
if target == worker:
|
if target == worker:
|
||||||
p.daemon = Conf.DAEMONIZE_WORKERS
|
p.daemon = Conf.DAEMONIZE_WORKERS
|
||||||
|
|||||||
@@ -11,36 +11,36 @@ Start your cluster using Django's ``manage.py`` command::
|
|||||||
|
|
||||||
You should see the cluster starting ::
|
You should see the cluster starting ::
|
||||||
|
|
||||||
10:57:40 [Q] INFO Q Cluster freddie-uncle-twenty-ten starting.
|
10:57:40 [Q] INFO Q Cluster-31781 starting.
|
||||||
10:57:40 [Q] INFO Process-ede257774c4444c980ab479f10947acc ready for work at 31784
|
10:57:40 [Q] INFO Process-1:1 ready for work at 31784
|
||||||
10:57:40 [Q] INFO Process-ed580482da3f42968230baa2e4253e42 ready for work at 31785
|
10:57:40 [Q] INFO Process-1:2 ready for work at 31785
|
||||||
10:57:40 [Q] INFO Process-8a370dc2bc1d49aa9864e517c9895f74 ready for work at 31786
|
10:57:40 [Q] INFO Process-1:3 ready for work at 31786
|
||||||
10:57:40 [Q] INFO Process-74912f9844264d1397c6e54476b530c0 ready for work at 31787
|
10:57:40 [Q] INFO Process-1:4 ready for work at 31787
|
||||||
10:57:40 [Q] INFO Process-b00edb26c6074a6189e5696c60aeb35b ready for work at 31788
|
10:57:40 [Q] INFO Process-1:5 ready for work at 31788
|
||||||
10:57:40 [Q] INFO Process-b0862965db04479f9784a26639ee51e0 ready for work at 31789
|
10:57:40 [Q] INFO Process-1:6 ready for work at 31789
|
||||||
10:57:40 [Q] INFO Process-7e8abbb8ca2d4d9bb20a937dd5e2872b ready for work at 31790
|
10:57:40 [Q] INFO Process-1:7 ready for work at 31790
|
||||||
10:57:40 [Q] INFO Process-b0862965db04479f9784a26639ee51e0 ready for work at 31791
|
10:57:40 [Q] INFO Process-1:8 ready for work at 31791
|
||||||
10:57:40 [Q] INFO Process-67fa9461ac034736a766cd813f617e62 monitoring at 31792
|
10:57:40 [Q] INFO Process-1:9 monitoring at 31792
|
||||||
10:57:40 [Q] INFO Process-eac052c646b2459797cee98bdb84c85d guarding cluster at 31783
|
10:57:40 [Q] INFO Process-1 guarding cluster at 31783
|
||||||
10:57:40 [Q] INFO Process-5d98deb19b1e4b2da2ef1e5bd6824f75 pushing tasks at 31793
|
10:57:40 [Q] INFO Process-1:10 pushing tasks at 31793
|
||||||
10:57:40 [Q] INFO Q Cluster freddie-uncle-twenty-ten running.
|
10:57:40 [Q] INFO Q Cluster-31781 running.
|
||||||
|
|
||||||
|
|
||||||
Stopping the cluster with ctrl-c or either the ``SIGTERM`` and ``SIGKILL`` signals, will initiate the :ref:`stop_procedure`::
|
Stopping the cluster with ctrl-c or either the ``SIGTERM`` and ``SIGKILL`` signals, will initiate the :ref:`stop_procedure`::
|
||||||
|
|
||||||
16:44:12 [Q] INFO Q Cluster freddie-uncle-twenty-ten stopping.
|
16:44:12 [Q] INFO Q Cluster-31781 stopping.
|
||||||
16:44:12 [Q] INFO Process-eac052c646b2459797cee98bdb84c85d stopping cluster processes
|
16:44:12 [Q] INFO Process-1 stopping cluster processes
|
||||||
16:44:13 [Q] INFO Process-5d98deb19b1e4b2da2ef1e5bd6824f75 stopped pushing tasks
|
16:44:13 [Q] INFO Process-1:10 stopped pushing tasks
|
||||||
16:44:13 [Q] INFO Process-b0862965db04479f9784a26639ee51e0 stopped doing work
|
16:44:13 [Q] INFO Process-1:6 stopped doing work
|
||||||
16:44:13 [Q] INFO Process-7e8abbb8ca2d4d9bb20a937dd5e2872b stopped doing work
|
16:44:13 [Q] INFO Process-1:4 stopped doing work
|
||||||
16:44:13 [Q] INFO Process-b0862965db04479f9784a26639ee51e0 stopped doing work
|
16:44:13 [Q] INFO Process-1:1 stopped doing work
|
||||||
16:44:13 [Q] INFO Process-b00edb26c6074a6189e5696c60aeb35b stopped doing work
|
16:44:13 [Q] INFO Process-1:5 stopped doing work
|
||||||
16:44:13 [Q] INFO Process-74912f9844264d1397c6e54476b530c0 stopped doing work
|
16:44:13 [Q] INFO Process-1:7 stopped doing work
|
||||||
16:44:13 [Q] INFO Process-8a370dc2bc1d49aa9864e517c9895f74 stopped doing work
|
16:44:13 [Q] INFO Process-1:3 stopped doing work
|
||||||
16:44:13 [Q] INFO Process-ed580482da3f42968230baa2e4253e42 stopped doing work
|
16:44:13 [Q] INFO Process-1:8 stopped doing work
|
||||||
16:44:13 [Q] INFO Process-ede257774c4444c980ab479f10947acc stopped doing work
|
16:44:13 [Q] INFO Process-1:2 stopped doing work
|
||||||
16:44:14 [Q] INFO Process-67fa9461ac034736a766cd813f617e62 stopped monitoring results
|
16:44:14 [Q] INFO Process-1:9 stopped monitoring results
|
||||||
16:44:15 [Q] INFO Q Cluster freddie-uncle-twenty-ten has stopped.
|
16:44:15 [Q] INFO Q Cluster-31781 has stopped.
|
||||||
|
|
||||||
The number of workers, optional timeouts, recycles and cpu_affinity can be controlled via the :doc:`configure` settings.
|
The number of workers, optional timeouts, recycles and cpu_affinity can be controlled via the :doc:`configure` settings.
|
||||||
|
|
||||||
|
|||||||
@@ -75,7 +75,7 @@ author = "Ilan Steemers, Stan Triepels"
|
|||||||
# The short X.Y version.
|
# The short X.Y version.
|
||||||
version = "1.5"
|
version = "1.5"
|
||||||
# The full version, including alpha/beta/rc tags.
|
# The full version, including alpha/beta/rc tags.
|
||||||
release = "1.5.3"
|
release = "1.5.2"
|
||||||
|
|
||||||
# The language for content autogenerated by Sphinx. Refer to documentation
|
# The language for content autogenerated by Sphinx. Refer to documentation
|
||||||
# for a list of supported languages.
|
# for a list of supported languages.
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[tool.poetry]
|
[tool.poetry]
|
||||||
name = "django-q2"
|
name = "django-q2"
|
||||||
version = "1.5.3"
|
version = "1.5.2"
|
||||||
packages = [
|
packages = [
|
||||||
{ include = "django_q" },
|
{ include = "django_q" },
|
||||||
]
|
]
|
||||||
|
|||||||
Reference in New Issue
Block a user