diff --git a/taskvine/src/manager/vine_manager.c b/taskvine/src/manager/vine_manager.c index 7a71fc05ae..db5e1e2d65 100644 --- a/taskvine/src/manager/vine_manager.c +++ b/taskvine/src/manager/vine_manager.c @@ -2933,12 +2933,12 @@ static vine_result_code_t commit_task_group_to_worker(struct vine_manager *q, st int counter = 0; do { - result = commit_task_to_worker(q, w, t); if (counter && (result == VINE_SUCCESS)) { list_remove(q->ready_list, t); // decrement refcount vine_task_delete(t); } + result = commit_task_to_worker(q, w, t); counter++; } while ((l && (t = list_pop_head(l)))); diff --git a/taskvine/src/worker/vine_sandbox.c b/taskvine/src/worker/vine_sandbox.c index 62df00f776..c5133b9a01 100644 --- a/taskvine/src/worker/vine_sandbox.c +++ b/taskvine/src/worker/vine_sandbox.c @@ -56,15 +56,11 @@ vine_cache_status_t vine_sandbox_ensure(struct vine_process *p, struct vine_cach struct vine_process *lp; uint64_t task_id; int found_file = 0; - debug(D_VINE, "iterate proc list"); - debug(D_VINE, "procs table %p", procs_table); ITABLE_ITERATE(procs_table, task_id, lp) { - debug(D_VINE, "index proc"); struct vine_mount *lm; LIST_ITERATE(lp->task->output_mounts, lm) { - debug(D_VINE, "comparing %s and %s", lm->file->cached_name, m->file->cached_name); if (strcmp(lm->file->cached_name, m->file->cached_name) == 0) { found_file = 1; break; @@ -75,7 +71,6 @@ vine_cache_status_t vine_sandbox_ensure(struct vine_process *p, struct vine_cach } } if (found_file) { - debug(D_VINE, "Found file in process queue"); processing++; break; }