Lints

src/allmydata/client.py

@@ -22,7 +22,6 @@ from zope.interface import implementer
 from twisted.plugin import (
     getPlugins,
 )
-from twisted.internet.interfaces import IReactorFromThreads
 from twisted.internet import reactor, defer
 from twisted.application import service
 from twisted.application.internet import TimerService

src/allmydata/mutable/publish.py

@@ -14,7 +14,7 @@ import os, time
 from io import BytesIO
 from itertools import count
 from zope.interface import implementer
-from twisted.internet import defer, reactor
+from twisted.internet import defer
 from twisted.python import failure
 
 from allmydata.crypto import aes

src/allmydata/mutable/retrieve.py

@@ -7,7 +7,7 @@ import time
 
 from itertools import count
 from zope.interface import implementer
-from twisted.internet import defer, reactor
+from twisted.internet import defer
 from twisted.python import failure
 from twisted.internet.interfaces import IPushProducer, IConsumer
 from foolscap.api import eventually, fireEventually, DeadReferenceError, \

src/allmydata/storage/http_client.py

@@ -39,7 +39,6 @@ from twisted.internet.interfaces import (
     IOpenSSLClientConnectionCreator,
     IReactorTime,
     IDelayedCall,
-    IReactorFromThreads,
 )
 from twisted.internet.ssl import CertificateOptions
 from twisted.protocols.tls import TLSMemoryBIOProtocol
@@ -438,7 +437,7 @@ class StorageClient(object):
     _swissnum: bytes
     _treq: Union[treq, StubTreq, HTTPClient]
     _pool: HTTPConnectionPool
-    _clock: Union[IReactorTime, IReactorFromThreads]
+    _clock: IReactorTime
     # Are we running unit tests?
     _analyze_response: Callable[[IResponse], None] = lambda _: None
 

src/allmydata/test/test_util.py

@@ -18,7 +18,6 @@ import json
 from threading import current_thread
 
 from twisted.trial import unittest
-from twisted.internet import reactor
 from foolscap.api import Violation, RemoteException
 
 from allmydata.util import idlib, mathutil

src/allmydata/util/cputhreadpool.py

@@ -24,7 +24,6 @@ from unittest import TestCase
 from twisted.python.threadpool import ThreadPool
 from twisted.internet.defer import Deferred, maybeDeferred
 from twisted.internet.threads import deferToThreadPool
-from twisted.internet.interfaces import IReactorFromThreads
 from twisted.internet import reactor
 
 _CPU_THREAD_POOL = ThreadPool(minthreads=0, maxthreads=os.cpu_count(), name="TahoeCPU")