Skip to content

Commit fd47912

Browse files
committed
stream: Fixes for DTaskTLS
1 parent a804d15 commit fd47912

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/stream.jl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -298,7 +298,7 @@ end
298298
function (dpm::DestPostMigration)(store, unsent)
299299
STREAM_THUNK_ID[] = dpm.thunk_id
300300
@assert !in_task()
301-
tls = DTaskTLS(OSProc(), typemax(UInt64), nothing, [], dpm.cancel_token)
301+
tls = DTaskTLS(OSProc(), typemax(UInt64), nothing, [], dpm.cancel_token, false)
302302
set_tls!(tls)
303303
return dpm.f(store, unsent)
304304
end

0 commit comments

Comments
 (0)