nas/MoviePilot
1
0
Fork 0
mirror of https://github.com/jxxghp/MoviePilot.git synced 2026-11-03 22:04:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(transfer): satisfy recovery lease type contract

Browse Source
This commit is contained in:
moviepilot-codex[bot]
2026-09-21 16:09:17 +08:00
parent eb85bb7345
commit 17497eb4ca
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
app/chain/transfer/queue.py
View File

@@ -7,7 +7,7 @@ import time
import traceback
import uuid
from pathlib import Path
from typing import Any, Callable, Dict, List, Optional, Tuple
from typing import Any, Callable, Dict, List, Optional, Tuple, cast
from pydantic_core import to_jsonable_python
@@ -508,10 +508,13 @@ class TransferQueueOwner(_TransferOwnerBase):
recovery_capacity = max(0, worker_capacity - owned_count)
if recovery_capacity <= 0:
return []
return self._transfer_admissions.claim_recoverable(
owner_id=self._worker_owner_id,
limit=min(self._RECOVERY_CLAIM_LIMIT, recovery_capacity),
lease_seconds=self._WORKER_LEASE_SECONDS,
return cast(
List[TransferAdmission],
self._transfer_admissions.claim_recoverable(
owner_id=self._worker_owner_id,
limit=min(self._RECOVERY_CLAIM_LIMIT, recovery_capacity),
lease_seconds=self._WORKER_LEASE_SECONDS,
),
)
def _TransferChain__run_lease_heartbeat(self, stop_event: threading.Event) -> None: