Skip to content

Commit bf11785

Browse files
Tests
1 parent af4cf44 commit bf11785

File tree

2 files changed

+15
-6
lines changed

2 files changed

+15
-6
lines changed

test/container.jl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,7 @@
121121
val::Ref{Int}
122122
end
123123

124-
function (model::Model)(rng::Random.AbstractRNG)
124+
function (model::Model)()
125125
t = [0]
126126
while true
127127
model.val[] += 1
@@ -149,7 +149,7 @@
149149
@testset "current trace" begin
150150
struct TaskIdModel <: AdvancedPS.AbstractGenericModel end
151151

152-
function (model::TaskIdModel)(rng::Random.AbstractRNG)
152+
function (model::TaskIdModel)()
153153
# Just print the task it's running in
154154
id = objectid(AdvancedPS.current_trace())
155155
return Libtask.produce(id)

test/smc.jl

Lines changed: 13 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -28,14 +28,16 @@
2828
NormalModel() = new()
2929
end
3030

31-
function (m::NormalModel)(rng::Random.AbstractRNG)
31+
function (m::NormalModel)()
3232
# First latent variable.
33+
rng = Libtask.get_dynamic_scope()
3334
m.a = a = rand(rng, Normal(4, 5))
3435

3536
# First observation.
3637
AdvancedPS.observe(Normal(a, 2), 3)
3738

3839
# Second latent variable.
40+
rng = Libtask.get_dynamic_scope()
3941
m.b = b = rand(rng, Normal(a, 1))
4042

4143
# Second observation.
@@ -52,8 +54,11 @@
5254
FailSMCModel() = new()
5355
end
5456

55-
function (m::FailSMCModel)(rng::Random.AbstractRNG)
57+
function (m::FailSMCModel)()
58+
rng = Libtask.get_dynamic_scope()
5659
m.a = a = rand(rng, Normal(4, 5))
60+
61+
rng = Libtask.get_dynamic_scope()
5762
m.b = b = rand(rng, Normal(a, 1))
5863
if a >= 4
5964
AdvancedPS.observe(Normal(b, 2), 1.5)
@@ -75,8 +80,9 @@
7580
TestModel() = new()
7681
end
7782

78-
function (m::TestModel)(rng::Random.AbstractRNG)
83+
function (m::TestModel)()
7984
# First hidden variables.
85+
rng = Libtask.get_dynamic_scope()
8086
m.a = rand(rng, Normal(0, 1))
8187
m.x = x = rand(rng, Bernoulli(1))
8288
m.b = rand(rng, Gamma(2, 3))
@@ -85,6 +91,7 @@
8591
AdvancedPS.observe(Bernoulli(x / 2), 1)
8692

8793
# Second hidden variable.
94+
rng = Libtask.get_dynamic_scope()
8895
m.c = rand(rng, Beta())
8996

9097
# Second observation.
@@ -159,10 +166,12 @@
159166
DummyModel() = new()
160167
end
161168

162-
function (m::DummyModel)(rng)
169+
function (m::DummyModel)()
170+
rng = Libtask.get_dynamic_scope()
163171
m.a = rand(rng, Normal())
164172
AdvancedPS.observe(Normal(), m.a)
165173

174+
rng = Libtask.get_dynamic_scope()
166175
m.b = rand(rng, Normal())
167176
return AdvancedPS.observe(Normal(), m.b)
168177
end

0 commit comments

Comments
 (0)