parent
a31ce44dfc
commit
ed16a4fd3d
2 changed files with 1 additions and 4 deletions
|
|
@ -43,7 +43,7 @@ def update_products_task():
|
||||||
for vendor_class in vendors_classes:
|
for vendor_class in vendors_classes:
|
||||||
vendor = vendor_class()
|
vendor = vendor_class()
|
||||||
try:
|
try:
|
||||||
vendor.update_stock.delay()
|
vendor.update_stock()
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.warning(f"Skipping {vendor_class} due to error: {e!s}")
|
logger.warning(f"Skipping {vendor_class} due to error: {e!s}")
|
||||||
|
|
||||||
|
|
|
||||||
3
core/vendors/__init__.py
vendored
3
core/vendors/__init__.py
vendored
|
|
@ -2,8 +2,6 @@ import json
|
||||||
from contextlib import suppress
|
from contextlib import suppress
|
||||||
from math import ceil
|
from math import ceil
|
||||||
|
|
||||||
from celery import shared_task
|
|
||||||
|
|
||||||
from core.elasticsearch import process_query
|
from core.elasticsearch import process_query
|
||||||
from core.models import AttributeValue, Brand, Category, Product, Stock, Vendor
|
from core.models import AttributeValue, Brand, Category, Product, Stock, Vendor
|
||||||
from payments.errors import RatesError
|
from payments.errors import RatesError
|
||||||
|
|
@ -206,7 +204,6 @@ class AbstractVendor:
|
||||||
self.get_stocks_queryset().delete()
|
self.get_stocks_queryset().delete()
|
||||||
self.get_attribute_values_queryset().delete()
|
self.get_attribute_values_queryset().delete()
|
||||||
|
|
||||||
@shared_task
|
|
||||||
def update_stock(self):
|
def update_stock(self):
|
||||||
pass
|
pass
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue