spdl.pipeline.create_task

create_task(coro: Coroutine[Any, Any, T] | Generator[Any, None, T], name: str | None = None, log_cancelled: bool = False, suppress_repeated_logs: bool = False, suppression_threshold: int = 5, suppression_warning_interval: int = 100) → Task[T]

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