Skip to content

Commit

Permalink
fix formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
m-fila committed Aug 20, 2024
1 parent 837ae10 commit dc42d51
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
6 changes: 3 additions & 3 deletions bin/schedule.jl
Original file line number Diff line number Diff line change
Expand Up @@ -50,9 +50,9 @@ function main()
fast = args["fast"]

@time "Pipeline execution" FrameworkDemo.run_pipeline(graph;
event_count = event_count,
max_concurrent = max_concurrent,
fast = fast)
event_count = event_count,
max_concurrent = max_concurrent,
fast = fast)

if !isnothing(args["dot-trace"])
logs = Dagger.fetch_logs!()
Expand Down
6 changes: 3 additions & 3 deletions src/scheduling.jl
Original file line number Diff line number Diff line change
Expand Up @@ -84,9 +84,9 @@ function calibrate_crunch(; fast::Bool = false)::Union{Dagger.Shard, Nothing}
end

function run_pipeline(graph::MetaDiGraph;
event_count::Int,
max_concurrent::Int,
fast::Bool = false)
event_count::Int,
max_concurrent::Int,
fast::Bool = false)
graphs_tasks = Dict{Int, Dagger.DTask}()
notifications = RemoteChannel(() -> Channel{Int}(max_concurrent))
coefficients = FrameworkDemo.calibrate_crunch(; fast = fast)
Expand Down

0 comments on commit dc42d51

Please sign in to comment.