Skip to content

Commit c882348

Browse files
committed
linting
1 parent 2ac2093 commit c882348

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

postgrestq/task_queue.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -191,7 +191,8 @@ def add(
191191
lease_timeout,
192192
can_start_at
193193
)
194-
VALUES (%s, %s, %s, %s, %s, COALESCE(%s, current_timestamp))
194+
VALUES (%s, %s, %s, %s, %s,
195+
COALESCE(%s, current_timestamp))
195196
"""
196197
).format(sql.Identifier(self._table_name)),
197198
(
@@ -487,7 +488,8 @@ def check_expired_leases(self) -> None:
487488
AND started_at IS NOT NULL
488489
AND queue_name = %s
489490
AND (
490-
started_at + (lease_timeout || ' seconds')::INTERVAL
491+
started_at +
492+
(lease_timeout || ' seconds')::INTERVAL
491493
) < current_timestamp
492494
ORDER BY can_start_at;
493495
"""

0 commit comments

Comments
 (0)