celery.beat: periodic tasks on windows -
i trying running periodic tasks on celery beat.
i tried same way described here: http://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html#beat-entries maybe because not quite sure put files , how import everything..
or maybe it's because of wrong timezone (i tried several things here though).
i put in 1 file:
from __future__ import absolute_import import time import job_example celery import celery datetime import timedelta celery.schedules import crontab celerybeat_schedule = { 'add-every-30-seconds': { 'task': 'tasks.add', #'schedule': crontab(hour=15, minute=30, day_of_week=1), #'schedule': crontab(), # execute every minute 'schedule': timedelta(seconds=30), 'args': (15, 16), }, } celery_timezone = 'europe/berlin' # celery_timezone = 'utc' app = celery(include=['tasks']) app.conf.update( broker_url='amqp://localhost//', celery_result_backend='db+postgresql://postgres:1234@localhost:5432/test_lukas', celeryd_task_time_limit=300, # celeryd_task_soft_time_limit=7, # not work under windows celery_task_result_expires=3600, ) celery_imports=("tasks",) @app.task def add(x, y): return x + y @app.task def donbsjob(): print("starting nbsjob now") time.sleep(60) #job_example.buildsw(loc) return("str: donbsjob done") then start worker with:
d:\projekte\mog_arbeitshilfen\learningpython\celproj>celery -a tasks worker -l info ... , celery beat (task-triggerer):
d:\projekte\mog_arbeitshilfen\learningpython\celproj>celery beat --loglevel=info celery beat v3.1.18 (cipater) starting. __ - ... __ - _ configuration -> . broker -> amqp://guest:**@localhost:5672// . loader -> celery.loaders.default.loader . scheduler -> celery.beat.persistentscheduler . db -> celerybeat-schedule . logfile -> [stderr]@%info . maxinterval -> (0s) [2015-07-08 10:14:27,534: info/mainprocess] beat: starting... unfortunately tasks never triggered - don't appear on worker-output , neither on beat-output
some additional information: broker using rabbitmq server. backend set postgresql-db. not using django. d:\celery_test\project>celery report
software -> celery:3.1.18 (cipater) kombu:3.0.26 py:3.4.3 billiard:3.3.0.20 py-amqp:1.4.6 platform -> system:windows arch:32bit, windowspe imp:cpython loader -> celery.loaders.default.loader settings -> transport:amqp results:disabled i appreciate or hints you. thank in advance, lukas
Comments
Post a Comment