diff --git a/webservice/webservice.py b/webservice/webservice.py index d01b9cdde81c94d5274d891407d59437018521bb..cf175f068146fda2333ac15cd5e167ba877460e7 100644 --- a/webservice/webservice.py +++ b/webservice/webservice.py @@ -523,15 +523,12 @@ async def wait_transfers(wait_runs: List[str], in_folder: str, proposal: str): :param proposal: Proposal number :return: True if all runs transferred, false on timeout """ - all_transfers = [] - logging.debug("Waiting for: propsal %s, runs %s", proposal, wait_runs) # FIXME: this loop should be an asyncio.gather for runnr in wait_runs: rpath = "{}/r{:04d}/".format(in_folder, int(runnr)) transfer_complete = await wait_on_transfer(rpath) - all_transfers.append(transfer_complete) if not transfer_complete: logging.error( Errors.TRANSFER_EVAL_FAILED.format(proposal, runnr)