Skip to content
This repository has been archived by the owner on Aug 24, 2024. It is now read-only.

Don't throw error if task has been deleted #35

Open
wants to merge 3 commits into
base: master
Choose a base branch
from
Open

Don't throw error if task has been deleted #35

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
1ebf3a2
Don't throw error if task has been deleted
Nov 28, 2017
bd788b3
Add date when beat apply a job
Apr 6, 2018
7f45171
Indent
Raznak May 11, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
21 changes: 15 additions & 6 deletions celerybeatmongo/schedulers.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -89,6 +89,8 @@ def save(self):
self._task.save(save_condition={})
except Exception:
get_logger(__name__).error(traceback.format_exc())
except mongoengine.errors.NotUniqueError:
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

this exception already catch by previous "except Exception"

pass


class MongoScheduler(Scheduler):
Expand All @@ -109,19 +111,19 @@ def __init__(self, *args, **kwargs):
if hasattr(current_app.conf, "CELERY_MONGODB_SCHEDULER_URL"):
self._mongo = mongoengine.connect(db, host=current_app.conf.CELERY_MONGODB_SCHEDULER_URL)
get_logger(__name__).info("backend scheduler using %s/%s:%s",
current_app.conf.CELERY_MONGODB_SCHEDULER_URL,
db, self.Model._get_collection().name)
current_app.conf.CELERY_MONGODB_SCHEDULER_URL,
db, self.Model._get_collection().name)
else:
self._mongo = mongoengine.connect(db)
get_logger(__name__).info("backend scheduler using %s/%s:%s",
"mongodb://localhost",
db, self.Model._get_collection().name)
"mongodb://localhost",
db, self.Model._get_collection().name)

self._schedule = {}
self._last_updated = None
Scheduler.__init__(self, *args, **kwargs)
self.max_interval = (kwargs.get('max_interval')
or self.app.conf.CELERYBEAT_MAX_LOOP_INTERVAL or 5)
or self.app.conf.CELERYBEAT_MAX_LOOP_INTERVAL or 5)

def setup_schedule(self):
pass
Expand Down Expand Up @@ -149,4 +151,11 @@ def schedule(self):

def sync(self):
for entry in self._schedule.values():
entry.save()
try:
entry.kwargs.update({
'date_ref': datetime.datetime.now().strftime("%Y-%m-%dT%H:%M:%S.%f")
})

entry.save()
except mongoengine.errors.NotUniqueError:
pass