code: def running(self):
          
          r = self._client._redis
          flag = '{}:flag'.format(self._queue)
          if bool(r.exists(flag)):
              return r.ttl(flag) is None
  
          return False
docs: Returns true if job still in running state
          :return: