We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 9f5bf99 + b979560 commit 3a60d03Copy full SHA for 3a60d03
queue_job/controllers/main.py
@@ -7,6 +7,7 @@
7
import time
8
import traceback
9
from io import StringIO
10
+from typing import Optional
11
12
from psycopg2 import OperationalError, errorcodes
13
from werkzeug.exceptions import BadRequest, Forbidden
@@ -27,7 +28,7 @@
27
28
29
class RunJobController(http.Controller):
30
@classmethod
- def _acquire_job(cls, env: api.Environment, job_uuid: str) -> Job | None:
31
+ def _acquire_job(cls, env: api.Environment, job_uuid: str) -> Optional[Job]:
32
"""Acquire a job for execution.
33
34
- make sure it is in ENQUEUED state
0 commit comments