|
| 1 | +# coding: utf-8 |
| 2 | +from django import VERSION |
| 3 | +from django.core.management import call_command |
| 4 | + |
| 5 | +from ._compat import patch |
| 6 | + |
| 7 | + |
| 8 | +CELERYD_COMMAND = 'djcelery.management.commands.celeryd.Command.handle' |
| 9 | + |
| 10 | + |
| 11 | +def test_celeryd_command(): |
| 12 | + if VERSION >= (1, 10): |
| 13 | + traceback = False |
| 14 | + else: |
| 15 | + traceback = None |
| 16 | + with patch(CELERYD_COMMAND) as handle: |
| 17 | + call_command('celeryd') |
| 18 | + handle.assert_called_with( |
| 19 | + autoreload=None, autoscale=None, beat=None, broker=None, |
| 20 | + concurrency=0, detach=None, exclude_queues=[], executable=None, |
| 21 | + gid=None, heartbeat_interval=None, hostname=None, include=[], |
| 22 | + logfile=None, loglevel='WARN', max_tasks_per_child=None, |
| 23 | + no_color=False, no_execv=False, optimization=None, pidfile=None, |
| 24 | + pool_cls='prefork', purge=False, pythonpath=None, queues=[], |
| 25 | + quiet=None, schedule_filename='celerybeat-schedule', |
| 26 | + scheduler_cls=None, send_events=False, settings=None, |
| 27 | + skip_checks=True, state_db=None, task_soft_time_limit=None, |
| 28 | + task_time_limit=None, traceback=traceback, uid=None, umask=None, |
| 29 | + verbosity=1, without_gossip=False, without_heartbeat=False, |
| 30 | + without_mingle=False, working_directory=None |
| 31 | + ) |
0 commit comments