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

don't block on sending download analytics events

Browse source
This commit is contained in:
Jack Robison 2019-03-01 15:22:19 -05:00
parent df8934d472
commit 9de3f3ff09
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
lbrynet/stream/stream_manager.py
View file

@ -281,9 +281,9 @@ class StreamManager:
await stream.downloader.stream_finished_event.wait()
stream.update_status(ManagedStream.STATUS_FINISHED)
if self.analytics_manager:
await self.analytics_manager.send_download_finished(
self.loop.create_task(self.analytics_manager.send_download_finished(
stream.download_id, stream.claim_name, stream.sd_hash
)
))
task = self.loop.create_task(_wait_for_stream_finished())
self.update_stream_finished_futs.append(task)
@ -464,9 +464,9 @@ class StreamManager:
)
log.info("started new stream, deleting old one")
if self.analytics_manager:
await self.analytics_manager.send_download_started(
self.loop.create_task(self.analytics_manager.send_download_started(
stream.download_id, parsed_uri.name, claim.source_hash.decode()
)
))
await self.delete_stream(existing[0])
return stream
elif existing:
@ -483,9 +483,9 @@ class StreamManager:
self.node, resolved, file_name, timeout, fee_amount, fee_address
)
if self.analytics_manager:
await self.analytics_manager.send_download_started(
self.loop.create_task(self.analytics_manager.send_download_started(
stream.download_id, parsed_uri.name, claim.source_hash.decode()
)
))
return stream
async def download_stream_from_uri(self, uri, exchange_rate_manager: 'ExchangeRateManager',