From 724f665753514da1890adcf9c61045512e7d7d66 Mon Sep 17 00:00:00 2001 From: Luke Murphy Date: Tue, 13 Oct 2020 13:11:16 +0200 Subject: [PATCH] Always remove at this point --- dropship/wormhole.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/dropship/wormhole.py b/dropship/wormhole.py index 4e7107a..f0018ea 100644 --- a/dropship/wormhole.py +++ b/dropship/wormhole.py @@ -30,9 +30,10 @@ async def wormhole_recv(code, parent, task_status=TASK_STATUS_IGNORED): task_status.started((scope,)) log.info(f"wormhole_recv: now starting receiving process ({code})") await process.wait() - parent._remove_pending_transfer(code) log.info(f"wormhole_recv: succesfully received ({code})") if scope.cancel_called: process.terminate() log.info(f"wormhole_recv: succesfully terminated process ({code})") + + parent._remove_pending_transfer(code)