Skip to content

Commit

Permalink
Filter null in post scheduling
Browse files Browse the repository at this point in the history
Signed-off-by: Lehmann_Fabian <[email protected]>
  • Loading branch information
Lehmann-Fabian committed Jan 20, 2024
1 parent f4e9240 commit fd30987
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -156,12 +156,14 @@ void postScheduling( List<Task> unscheduledTasks, final Map<NodeWithAlloc, Requi
if ( inputsOfTask == null ) return null;
return getDataOnNode( task, inputsOfTask, allNodes, readyTasksPerNode );
} )
.filter( Objects::nonNull )
.filter( TaskStat::canStartSomewhere )
.sequential()
.forEach( taskStats::add );

taskStats.setComparator( phaseTwoComparator );


final CurrentlyCopying planedToCopy = new CurrentlyCopying();
//Fill the currently available resources as fast as possible: start the tasks with the least data missing on a node.
nodeTaskFilesAlignments = capacityAvailableToNode
Expand Down

0 comments on commit fd30987

Please sign in to comment.