ray.serve.schema.TaskProcessorAdapter.enqueue_task_async#

async TaskProcessorAdapter.enqueue_task_async(task_name: str, args: Any | None = None, kwargs: Any | None = None, **options) → TaskResult[source]#

Enqueue a task asynchronously.

Parameters:

  • task_name – Name of the registered task to execute.

  • args – Positional arguments to pass to the task function.

  • kwargs – Keyword arguments to pass to the task function.

  • **options – Additional adapter-specific options for task execution.

Returns:

Object containing task ID, status, and other metadata.

Return type:

TaskResult

Raises:

NotImplementedError – If subclass didn’t implement enqueue_task_async function