Fixes: 1) Remove redundant populate_index calls from core/tasks.py;
Extra: 1) Cleanup unused import for `populate_index`.
This commit is contained in:
parent
d419d9c72e
commit
f7c5fdcf37
1 changed files with 0 additions and 3 deletions
|
|
@ -11,7 +11,6 @@ from celery.utils.log import get_task_logger
|
||||||
from constance import config
|
from constance import config
|
||||||
from django.core.cache import cache
|
from django.core.cache import cache
|
||||||
|
|
||||||
from core.elasticsearch import populate_index
|
|
||||||
from core.models import Product, Promotion
|
from core.models import Product, Promotion
|
||||||
from core.utils.caching import set_default_cache
|
from core.utils.caching import set_default_cache
|
||||||
from core.vendors import delete_stale
|
from core.vendors import delete_stale
|
||||||
|
|
@ -39,7 +38,6 @@ def update_products_task():
|
||||||
|
|
||||||
if not update_products_task_running:
|
if not update_products_task_running:
|
||||||
cache.set("update_products_task_running", True, 86400)
|
cache.set("update_products_task_running", True, 86400)
|
||||||
populate_index()
|
|
||||||
vendors_classes = []
|
vendors_classes = []
|
||||||
|
|
||||||
for vendor_class in vendors_classes:
|
for vendor_class in vendors_classes:
|
||||||
|
|
@ -50,7 +48,6 @@ def update_products_task():
|
||||||
logger.warning(f"Skipping {vendor_class} due to error: {e!s}")
|
logger.warning(f"Skipping {vendor_class} due to error: {e!s}")
|
||||||
|
|
||||||
delete_stale()
|
delete_stale()
|
||||||
populate_index()
|
|
||||||
|
|
||||||
cache.delete("update_products_task_running")
|
cache.delete("update_products_task_running")
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue