Skip to content

Commit

Permalink
removed ! as schedule algorithm is not mutating
Browse files Browse the repository at this point in the history
  • Loading branch information
m-fila committed Jul 10, 2024
1 parent ea3a127 commit 10f20ee
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions src/scheduling.jl
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ function is_terminating_alg(graph::AbstractGraph, vertex_id::Int)
all(is_terminating, successor_dataobjects)
end

function schedule_algorithm!(graph::MetaDiGraph, vertex_id::Int)
function schedule_algorithm(graph::MetaDiGraph, vertex_id::Int)
incoming_data = get_promises(graph, inneighbors(graph, vertex_id))
algorithm = MockupAlgorithm(graph, vertex_id)
Dagger.@spawn algorithm(incoming_data...)
Expand All @@ -67,7 +67,7 @@ function schedule_graph(graph::MetaDiGraph)
terminating_results = []

for vertex_id in intersect(sorted_vertices, alg_vertices)
res = schedule_algorithm!(graph, vertex_id)
res = schedule_algorithm(graph, vertex_id)
set_prop!(graph, vertex_id, :res_data, res)
for v in outneighbors(graph, vertex_id)
set_prop!(graph, v, :res_data, res)
Expand All @@ -80,9 +80,9 @@ function schedule_graph(graph::MetaDiGraph)
end

function schedule_graph_with_notify(graph::MetaDiGraph,
notifications::RemoteChannel,
graph_name::String,
graph_id::Int)
notifications::RemoteChannel,
graph_name::String,
graph_id::Int)
terminating_results = schedule_graph(graph)

Dagger.@spawn notify_graph_finalization(notifications, graph_name, graph_id, terminating_results...)
Expand Down

0 comments on commit 10f20ee

Please sign in to comment.