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

[samirbhattarai135]

The "worker dead" message indicates Taskiq's broker/infrastructure thinks your worker is unresponsive because it's stuck in an infinite loop without yielding control.
For truly endless processes, don't use a task queue at all. Instead, run it as a service:

 # In a dedicated service file, not a task
  async def run_pipeline():
      """Long-running service - runs as its own process, not a task."""
      async with anyio.create_task_group() as tg:
          while True:
              data = await get_data()
              if not data:
                  await anyio.sleep(1)  # Backoff when no data
                  continue
              tg.start_soon(process_and_send, data)

  async def process_and_send(data):
      processed = process(data)
      await send(processed)

  # Run as a service, not a Taskiq task
  if __name__ == "__main__":
      anyio.run(run_pipeline)