andre/crewAI
1
0
Fork 0
mirror of https://github.com/crewAIInc/crewAI.git synced 2026-01-11 00:58:30 +00:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

Fix W293 lint errors in task.py docstrings

Browse Source 
Co-Authored-By: João <joao@crewai.com>
This commit is contained in:
Devin AI
2026-01-03 17:34:16 +00:00
parent 563e2eccbd
commit 5b8e42c028
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
lib/crewai/src/crewai/task.py
View File

@@ -1,5 +1,6 @@
from __future__ import annotations from __future__ import annotations
from collections.abc import Callable
from concurrent.futures import Future from concurrent.futures import Future
from copy import copy as shallow_copy from copy import copy as shallow_copy
import datetime import datetime
@@ -11,7 +12,6 @@ from pathlib import Path
import threading import threading
from typing import ( from typing import (
Any, Any,
Callable,
ClassVar, ClassVar,
cast, cast,
get_args, get_args,
@@ -481,7 +481,7 @@ class Task(BaseModel):
agent_execution_lock: threading.Lock | None = None, agent_execution_lock: threading.Lock | None = None,
) -> Future[TaskOutput | tuple[TaskOutput, Any, Any]]: ) -> Future[TaskOutput | tuple[TaskOutput, Any, Any]]:
"""Execute the task asynchronously. """Execute the task asynchronously.
Args: Args:
agent: The agent to execute the task. agent: The agent to execute the task.
context: Context for the task execution. context: Context for the task execution.
@@ -495,7 +495,7 @@ class Task(BaseModel):
the same agent. This is used to ensure accurate per-task token the same agent. This is used to ensure accurate per-task token
tracking when multiple async tasks from the same agent run tracking when multiple async tasks from the same agent run
concurrently. concurrently.
Returns: Returns:
Future containing TaskOutput, or tuple of (TaskOutput, tokens_before, tokens_after) Future containing TaskOutput, or tuple of (TaskOutput, tokens_before, tokens_after)
if token_capture_callback is provided. if token_capture_callback is provided.
@@ -518,7 +518,7 @@ class Task(BaseModel):
agent_execution_lock: threading.Lock | None = None, agent_execution_lock: threading.Lock | None = None,
) -> None: ) -> None:
"""Execute the task asynchronously with context handling. """Execute the task asynchronously with context handling.
If agent_execution_lock is provided, the task execution will be If agent_execution_lock is provided, the task execution will be
serialized with other tasks using the same lock. This ensures serialized with other tasks using the same lock. This ensures
accurate per-task token tracking by: accurate per-task token tracking by:
@@ -526,7 +526,7 @@ class Task(BaseModel):
2. Executing the task 2. Executing the task
3. Capturing tokens_after immediately after completion 3. Capturing tokens_after immediately after completion
4. Releasing the lock 4. Releasing the lock
If token_capture_callback is provided, it will be called twice: If token_capture_callback is provided, it will be called twice:
once before task execution and once after, both while holding the lock. once before task execution and once after, both while holding the lock.
""" """