also make sure evaluation is always awaited for

By waiting for eval_proc, we didn't started evaluation itself
This commit is contained in:
Jörg Thalheim 2023-09-23 14:23:06 +02:00
parent acd8ff4244
commit c0eb735577

View File

@ -705,9 +705,14 @@ async def run(stack: AsyncExitStack, opts: Options) -> int:
upload_queue: QueueWithContext[Build | StopTask] = QueueWithContext()
download_queue: QueueWithContext[Build | StopTask] = QueueWithContext()
evaluation = run_evaluation(eval_proc, build_queue, failures[EvalFailure], opts)
async with TaskGroup() as tg:
tasks = []
tasks.append(
tg.create_task(
run_evaluation(eval_proc, build_queue, failures[EvalFailure], opts)
)
)
evaluation = tasks[0]
build_output = sys.stdout.buffer
if pipe:
build_output = pipe.write_file