Skip to content

Commit

Permalink
update readme, fix worker warning, fix concurrency defaults (#44)
Browse files Browse the repository at this point in the history
* silence warning rmprocs: proc 1 not removed

* change concurrency default to 1

* mention dagger in readme
  • Loading branch information
m-fila authored Aug 28, 2024
1 parent fe2e86a commit a55a303
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 4 deletions.
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
[![test](https://github.com/key4hep/key4hep-julia-fwk/actions/workflows/test.yml/badge.svg)](https://github.com/key4hep/key4hep-julia-fwk/actions/workflows/test.yml)
[![Aqua QA](https://raw.githubusercontent.com/JuliaTesting/Aqua.jl/master/badge.svg)](https://github.com/JuliaTesting/Aqua.jl)

Demonstrator project for HEP data-processing framework in Julia
Demonstrator project for HEP data-processing framework in Julia and based on [Dagger.jl](https://github.com/JuliaParallel/Dagger.jl)


## Getting started
Expand Down
8 changes: 5 additions & 3 deletions bin/schedule.jl
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ function parse_args()
"--max-concurrent"
help = "Number of slots for graphs to be scheduled concurrently"
arg_type = Int
default = 3
default = 1

"--dot-trace"
help = "Output graphviz dot file for execution logs graph"
Expand Down Expand Up @@ -65,6 +65,8 @@ end

if abspath(PROGRAM_FILE) == @__FILE__
main()
rmprocs!(Dagger.Sch.eager_context(), workers())
rmprocs(workers())
if length(workers()) > 1
rmprocs!(Dagger.Sch.eager_context(), workers())
rmprocs(workers())
end
end

0 comments on commit a55a303

Please sign in to comment.