Important

Refactor evaluation logic by introducingprocess_batch() to handle batch processing of datapoints and variants, improving modularity and reducing code duplication.

• Behavior:
  • Introducesprocess_batch() inlib.rs to handle batches of datapoints and variants.
  • process_batch() is used inrun_evaluation_core_streaming() for single variant processing and will be used for top-k variant selection.
• Infrastructure:
  • AddsProcessBatchParams,DatapointVariantResult,DatapointVariantError, andBatchItemResult structs to support batch processing.
  • Implementscollect_batch_result() to convertJoinSet results intoBatchItemResult.
• Misc:
  • Removes redundant task spawning logic fromrun_evaluation_core_streaming() and replaces it withprocess_batch() call.

^{This description was created by forde4a614. You cancustomize this summary. It will automatically update as commits are pushed.}