Coverage for django_napse/core/tasks/order_process_executor.py: 64%

1# from django_napse.core.models import Order 

2from django_napse.core.tasks.base_tasks import BaseTask 

3 

4 

5class OrderProcessExecutorTask(BaseTask): 

6 name = "order_process_executor" 

7 interval_time = 5 # Impossible to make dynamic modification because of celery 

8 

9 def run(self): 

10 """Run TASK. 

11 

12 Process orders from bots to make buy/sell on binance. 

13 """ 

14 print("OrderProcessExecutorTask") 

15 if not self.avoid_overlap(verbose=True): 

16 print("skipped") 

17 return 

18 # for order in Order.objects.filter(status="pending", completed=True): 

19 # order = processor.process_order(order) 

20 

21 

22OrderProcessExecutorTask().delete_task() 

23OrderProcessExecutorTask().register_task()