Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

pylint fixes and ClaimDict->Claim

Browse source
This commit is contained in:
Lex Berezhny 2019-03-22 02:51:27 -04:00
parent ca92fddecf
commit ea09aca175
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
lbrynet/stream/stream_manager.py
View file

@ -347,13 +347,13 @@ class StreamManager:
else: else:
return await self.storage.rowid_for_stream(downloader.descriptor.stream_hash) return await self.storage.rowid_for_stream(downloader.descriptor.stream_hash)
async def _check_update_or_replace(self, outpoint: str, claim_id: str, claim: ClaimDict) -> typing.Tuple[ async def _check_update_or_replace(self, outpoint: str, claim_id: str, claim: Claim) -> typing.Tuple[
typing.Optional[ManagedStream], typing.Optional[ManagedStream]]: typing.Optional[ManagedStream], typing.Optional[ManagedStream]]:
existing = self.get_filtered_streams(outpoint=outpoint) existing = self.get_filtered_streams(outpoint=outpoint)
if existing: if existing:
await self.start_stream(existing[0]) await self.start_stream(existing[0])
return existing[0], None return existing[0], None
existing = self.get_filtered_streams(sd_hash=claim.source_hash.decode()) existing = self.get_filtered_streams(sd_hash=claim.stream.hash)
if existing and existing[0].claim_id != claim_id: if existing and existing[0].claim_id != claim_id:
raise ResolveError(f"stream for {existing[0].claim_id} collides with existing " raise ResolveError(f"stream for {existing[0].claim_id} collides with existing "
f"download {claim_id}") f"download {claim_id}")
@ -373,7 +373,7 @@ class StreamManager:
return None, None return None, None
async def start_downloader(self, got_descriptor_time: asyncio.Future, downloader: StreamDownloader, async def start_downloader(self, got_descriptor_time: asyncio.Future, downloader: StreamDownloader,
download_id: str, outpoint: str, claim: ClaimDict, resolved: typing.Dict, download_id: str, outpoint: str, claim: Claim, resolved: typing.Dict,
file_name: typing.Optional[str] = None) -> ManagedStream: file_name: typing.Optional[str] = None) -> ManagedStream:
start_time = self.loop.time() start_time = self.loop.time()
downloader.download(self.node) downloader.download(self.node)