From c364db8bb1799152614d987be03ddeebfb684336 Mon Sep 17 00:00:00 2001 From: JinZhou5042 <142265839+JinZhou5042@users.noreply.github.com> Date: Mon, 2 Dec 2024 09:00:55 -0500 Subject: [PATCH] vine: check the availability of staged inputs (#3994) * vine: check the availability of staged inputs * check for created files * revert changes * revert changes * vine: change &= to = * set t->output_received on success * break when result is not success * lint * remove redund code * always do vine_manager_get_output_files --- taskvine/src/manager/vine_manager.c | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/taskvine/src/manager/vine_manager.c b/taskvine/src/manager/vine_manager.c index 79c226baa4..a9ca71d52f 100644 --- a/taskvine/src/manager/vine_manager.c +++ b/taskvine/src/manager/vine_manager.c @@ -1277,10 +1277,12 @@ static int fetch_outputs_from_worker(struct vine_manager *q, struct vine_worker_ default: /* Otherwise get all of the output files. */ if (!t->output_received) { - result &= retrieve_output(q, w, t); - t->output_received = 1; + result = retrieve_output(q, w, t); + if (result == VINE_SUCCESS) { + t->output_received = 1; + } } - result &= vine_manager_get_output_files(q, w, t); + result = vine_manager_get_output_files(q, w, t); break; }