diff --git a/clients/python/src/taskbroker_client/task.py b/clients/python/src/taskbroker_client/task.py index ba84762d..67d68d5f 100644 --- a/clients/python/src/taskbroker_client/task.py +++ b/clients/python/src/taskbroker_client/task.py @@ -208,8 +208,13 @@ def apply_async_with_future( **options: Any, ) -> ProducerFuture | None: """ - Schedule a task and return the producer future for callers that need to - wait on delivery alongside other Kafka produces. + Schedule a task and return the producer future. + + This does not wait for delivery. Callers that need delivery confirmation + must wait on the returned future themselves. Callers that do not need the + future should use apply_async(). Ignoring the returned future does not + cancel or prevent the produce; the task activation has already been + handed to the producer. """ activation, args, kwargs = self._create_activation_for_async_dispatch( args=args, kwargs=kwargs, headers=headers, expires=expires, countdown=countdown