async def METHOD_NAME(self, producer):
    assert producer in self.producers
    if producer not in self._producer_procs:
        with open(f"producer_{producer}.logs", "a") as f:
            print(f"Starting producer: {producer}")
            self._producer_procs[producer] = await self._exec_producer(
                stdout=f,
            )