Merge pull request #505 from sanders41/wait

Remove unused calculation
sanders41 · May 23, 2023 · 9530847 · 9530847
2 parents 70dd855 + e56a42c
commit 9530847
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/meilisearch_python_async/client.py b/meilisearch_python_async/client.py
@@ -149,7 +149,9 @@ async def delete_index_if_exists(self, uid: str) -> bool:
         """
         url = f"indexes/{uid}"
         response = await self._http_requests.delete(url)
-        status = await wait_for_task(self.http_client, response.json()["taskUid"])
+        status = await wait_for_task(
+            self.http_client, response.json()["taskUid"], timeout_in_ms=100000
+        )
         if status.status == "succeeded":
             return True
         return False

diff --git a/meilisearch_python_async/index.py b/meilisearch_python_async/index.py
@@ -113,7 +113,7 @@ async def delete_if_exists(self) -> bool:
             >>>     await index.delete_if_exists()
         """
         response = await self.delete()
-        status = await wait_for_task(self.http_client, response.task_uid)
+        status = await wait_for_task(self.http_client, response.task_uid, timeout_in_ms=100000)
         if status.status == "succeeded":
             return True
 

diff --git a/meilisearch_python_async/task.py b/meilisearch_python_async/task.py
@@ -292,8 +292,6 @@ async def wait_for_task(
             if status.status in ("succeeded", "failed"):
                 return status
             await sleep(interval_in_ms / 1000)
-            time_delta = datetime.now() - start_time
-            elapsed_time = time_delta.seconds * 1000 + time_delta.microseconds / 1000
 
 
 def _get_client(client: AsyncClient | Client) -> AsyncClient: