Update tasks in goip/tasks.py

goip/tasks.py

@@ -12,16 +12,16 @@ class UpdateSMStatusError(Exception):
 
 
 
 
 @app.task
 @app.task
-def list_send_sms(group_id, numbers, text):
+def list_send_sms_task(group_id, numbers, text):
     group = SmsGroup.objects.get(uuid=group_id)
     group = SmsGroup.objects.get(uuid=group_id)
     for number, sms_text in generate_sms(numbers, text):
     for number, sms_text in generate_sms(numbers, text):
         sms_id = GOIP.send_sms(sms_text, number)
         sms_id = GOIP.send_sms(sms_text, number)
         group.sms.create(sms_id=sms_id, number=number, text=sms_text)
         group.sms.create(sms_id=sms_id, number=number, text=sms_text)
-        update_sms_status.apply_async((sms_id,), countdown=DELAY)
+        update_sms_status_task.apply_async((sms_id,), countdown=DELAY)
 
 
 
 
 @app.task(bind=True)
 @app.task(bind=True)
-def update_sms_status(self, sms_id):
+def update_sms_status_task(self, sms_id):
     status = GOIP.get_sms_status(sms_id)
     status = GOIP.get_sms_status(sms_id)
     if not status:
     if not status:
         if self.request.retries == 3:
         if self.request.retries == 3:
@@ -33,13 +33,13 @@ def update_sms_status(self, sms_id):
 
 
 
 
 @app.task
 @app.task
-def reset_sms_count_limit():
+def reset_sms_count_limit_task():
     for i in GoipNames.objects.filter(is_active=True):
     for i in GoipNames.objects.filter(is_active=True):
         reset_sms_count(i.channel_id)
         reset_sms_count(i.channel_id)
 
 
 
 
 @app.task
 @app.task
-def update_sms_count_limit():
+def update_sms_count_limit_task():
     """
     """
     Таск обнавляет количество лимитов в базе,
     Таск обнавляет количество лимитов в базе,
     :return: None
     :return: None