spdl.pipeline.create_task

create_task(coro: Coroutine[Any, Any, T] | Generator[Any, None, T], name: str | None = None, ignore_cancelled: bool = True) → Task[T]

Wrapper around asyncio.create_task(). Add logging callback.