Skip to content

Commit a10dcb8

Browse files
committed
fix bug in chunking
1 parent 0ded77a commit a10dcb8

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/coreloop.jl

+2-2
Original file line numberDiff line numberDiff line change
@@ -124,21 +124,21 @@ function _chunk_batches(batches, filt, fg, workers)
124124
chunks = Vector{Any}(undef, workers)
125125

126126
eqs_per_worker = total_eqs / workers
127-
# println("Total eqs: $total_eqs in $Ncomp components, eqs per worker: $eqs_per_worker ($fg)")
127+
# println("\nTotal eqs: $total_eqs in $Ncomp components, eqs per worker: $eqs_per_worker ($fg)")
128128
bi = 1
129129
ci = 1
130130
assigned = 0
131131
eqs_assigned = 0
132132
for w in 1:workers
133133
# println("Assign worker $w: goal: $eqs_per_worker")
134134
chunk = Vector{Any}()
135-
ci_start = ci
136135
eqs_in_worker = 0
137136
assigned_in_worker = 0
138137
while assigned < Ncomp
139138
batch = batches[bi]
140139

141140
if filt(batch) #only process if the batch is not filtered out
141+
ci_start = ci
142142
Neqs = _N_eqs(fg, batch)
143143
stop_collecting = false
144144
while true

0 commit comments

Comments
 (0)