I think this should be multiple subscriptions, one for each data product
```python
for data_product_id in in_data_product_ids:
    stream_id = self._get_stream_from_dp(data_product_id)
    subscription_id = self.clients.pubsub_management.create_subscription(name=queue_name, stream_ids=[stream_id])
```