LBRYCommunity/lbry-sdk
1
0
Fork 1
Code Issues Pull requests Projects Releases 282 Packages Wiki Activity

Fix import issues in DaemonServer.py

Browse source
This commit is contained in:
Alex Liebowitz 2016-10-02 02:50:17 -04:00
parent 2253943eba
commit 04ced2e975
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
lbrynet/lbrynet_daemon/DaemonServer.py
View file

@ -11,11 +11,12 @@ import cgi
from appdirs import user_data_dir from appdirs import user_data_dir
from twisted.web import server, static, resource from twisted.web import server, static, resource
from twisted.internet import abstract, defer, interfaces, error, reactor, task, threads from twisted.internet import abstract, defer, interfaces, error, reactor, task
from zope.interface import implementer from zope.interface import implementer
from lbrynet.lbrynet_daemon.Daemon import Daemon from lbrynet.lbrynet_daemon.Daemon import Daemon
from lbrynet.lbryfilemanager.EncryptedFileDownloader import ManagedEncryptedFileDownloader
from lbrynet.conf import API_ADDRESS, UI_ADDRESS, DEFAULT_UI_BRANCH, LOG_FILE_NAME from lbrynet.conf import API_ADDRESS, UI_ADDRESS, DEFAULT_UI_BRANCH, LOG_FILE_NAME
@ -279,7 +280,7 @@ class EncryptedFileStreamer(object):
if not self._running: if not self._running:
return return
if stream_status != ManagedLBRYFileDownloader.STATUS_FINISHED: if stream_status != ManagedEncryptedFileDownloader.STATUS_FINISHED:
self._deferred.addCallback(lambda _: task.deferLater(reactor, self.new_data_check_interval, self._check_for_new_data)) self._deferred.addCallback(lambda _: task.deferLater(reactor, self.new_data_check_interval, self._check_for_new_data))
else: else:
self.stopProducing() self.stopProducing()