Skip to content

Commit

Permalink
default implementation for clean method
Browse files Browse the repository at this point in the history
thangqp committed Oct 30, 2024
1 parent 1d02bbb commit 243d2be
Showing 1 changed file with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
@@ -153,18 +153,18 @@ public Consumer<Message<String>> consumeRun() {
this.handleNonCancellationException(resultContext, e, rootReporter);
}
} finally {
futures.remove(resultContext.getResultUuid());
cancelComputationRequests.remove(resultContext.getResultUuid());
clean(resultContext.getRunContext());
clean(resultContext);
}
};
}

/**
* perform cleaning some data, e.g. files generated by the computation
* @param runContext The run context of the computation
* Perform cleaning
* @param resultContext The context of the computation
*/
protected void clean(C runContext) {
protected void clean(AbstractResultContext<C> resultContext) {
futures.remove(resultContext.getResultUuid());
cancelComputationRequests.remove(resultContext.getResultUuid());
}

/**

0 comments on commit 243d2be

Please sign in to comment.