We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3eecdd7 commit fcc648fCopy full SHA for fcc648f
nucleus/job.py
@@ -4,6 +4,8 @@
4
5
import requests
6
7
+JOB_POLLING_INTERVAL = 5
8
+
9
10
@dataclass
11
class AsyncJob:
@@ -26,10 +28,12 @@ def errors(self) -> List[str]:
26
28
27
29
def sleep_until_complete(self, verbose_std_out=True):
30
while 1:
- time.sleep(1)
31
status = self.status()
32
33
+ time.sleep(JOB_POLLING_INTERVAL)
34
35
if verbose_std_out:
- print(status)
36
+ print(f"Status at {time.ctime()}: {status}")
37
if status["status"] == "Running":
38
continue
39
break
0 commit comments