def list(self, request):
        try:
            timestamp = int(time())
            random = randint(0, 100000)
            result = add.apply_async(args=[timestamp, random])
            now = datetime.datetime.now()
            while (now + datetime.timedelta(seconds=10)) > datetime.datetime.now():
                if result.result == timestamp + random:
                    return Response("OK", status=status.HTTP_200_OK)
                sleep(0.5)
        except __HOLE__:
            pass
        return Response("FAILED", status=status.HTTP_500_INTERNAL_SERVER_ERROR)
dataset/ETHPy150Open ustream/openduty/openduty/healthcheck.py/CeleryHealthCheckViewSet.list