fix: meta-reference parallel utils bug, use isinstance not equality

This commit is contained in:
Ashwin Bharambe 2025-04-24 11:27:49 -07:00
parent 70488abe9c
commit a5d6ab16b2

View file

@ -231,7 +231,7 @@ def worker_process_entrypoint(
while True: while True:
try: try:
task = req_gen.send(result) task = req_gen.send(result)
if isinstance(task, str) and task == EndSentinel(): if isinstance(task, EndSentinel):
break break
assert isinstance(task, TaskRequest) assert isinstance(task, TaskRequest)