Running an endless task with taskiq

[PPPoE15]

Hi, thanks for TaskIQ, we just started to implement it to our project.

I have a question about running an endless task. We need to run some pipe like below:

@broker.task()
async def pipe() -> None:
    while True:
        data = await get_data()
        if not data:
            break
        data = process(data)
        await send(data)

How can i run this task?
Perhaps i should to create some kind time-limited cycle?
Sometimes when the task is running a long time, taskiq tells me in logs that worker is dead and it will be restarted