Making local results directory properly

This commit is contained in:
Jake Poznanski 2025-08-13 20:40:04 +00:00
parent 11302feb8c
commit e86267a01c

View File

@ -513,6 +513,8 @@ async def worker(args, work_queue: WorkQueue, semaphore, worker_id):
bucket, key = parse_s3_path(output_final_path)
workspace_s3.upload_file(temp_path, bucket, key)
else:
# Ensure the results directory exists for local workspace
os.makedirs(os.path.dirname(output_final_path), exist_ok=True)
shutil.copyfile(temp_path, output_final_path)
finally:
# Clean up the temporary file