[Bug]: Typo __int__ in MilvusBaseRanker and wrong type hint on milvus_search.join_fn #40474

What happened?

Two small issues in sdks/python/apache_beam/ml/rag/enrichment/milvus_search.py:

1. MilvusBaseRanker defines __int__ instead of __init__

class MilvusBaseRanker:
  def __int__(self):
    return

This looks like a typo for __init__. As written, it defines the integer conversion hook, so int(ranker) would raise TypeError: __int__ returned non-int (type NoneType). Since the base class has no state to initialize, the method can simply be removed.

2. join_fn is annotated with Embedding but receives an EmbeddableItem

def join_fn(left: Embedding, right: dict[str, Any]) -> Embedding:
  left.metadata['enrichment_data'] = right
  return left

The handler's input/output type is EmbeddableItem (InputT/OutputT in the same module), and Embedding has no metadata attribute. The annotation should be EmbeddableItem for both the parameter and the return type.

Neither issue changes runtime behavior for current users; the fix is a small cleanup. I plan to send a PR.

Issue Priority

Priority: 3 (minor)

Issue Components

• Component: Python SDK
• Component: Java SDK
• Component: Go SDK
• Component: Typescript SDK
• Component: IO connector
• Component: Beam YAML
• Component: Beam examples
• Component: Beam playground
• Component: Beam katas
• Component: Website
• Component: Infrastructure
• Component: Spark Runner
• Component: Flink Runner
• Component: Prism Runner
• Component: Twister2 Runner
• Component: Hazelcast Jet Runner
• Component: Google Cloud Dataflow Runner