code: def handle(self, *args, **options):
          
          trigger_id = options.get('trigger_id')
          trigger = TriggerService.objects.filter(
              id=int(trigger_id),
              status=True,
              user__is_active=True,
              provider_failed__lt=settings.DJANGO_TH.get('failed_tries', 10),
              consumer_failed__lt=settings.DJANGO_TH.get('failed_tries', 10)
          ).select_related('consumer__name', 'provider__name')
          try:
              with Pool(processes=1) as pool:
                  r = Read()
                  result = pool.map_async(r.reading, trigger)
                  result.get(timeout=360)
                  p = Pub()
                  result = pool.map_async(p.publishing, trigger)
                  result.get(timeout=360)
  
                  cache.delete('django_th' + '_fire_trigger_' + str(trigger_id))
          except TimeoutError as e:
              logger.warning(e)
docs: get the trigger to fire