spdl.pipeline.create_task

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

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