|
|
|
@ -411,7 +411,7 @@ class CliRunnerCallbacks(DefaultRunnerCallbacks):
|
|
|
|
self._async_notified[jid] = clock + 1
|
|
|
|
self._async_notified[jid] = clock + 1
|
|
|
|
if self._async_notified[jid] > clock:
|
|
|
|
if self._async_notified[jid] > clock:
|
|
|
|
self._async_notified[jid] = clock
|
|
|
|
self._async_notified[jid] = clock
|
|
|
|
display("<job %s> polling, %ss remaining" % (jid, clock), runner=self.runner)
|
|
|
|
display("<job %s> polling on %s, %ss remaining" % (jid, host, clock), runner=self.runner)
|
|
|
|
super(CliRunnerCallbacks, self).on_async_poll(host, res, jid, clock)
|
|
|
|
super(CliRunnerCallbacks, self).on_async_poll(host, res, jid, clock)
|
|
|
|
|
|
|
|
|
|
|
|
def on_async_ok(self, host, res, jid):
|
|
|
|
def on_async_ok(self, host, res, jid):
|
|
|
|
|