code: def handle(self, *args, **options):
          
          from django.db import connection
          connection.close()
          failed_tries = settings.DJANGO_TH.get('failed_tries', 10)
          trigger = TriggerService.objects.filter(
              Q(provider_failed__lte=failed_tries) |
              Q(consumer_failed__lte=failed_tries),
              status=True,
              user__is_active=True,
              provider__name__status=True,
              consumer__name__status=True,
          ).select_related('consumer__name', 'provider__name')
  
          with ThreadPoolExecutor(max_workers=settings.DJANGO_TH.get('processes')) as executor:
              r = Read()
              for t in trigger:
                  executor.submit(r.reading, t)
docs: get all the triggers that need to be handled