Recursion => while loop

Author: jon-wurtz

src/bloqade/analog/task/exclusive.py

@@ -254,26 +254,26 @@ def pull(self,poll_interval:float=20):
         Please ensure that it is relatively large, otherwise
         the server could get overloaded with queries.
         """
-        if self._task_result_ir.task_status is QuEraTaskStatusCode.Unsubmitted:
-            raise ValueError("Task ID not found.")
-
-        if self._task_result_ir.task_status in [
-            QuEraTaskStatusCode.Completed,
-            QuEraTaskStatusCode.Partial,
-            QuEraTaskStatusCode.Failed,
-            QuEraTaskStatusCode.Unaccepted,
-            QuEraTaskStatusCode.Cancelled,
-        ]:
-            return self
-
-        status = self.status()
-        if status in [QuEraTaskStatusCode.Completed, QuEraTaskStatusCode.Partial]:
-            self._task_result_ir = self._http_handler.fetch_results(self._task_id)
-        else:
-            time.sleep(poll_interval)
-            self.pull(poll_interval)
 
-        return self
+        while True:
+            if self._task_result_ir.task_status is QuEraTaskStatusCode.Unsubmitted:
+                raise ValueError("Task ID not found.")
+
+            if self._task_result_ir.task_status in [
+                QuEraTaskStatusCode.Completed,
+                QuEraTaskStatusCode.Partial,
+                QuEraTaskStatusCode.Failed,
+                QuEraTaskStatusCode.Unaccepted,
+                QuEraTaskStatusCode.Cancelled,
+            ]:
+                return self
+
+            status = self.status()
+            if status in [QuEraTaskStatusCode.Completed, QuEraTaskStatusCode.Partial]:
+                self._task_result_ir = self._http_handler.fetch_results(self._task_id)
+                return self
+            
+            time.sleep(poll_interval)
 
     def cancel(self):
         # This is not supported