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')
          try:
              with Pool(processes=settings.DJANGO_TH.get('processes')) as pool:
                  p = Pub()
                  result = pool.map_async(p.publishing, trigger)
                  result.get(timeout=60)
          except TimeoutError as e:
              logger.warning(e)
docs: get all the triggers that need to be handled