Skip to content
Snippets Groups Projects
Commit a2c6fa10 authored by Jean-Paul Calderone's avatar Jean-Paul Calderone
Browse files

be sure to wait on the now-async recover method result

Supposedly the method cannot fail so we just drop the Deferred on the floor.
It feels a little off but maybe it's okay.
parent 2215f16e
No related branches found
No related tags found
1 merge request!295Implement a limited form of the "recovery" endpoint of the replication/recovery design
...@@ -24,6 +24,7 @@ In the future it should also allow users to read statistics about token usage. ...@@ -24,6 +24,7 @@ In the future it should also allow users to read statistics about token usage.
from json import loads from json import loads
import attr import attr
from twisted.internet.defer import ensureDeferred
from twisted.logger import Logger from twisted.logger import Logger
from twisted.web.http import BAD_REQUEST from twisted.web.http import BAD_REQUEST
from twisted.web.resource import ErrorPage, IResource, NoResource, Resource from twisted.web.resource import ErrorPage, IResource, NoResource, Resource
...@@ -208,7 +209,7 @@ class RecoverResource(Resource): ...@@ -208,7 +209,7 @@ class RecoverResource(Resource):
try: try:
self.store.call_if_empty( self.store.call_if_empty(
lambda conn: self.recoverer.recover(cap_str, conn), lambda conn: ensureDeferred(self.recoverer.recover(cap_str, conn)),
) )
except NotEmpty: except NotEmpty:
request.setResponseCode(409) request.setResponseCode(409)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment