code: def result_cached(task_id, wait=0, broker=None):
      
      if not broker:
          broker = get_broker()
      start = time()
      while True:
          r = broker.cache.get('{}:{}'.format(broker.list_key, task_id))
          if r:
              return SignedPackage.loads(r)['result']
          if (time() - start) * 1000 >= wait >= 0:
              break
          sleep(0.01)
docs: Return the result from the cache backend