more flake8 fixes
This commit is contained in:
parent
48d740406b
commit
d65fcaa1a6
|
@ -20,7 +20,8 @@ def make_dilator():
|
|||
eq = EventualQueue(clock)
|
||||
term = mock.Mock(side_effect=lambda: True) # one write per Eventual tick
|
||||
|
||||
def term_factory(): return term
|
||||
def term_factory():
|
||||
return term
|
||||
coop = Cooperator(terminationPredicateFactory=term_factory,
|
||||
scheduler=eq.eventually)
|
||||
send = mock.Mock()
|
||||
|
|
|
@ -24,7 +24,8 @@ def make_outbound():
|
|||
eq = EventualQueue(clock)
|
||||
term = mock.Mock(side_effect=lambda: True) # one write per Eventual tick
|
||||
|
||||
def term_factory(): return term
|
||||
def term_factory():
|
||||
return term
|
||||
coop = Cooperator(terminationPredicateFactory=term_factory,
|
||||
scheduler=eq.eventually)
|
||||
o = Outbound(m, coop)
|
||||
|
@ -567,7 +568,8 @@ def make_pushpull(pauses):
|
|||
eq = EventualQueue(clock)
|
||||
term = mock.Mock(side_effect=lambda: True) # one write per Eventual tick
|
||||
|
||||
def term_factory(): return term
|
||||
def term_factory():
|
||||
return term
|
||||
coop = Cooperator(terminationPredicateFactory=term_factory,
|
||||
scheduler=eq.eventually)
|
||||
pp = PullToPush(p, unregister, coop)
|
||||
|
|
|
@ -12,8 +12,8 @@ import mock
|
|||
from .. import (__version__, _allocator, _boss, _code, _input, _key, _lister,
|
||||
_mailbox, _nameplate, _order, _receive, _rendezvous, _send,
|
||||
_terminator, errors, timing)
|
||||
from .._interfaces import (IAllocator, IBoss, ICode, IDilator, IInput, IKey, ILister,
|
||||
IMailbox, INameplate, IOrder, IReceive,
|
||||
from .._interfaces import (IAllocator, IBoss, ICode, IDilator, IInput, IKey,
|
||||
ILister, IMailbox, INameplate, IOrder, IReceive,
|
||||
IRendezvousConnector, ISend, ITerminator, IWordlist)
|
||||
from .._key import derive_key, derive_phase_key, encrypt_data
|
||||
from ..journal import ImmediateJournal
|
||||
|
|
Loading…
Reference in New Issue
Block a user