Невозможно отменить цепочку Twisted Deferred (AlreadyCalledError) - PullRequest
Новая
       33

Невозможно отменить цепочку Twisted Deferred (AlreadyCalledError)

0 голосов
/ 31 мая 2019

Я пытаюсь отменить цепочку Deferred (основной) всякий раз, когда какой-либо цепочечный отложенный (дочерний) вызывает ошибку.Но я получаю AlreadyCalledError, и цепочка продолжает свою работу.

Вот код: 

from twisted.internet import defer

def asyncText(s, okCallback, errCallback):
  deferred = defer.Deferred()
  deferred.addCallbacks(okCallback, errCallback)
  if s.find('STOP')>=0:
    deferred.errback(ValueError('You are trying to print the unprintable :('))
  else:
    deferred.callback(s)
  return deferred

def asyncChain():
  texts = ['Hello StackOverflow,', 
           'this is an example of Twisted.chainDeferred()',
           'which is raising an AlreadyCalledError',
           'when I try to cancel() it.',
           'STOP => I will raise error and should stop the main deferred',
           'Best regards'
           ]

  mainDeferred= defer.Deferred()

  for text in texts: 
    def onSuccess(res):
      print('>> {}'.format(res))

    def onError(err):
      print('Error!! {}'.format(err))
      mainDeferred.cancel()

    d = asyncText(text, onSuccess, onError)
    mainDeferred.chainDeferred(d)

А вот вывод: 

>>> asyncChain()
- Hello StackOverflow,
- this is an example of Twisted.chainDeferred()
- which is raising an AlreadyCalledError
- when I try to cancel() it.
Error!! [Failure instance: Traceback (failure with no frames): <class 'ValueError'>: You are trying to print the unprintable :(
]
- Best regards
Unhandled error in Deferred:

Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File ".../test.py", line 1, in asyncChain
    mainDeferred.chainDeferred(d)
  File ".../.venvs/p3/lib/python3.6/site-packages/twisted/internet/defer.py", line 435, in chainDeferred
    return self.addCallbacks(d.callback, d.errback)
  File ".../.venvs/p3/lib/python3.6/site-packages/twisted/internet/defer.py", line 311, in addCallbacks
    self._runCallbacks()
--- <exception caught here> ---
  File ".../.venvs/p3/lib/python3.6/site-packages/twisted/internet/defer.py", line 654, in _runCallbacks
    current.result = callback(current.result, *args, **kw)
  File ".../.venvs/p3/lib/python3.6/site-packages/twisted/internet/defer.py", line 501, in errback
    self._startRunCallbacks(fail)
  File ".../.venvs/p3/lib/python3.6/site-packages/twisted/internet/defer.py", line 561, in _startRunCallbacks
    raise AlreadyCalledError
twisted.internet.defer.AlreadyCalledError:

Iтакже пытался использовать canceller, например так: 

def asyncOnCancel(d):
  print('------ cancel() called ------')
  d.errback(ValueError('chain seems to be cancelled!'))
def asyncChainOnError(err):
  print('------ ERROR ON Chain {} ------'.format(err))

...
  mainDeferred= defer.Deferred(canceller= asyncOnCancel)
  mainDeferred.addErrback(asyncChainOnError)
...

Но результат тот же.

Я также пытался отложить дочерние вызовы .callback(s) или вызвать их после .chainDeferred().Но я всегда получаю одно и то же поведение.

  • Действительно ли возможно отменить цепочку Deferred (и получить цепочку дочерних отсрочек для отмены тоже)?
  • Почему я получаю это AlreadyCalledError?

Я использую Python 3.6.6 и Twisted 18.9.0.

Спасибо!

******* РЕДАКТИРОВАТЬ *******

После того, как Жан-Поль ответит и заметит, что .chainDeferred() не то, что мне нужно, я положу здесьболее ясный способ, что я хочу (и как я, в конце концов, сделал это).

То, что я хочу, было гораздо проще: запустить несколько отложенных, «синхронно» (они должны ждать, пока предыдущий получитзакончили), хотя им не нужно делиться своими результатами.В случае неудачи остальные из них не выполняются.

Оказывается, это довольно легко сделать с помощью @defer.inlineCallbacks и yield.Вот пример: 

def asyncText(s):
  deferred = defer.Deferred()
  if s.find('STOP') >= 0:
    deferred.callback(True)
  else:
    deferred.callback(False)
  return deferred

@defer.inlineCallbacks
def asyncChain():
  texts = ['Hello StackOverflow,',
           'this is a simpler way to explain the question.',
           'I need no chainDeferred(). I need no .cancel().',
           'I just need inlineCallbacks decorator.',
           'STOP',
           'Yeah I will not be printed'
           ]
  for text in texts:
    stopHere = yield asyncText(text)
    if stopHere:
      break
    print('- {}'.format(text))

deferred= asyncChain()

>>> asyncChain()
- Hello StackOverflow,
- this is a simpler way to explain the question.
- I need no chainDeferred(). I need no .cancel().
- I just need inlineCallbacks decorator.

1 Ответ

1 голос
/ 31 мая 2019

Непонятно, что вы на самом деле пытаетесь сделать, но я думаю, что ваша цепь отстала от того, что вы ожидаете: 

    d = asyncText(text, onSuccess, onError)
    mainDeferred.chainDeferred(d)

d уже срабатывает, когда возвращается asyncText. Но mainDeferred.chainDeferred(d) означает «когда mainDeferred сработает, передайте свой результат в d». Поскольку d уже запущен, это недействительно. Отложенный может стрелять только один раз.

Возможно, вы имели в виду d.chainDeferred(mainDeferred) вместо этого. Затем, «когда d срабатывает, передайте его результат mainDeferred».

Тем не менее, проблема все еще существует, поскольку, если вы соедините d с mainDeferred, тогда не имеет смысла отменять mainDeferred в обратном вызове на d. Результат будет распространяться от d до mainDeferred, потому что они связаны. Отмена не является необходимой или полезной.

...