HF RL Explorer

You are working on the ag2ai/faststream repository. The source code is checked out at /testbed at commit…

You are working on the ag2ai/faststream repository. The source code is checked out at /testbed at commit…: a task in SWE-Lego-RL-2699 (Harbor dataset). @broker.subscriber(partitions= TopicPartition("test", 1) ) async def handler(): ...

The task

@broker.subscriber(partitions=[TopicPartition("test", 1)]) async def handler(): ...

Part of Lego-X/Lego-RL-2699.