diff --git a/scheduler/scheduler.py b/scheduler/scheduler.py index a1abbdaaf..a97f1ae8e 100644 --- a/scheduler/scheduler.py +++ b/scheduler/scheduler.py @@ -207,7 +207,7 @@ def _check_request(self): if not task.get('schedule', {}).get('force_update', False): logger.debug('ignore newtask %(project)s:%(taskid)s %(url)s', task) continue - cache_key = "%(project)s:%(project)s" % task + cache_key = "%(project)s:%(taskid)s" % task if cache_key in processed_task_cache: logger.debug('processed newtask %(project)s:%(taskid)s %(url)s', task) continue