Skip to content

Commit

Permalink
v0.1.2: update compat DataFrames and Pipelines
Browse files Browse the repository at this point in the history
  • Loading branch information
cihga39871 committed Jul 25, 2021
1 parent c12873e commit ae8db70
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 14 deletions.
6 changes: 3 additions & 3 deletions Project.toml
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
name = "JobSchedulers"
uuid = "eeff360b-c02d-44d3-ab26-4013c616a17e"
authors = ["Jiacheng Chuan <[email protected]>"]
version = "0.1.1"
version = "0.1.2"

[deps]
DataFrames = "a93c6f00-e57d-5684-b7b6-d8193f3e46c0"
Expand All @@ -13,7 +13,7 @@ Test = "8dfed614-e22c-5e08-85e1-65c5234f0b40"

[compat]
julia = "1.0"
DataFrames = "0.22"
DataFrames = "1.2"
JLD2 = "0.4"
JSON = "0.21"
Pipelines = "0.3"
Pipelines = "0.4"
20 changes: 9 additions & 11 deletions test/runtests.jl
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ submit!(job)
job = Job(@task(begin; sleep(2); println("midpriority"); end), name="mid_priority", priority = 15)
submit!(job)
for i in 1:20
job = Job(@task(begin; sleep(2); println(i); end), name="$i", priority = 20)
local job = Job(@task(begin; sleep(2); println(i); end), name="$i", priority = 20)
submit!(job)
end

Expand All @@ -36,30 +36,27 @@ cancel!(jobx)


job2 = Job(@task(begin
t = now()
while true
if (now() - t).value > 1000
println(t)
t = now()
end
println(now())
sleep(1)
end
end), name="to_cancel", priority = 20)
submit!(job2)
cancel!(job2)

submit!(job2) # cannot resubmit
submit!(job) # cannot resubmit
submit!(job2)
@test_logs (:error,) submit!(job2) # cannot resubmit
@test_logs (:error,) submit!(job) # cannot resubmit
@test_logs (:error,) submit!(job2)


### dependency
dep1 = Job(@task(begin
sleep(10)
sleep(2)
println("dep1 ok")
end), name="dep1", priority = 20)

dep2 = Job(@task(begin
sleep(15)
sleep(3)
println("dep2 ok")
end), name="dep2", priority = 20)

Expand All @@ -72,6 +69,7 @@ submit!(dep1)
submit!(dep2)
submit!(job_with_dep)

sleep(15)

### set backup
rm("/tmp/jl_job_scheduler_backup", force=true)
Expand Down

0 comments on commit ae8db70

Please sign in to comment.