async def METHOD_NAME(self, client):
    async with client:
        ingestions = client.list_data_feed_ingestion_status(
            data_feed_id=self.data_feed_id,
            start_time=datetime.datetime(2021, 8, 9, tzinfo=timezone.utc),
            end_time=datetime.datetime(2021, 9, 16, tzinfo=timezone.utc),
        )
        ingestions_list = []
        async for status in ingestions:
            ingestions_list.append(status)
        assert len(list(ingestions_list)) > 0