Skip to content

Commit ac0c1f6

Browse files
committed
fix: correct work function expecting tuple as result
1 parent 09768aa commit ac0c1f6

1 file changed

Lines changed: 3 additions & 4 deletions

File tree

src/mpyflow/library/worker.py

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -173,10 +173,9 @@ async def __reader(self, p_name: str, /) -> int:
173173
async def __work(self, erg: tuple[int, IN], /) -> None:
174174
self.evq.reader_queue.task_done()
175175
ind, data = erg
176-
async for list_worked in self.__wm.workable_in[ind].workable_work(data):
177-
if sum(len(list_elem) for list_elem in list_worked):
178-
await _await_job(self.evq.worker_queue, self.evq.stop_event_error)
179-
await self.evq.worker_queue.put(list_worked)
176+
async for worked in self.__wm.workable_in[ind].workable_work(data):
177+
await _await_job(self.evq.worker_queue, self.evq.stop_event_error)
178+
await self.evq.worker_queue.put(worked)
180179
if self.evq.stop_event_error.is_set():
181180
break
182181

0 commit comments

Comments
 (0)