celerybeat-mongo

celerybeat-mongo copied to clipboard

Disabling a single task in the MongoDB collection seems to disable all tasks

2

I set the enabled field to `false` for one of the tasks and that resulted in all tasks not being scheduled anymore. The issue resolves once you set the enabled...

dmorina

Cannot import name 'Interval'

3

when trying to run the example from the README I get the error: ``` File "/home/adonias/Workspaces/Training/celery_test/proj.py", line 11, in from celerybeatmongo.models import PeriodicTask, Interval ImportError: cannot import name 'Interval' from...

AdoniasAlcantara

run_immediately doesn't :)

6

Setting the boolean field run_immediately from false to true does not start the task at all. The only thing I see is that after I set the field to 'true'...

P-T-I

I think is time to bump version to 0.2.1 and upgrade pip version. Important issues was fixed such as: - All tasks execution stops when one task hits it's "max_run_count"...

rafaelreuber

Issue with Timezone

1

Hello, I opened an issue on celery repo (https://github.com/celery/celery/issues/6617) The _last_run_at_ is saved in UTC in mongo but each time celery pick the task, it schedule it in UTC while...

Jean-PhilippeD

Update Mongo Schedule entry to support create task dynamically in application still running

1

With this change package will be used in app like flask. I added change to return object saved in db after. Example use celery.py ``` from celery import Celery config...

dainer88

Hi, I can't disable a task after creating it. Celery still is still executing it after. So I wrote a small bug fix but it is not very pretty.

Raznak

Non-default connection and database location settings are not used

15

Even though I added the correct keys into my celery app.conf, celerybeat-mongo does not find / uses them and falls back to the default collection, db and host-uri. ``` app.conf.update(...

P-T-I

Can it work immediately after update mongo data without restart celery ??

1

liuyoyi

Celery 4+ compatibility

3

Looks like lost :(( I fixed it with modifying this: ``` def get_from_database(self): d = {} for doc in PeriodicTask.objects(): if doc.enabled: d[doc.name] = MongoScheduleEntry(doc) return d ``` And remapping...

vulnersCom