diff --git a/core/tasks.py b/core/tasks.py
index 9797ab40..03691f3d 100644
--- a/core/tasks.py
+++ b/core/tasks.py
@@ -43,7 +43,7 @@ def update_products_task():
         for vendor_class in vendors_classes:
             vendor = vendor_class()
             try:
-                vendor.update_stock.delay()
+                vendor.update_stock()
             except Exception as e:
                 logger.warning(f"Skipping {vendor_class} due to error: {e!s}")
 
diff --git a/core/vendors/__init__.py b/core/vendors/__init__.py
index fb9aac2e..3a05c9e6 100644
--- a/core/vendors/__init__.py
+++ b/core/vendors/__init__.py
@@ -2,8 +2,6 @@ import json
 from contextlib import suppress
 from math import ceil
 
-from celery import shared_task
-
 from core.elasticsearch import process_query
 from core.models import AttributeValue, Brand, Category, Product, Stock, Vendor
 from payments.errors import RatesError
@@ -206,7 +204,6 @@ class AbstractVendor:
         self.get_stocks_queryset().delete()
         self.get_attribute_values_queryset().delete()
 
-    @shared_task
     def update_stock(self):
         pass