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 = True, suppression_threshold: int = 2, suppression_warning_interval: int = 100) Task[T] [source]¶
Wrapper around
asyncio.create_task()
. Add logging callback.