@@ -1342,7 +1342,8 @@ function do_task(to_proc, task_desc)
1342
1342
thunk_id, est_time_util, est_alloc_util, est_occupancy,
1343
1343
scope, Tf, data,
1344
1344
send_result, persist, cache, meta,
1345
- options, propagated, ids, positions, ctx_vars, sch_handle, uid = task_desc
1345
+ options, propagated, ids, positions,
1346
+ ctx_vars, sch_handle, sch_uid = task_desc
1346
1347
ctx = Context (Processor[]; log_sink= ctx_vars. log_sink, profile= ctx_vars. profile)
1347
1348
1348
1349
from_proc = OSProc ()
@@ -1379,7 +1380,7 @@ function do_task(to_proc, task_desc)
1379
1380
lock (TASK_SYNC) do
1380
1381
while true
1381
1382
# Get current time utilization for the selected processor
1382
- time_dict = get! (()-> Dict {Processor,Ref{UInt64}} (), PROCESSOR_TIME_UTILIZATION, uid )
1383
+ time_dict = get! (()-> Dict {Processor,Ref{UInt64}} (), PROCESSOR_TIME_UTILIZATION, sch_uid )
1383
1384
real_time_util = get! (()-> Ref {UInt64} (UInt64 (0 )), time_dict, to_proc)
1384
1385
1385
1386
# Get current allocation utilization and capacity
@@ -1484,6 +1485,7 @@ function do_task(to_proc, task_desc)
1484
1485
if meta
1485
1486
append! (fetched, data[2 : end ])
1486
1487
end
1488
+
1487
1489
f = popfirst! (fetched)
1488
1490
@assert ! (f isa Chunk) " Failed to unwrap thunk function"
1489
1491
fetched_args = Any[]
@@ -1519,8 +1521,8 @@ function do_task(to_proc, task_desc)
1519
1521
result_meta = try
1520
1522
# Set TLS variables
1521
1523
Dagger. set_tls! ((
1522
- sch_uid= uid ,
1523
- sch_handle= sch_handle ,
1524
+ sch_uid,
1525
+ sch_handle,
1524
1526
processor= to_proc,
1525
1527
task_spec= task_desc,
1526
1528
))
0 commit comments