diff --git a/warehouse/metrics_tools/compute/test_service.py b/warehouse/metrics_tools/compute/test_service.py index b5cd7ef0..b71b388a 100644 --- a/warehouse/metrics_tools/compute/test_service.py +++ b/warehouse/metrics_tools/compute/test_service.py @@ -74,10 +74,6 @@ async def collect_updates(update: JobStatusResponse): close = service.listen_for_job_updates(response.job_id, collect_updates) return (close, future) - # status = await service.get_job_status(response.job_id) - # while status.status in [QueryJobStatus.PENDING, QueryJobStatus.RUNNING]: - # status = await service.get_job_status(response.job_id) - # await asyncio.sleep(1) close, updates_future = await asyncio.create_task(wait_for_job_to_complete()) updates = await updates_future @@ -146,10 +142,6 @@ async def collect_updates(update: JobStatusResponse): close = service.listen_for_job_updates(response.job_id, collect_updates) return (close, future) - # status = await service.get_job_status(response.job_id) - # while status.status in [QueryJobStatus.PENDING, QueryJobStatus.RUNNING]: - # status = await service.get_job_status(response.job_id) - # await asyncio.sleep(1) close, updates_future = await asyncio.create_task(wait_for_job_to_complete()) updates = await updates_future