Почему задача celery не извлекает все записи из базы данных?

Я использую задачи celery для извлечения записей из другой базы данных в мою локальную базу данных. Да, когда я запускаю celery worker и применяю задачи, записи извлекаются и обновляются в моей локальной базе данных. Проблема в том, что задача не извлекает все записи. Я получаю только 20 записей, в то время как их более 1000. Кто может быть в курсе проблемы? Вот мой код:

@shared_task()
def customer_task():
    customerdata =Customer.objects.using('my_db').values('customer_no')
    print(customerdata.count())
    for item in customerdata.iterator():
        cust_no = item['customer_no']
        obj, created = Customer.objects.filter(customerNo=customer_no).update_or_create(customerNo=customer_no)
        print("customer created or updated in db")

Вернуться на верх