Skip to content

Commit 2b3558f

Browse files
Remove Copy task
Signed-off-by: Lehmann_Fabian <[email protected]>
1 parent 19b433a commit 2b3558f

File tree

2 files changed

+1
-67
lines changed

2 files changed

+1
-67
lines changed

src/main/java/cws/k8s/scheduler/model/cluster/CopyTask.java

Lines changed: 0 additions & 61 deletions
This file was deleted.

src/main/java/cws/k8s/scheduler/util/TraceObserver.java

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22

33
import cws.k8s.scheduler.model.NodeWithAlloc;
44
import cws.k8s.scheduler.model.Task;
5-
import cws.k8s.scheduler.model.cluster.CopyTask;
65
import lombok.RequiredArgsConstructor;
76
import lombok.Setter;
87

@@ -23,11 +22,7 @@ public void addTask( Task task ) {
2322
}
2423

2524
public void addCopyTask( Task task, NodeWithAlloc node, int phase ) {
26-
if ( task instanceof CopyTask cp ) {
27-
trace.get( cp.getTask() ).addOutputCopiedToNode( node.getName() );
28-
} else {
29-
trace.get( task ).addCopyTask( node.getName(), phase );
30-
}
25+
trace.get( task ).addCopyTask( node.getName(), phase );
3126
}
3227

3328
public void setLabelsOnNode( Task task, List<String> labels ) {

0 commit comments

Comments
 (0)