Fix incorrect arguments

This commit is contained in:
Erik Johnston 2018-08-23 14:46:46 +01:00
parent 507a6d7e42
commit ba5d7856d1

View file

@ -124,7 +124,7 @@ class _S3DownloadThread(threading.Thread):
producer = _S3Responder() producer = _S3Responder()
reactor.callFromThread(self.deferred.callback, producer) reactor.callFromThread(self.deferred.callback, producer)
_stream_to_producer(self.deferred, resp["Body"], timeout=90.) _stream_to_producer(reactor, producer, resp["Body"], timeout=90.)
def _stream_to_producer(reactor, producer, body, status=None, timeout=None): def _stream_to_producer(reactor, producer, body, status=None, timeout=None):