mirror of
https://github.com/django-q2/django-q2.git
synced 2026-10-02 16:28:12 +08:00
Adds test for cron
This commit is contained in:
@@ -9,8 +9,8 @@ from django.utils import timezone
|
|||||||
from django_q.brokers import get_broker
|
from django_q.brokers import get_broker
|
||||||
from django_q.cluster import pusher, worker, monitor, scheduler
|
from django_q.cluster import pusher, worker, monitor, scheduler
|
||||||
from django_q.conf import Conf
|
from django_q.conf import Conf
|
||||||
from django_q.tasks import Schedule, fetch, schedule as create_schedule
|
|
||||||
from django_q.queues import Queue
|
from django_q.queues import Queue
|
||||||
|
from django_q.tasks import Schedule, fetch, schedule as create_schedule
|
||||||
|
|
||||||
|
|
||||||
@pytest.fixture
|
@pytest.fixture
|
||||||
@@ -91,8 +91,17 @@ def test_scheduler(broker, monkeypatch):
|
|||||||
schedule_type=Schedule.MINUTES,
|
schedule_type=Schedule.MINUTES,
|
||||||
minutes=10)
|
minutes=10)
|
||||||
assert hasattr(minute_schedule, 'pk') is True
|
assert hasattr(minute_schedule, 'pk') is True
|
||||||
|
# Cron schedule
|
||||||
|
minute_schedule = create_schedule('django_q.tests.tasks.word_multiply',
|
||||||
|
2,
|
||||||
|
word='django',
|
||||||
|
schedule_type=Schedule.CRON,
|
||||||
|
cron="0 22 * * 1-5")
|
||||||
|
assert hasattr(minute_schedule, 'pk') is True
|
||||||
# All other types
|
# All other types
|
||||||
for t in Schedule.TYPE:
|
for t in Schedule.TYPE:
|
||||||
|
if t == Schedule.CRON:
|
||||||
|
continue
|
||||||
schedule = create_schedule('django_q.tests.tasks.word_multiply',
|
schedule = create_schedule('django_q.tests.tasks.word_multiply',
|
||||||
2,
|
2,
|
||||||
word='django',
|
word='django',
|
||||||
|
|||||||
Reference in New Issue
Block a user