@@ -84,7 +84,6 @@ function AdvancedPS.advance!(trace::LibtaskTrace, isref::Bool=false)
8484 rng = get_rng (trace)
8585 isref ? AdvancedPS. load_state! (rng) : AdvancedPS. save_state! (rng)
8686 AdvancedPS. inc_counter! (rng)
87- set_rng! (trace, rng)
8887 # Move to next step
8988 return Libtask. consume (trace. model. ctask)
9089end
@@ -98,15 +97,10 @@ function AdvancedPS.addreference!(trace::LibtaskTrace)
9897 return trace
9998end
10099
101- function AdvancedPS. update_rng! (trace:: LibtaskTrace )
102- set_rng! (trace, deepcopy (get_rng (trace)))
103- return trace
104- end
105-
106100# Task copying version of fork for Trace.
107101function AdvancedPS. fork (trace:: LibtaskTrace , isref:: Bool = false )
108102 newtrace = copy (trace)
109- AdvancedPS . update_rng ! (newtrace)
103+ set_rng ! (newtrace, deepcopy ( get_rng (newtrace)) )
110104 isref && AdvancedPS. delete_retained! (newtrace. model. f)
111105 isref && delete_seeds! (newtrace)
112106 AdvancedPS. addreference! (newtrace)
@@ -119,7 +113,6 @@ function AdvancedPS.forkr(trace::LibtaskTrace)
119113 rng = get_rng (trace)
120114 newf = AdvancedPS. reset_model (trace. model. f)
121115 Random123. set_counter! (rng, 1 )
122- trace. rng = rng
123116
124117 ctask = Libtask. TapedTask (TapedGlobals (rng, get_other_global (trace)), newf)
125118 new_tapedmodel = AdvancedPS. LibtaskModel (newf, ctask)
@@ -143,7 +136,7 @@ function AdvancedPS.observe(dist::Distributions.Distribution, x)
143136end
144137
145138"""
146- AbstractMCMC interface. We need libtask to sample from arbitrary callable AbstractModelext
139+ AbstractMCMC interface. We need libtask to sample from arbitrary callable AbstractModel
147140"""
148141
149142function AbstractMCMC. step (
0 commit comments