@@ -84,7 +84,6 @@ function AdvancedPS.advance!(trace::LibtaskTrace, isref::Bool=false)
84
84
rng = get_rng (trace)
85
85
isref ? AdvancedPS. load_state! (rng) : AdvancedPS. save_state! (rng)
86
86
AdvancedPS. inc_counter! (rng)
87
- set_rng! (trace, rng)
88
87
# Move to next step
89
88
return Libtask. consume (trace. model. ctask)
90
89
end
@@ -98,15 +97,10 @@ function AdvancedPS.addreference!(trace::LibtaskTrace)
98
97
return trace
99
98
end
100
99
101
- function AdvancedPS. update_rng! (trace:: LibtaskTrace )
102
- set_rng! (trace, deepcopy (get_rng (trace)))
103
- return trace
104
- end
105
-
106
100
# Task copying version of fork for Trace.
107
101
function AdvancedPS. fork (trace:: LibtaskTrace , isref:: Bool = false )
108
102
newtrace = copy (trace)
109
- AdvancedPS . update_rng ! (newtrace)
103
+ set_rng ! (newtrace, deepcopy ( get_rng (newtrace)) )
110
104
isref && AdvancedPS. delete_retained! (newtrace. model. f)
111
105
isref && delete_seeds! (newtrace)
112
106
AdvancedPS. addreference! (newtrace)
@@ -119,7 +113,6 @@ function AdvancedPS.forkr(trace::LibtaskTrace)
119
113
rng = get_rng (trace)
120
114
newf = AdvancedPS. reset_model (trace. model. f)
121
115
Random123. set_counter! (rng, 1 )
122
- trace. rng = rng
123
116
124
117
ctask = Libtask. TapedTask (TapedGlobals (rng, get_other_global (trace)), newf)
125
118
new_tapedmodel = AdvancedPS. LibtaskModel (newf, ctask)
@@ -143,7 +136,7 @@ function AdvancedPS.observe(dist::Distributions.Distribution, x)
143
136
end
144
137
145
138
"""
146
- AbstractMCMC interface. We need libtask to sample from arbitrary callable AbstractModelext
139
+ AbstractMCMC interface. We need libtask to sample from arbitrary callable AbstractModel
147
140
"""
148
141
149
142
function AbstractMCMC. step (
0 commit comments