Skip to content

Commit

Permalink
remove useless annonces
Browse files Browse the repository at this point in the history
  • Loading branch information
zeyu10 committed Jan 8, 2025
1 parent 8d85eff commit bc614e0
Showing 1 changed file with 0 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -20,20 +20,17 @@
import com.weibo.rill.flow.olympicene.core.model.dag.DAGInfo;
import com.weibo.rill.flow.olympicene.core.model.dag.DAGStatus;
import org.apache.commons.lang3.tuple.Pair;
import org.apache.skywalking.apm.toolkit.trace.Trace;

import java.util.Map;

public interface Stasher {

@Trace(operationName = "Stasher.stash")
boolean stash(String executionId, Pair<TaskInfo, Map<String, Object>> taskInfoToContext);

boolean needStash(String executionId, TaskInfo taskInfo, Map<String, Object> context);

boolean needStashFlow(DAGInfo dagInfo, DAGStatus dagStatus);

@Trace(operationName = "Stasher.stashFlow")
boolean stashFlow(DAGInfo wholeDagInfo, Map<String, Object> dagContext);

}

0 comments on commit bc614e0

Please sign in to comment.