File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -273,8 +273,8 @@ def get(self) -> Tuple[
273273 """Get a task from the task queue (non-blocking).
274274
275275 This statement marks the next available task in the queue as
276- started (being processed) and returns its ID and task details. The query
277- uses a FOR UPDATE SKIP LOCKED clause to lock the selected
276+ started (being processed) and returns its ID and task details.
277+ The query uses a FOR UPDATE SKIP LOCKED clause to lock the selected
278278 task so that other workers can't select the same task simultaneously.
279279
280280 After executing the query, the method fetches the result using
@@ -582,7 +582,7 @@ def _deserialize(self, blob: str) -> Any:
582582 def reschedule (
583583 self ,
584584 task_id : UUID ,
585- decrease_ttl : Optional [bool ]= False
585+ decrease_ttl : Optional [bool ] = False ,
586586 ) -> None :
587587 """Move a task back from being processed to the task queue.
588588
You can’t perform that action at this time.
0 commit comments