Asana Toolkit

docker/toolkits.txt

@@ -1,3 +1,4 @@
+arcade-asana
 arcade-code-sandbox
 arcade-dropbox
 arcade-github

toolkits/asana/.pre-commit-config.yaml

@@ -0,0 +1,18 @@
+files: ^./
+repos:
+  - repo: https://github.com/pre-commit/pre-commit-hooks
+    rev: "v4.4.0"
+    hooks:
+      - id: check-case-conflict
+      - id: check-merge-conflict
+      - id: check-toml
+      - id: check-yaml
+      - id: end-of-file-fixer
+      - id: trailing-whitespace
+
+  - repo: https://github.com/astral-sh/ruff-pre-commit
+    rev: v0.6.7
+    hooks:
+      - id: ruff
+        args: [--fix]
+      - id: ruff-format

toolkits/asana/.ruff.toml

@@ -0,0 +1,46 @@
+target-version = "py39"
+line-length = 100
+fix = true
+
+[lint]
+select = [
+    # flake8-2020
+    "YTT",
+    # flake8-bandit
+    "S",
+    # flake8-bugbear
+    "B",
+    # flake8-builtins
+    "A",
+    # flake8-comprehensions
+    "C4",
+    # flake8-debugger
+    "T10",
+    # flake8-simplify
+    "SIM",
+    # isort
+    "I",
+    # mccabe
+    "C90",
+    # pycodestyle
+    "E", "W",
+    # pyflakes
+    "F",
+    # pygrep-hooks
+    "PGH",
+    # pyupgrade
+    "UP",
+    # ruff
+    "RUF",
+    # tryceratops
+    "TRY",
+]
+
+[lint.per-file-ignores]
+"*" = ["TRY003", "B904"]
+"**/tests/*" = ["S101", "E501"]
+"**/evals/*" = ["S101", "E501"]
+
+[format]
+preview = true
+skip-magic-trailing-comma = false

toolkits/asana/LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2025 Arcade
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

toolkits/asana/Makefile

@@ -0,0 +1,53 @@
+.PHONY: help
+
+help:
+	@echo "🛠️ dropbox Commands:\n"
+	@grep -E '^[a-zA-Z_-]+:.*?## .*$$' $(MAKEFILE_LIST) | sort | awk 'BEGIN {FS = ":.*?## "}; {printf "\033[36m%-30s\033[0m %s\n", $$1, $$2}'
+
+.PHONY: install
+install: ## Install the poetry environment and install the pre-commit hooks
+	@echo "📦 Checking if Poetry is installed"
+	@if ! command -v poetry &> /dev/null; then \
+		echo "📦 Installing Poetry with pip"; \
+		pip install poetry==1.8.5; \
+	else \
+		echo "📦 Poetry is already installed"; \
+	fi
+	@echo "🚀 Installing package in development mode with all extras"
+	poetry install --all-extras
+
+.PHONY: build
+build: clean-build ## Build wheel file using poetry
+	@echo "🚀 Creating wheel file"
+	poetry build
+
+.PHONY: clean-build
+clean-build: ## clean build artifacts
+	@echo "🗑️ Cleaning dist directory"
+	rm -rf dist
+
+.PHONY: test
+test: ## Test the code with pytest
+	@echo "🚀 Testing code: Running pytest"
+	@poetry run pytest -W ignore -v --cov --cov-config=pyproject.toml --cov-report=xml
+
+.PHONY: coverage
+coverage: ## Generate coverage report
+	@echo "coverage report"
+	coverage report
+	@echo "Generating coverage report"
+	coverage html
+
+.PHONY: bump-version
+bump-version: ## Bump the version in the pyproject.toml file
+	@echo "🚀 Bumping version in pyproject.toml"
+	poetry version patch
+
+.PHONY: check
+check: ## Run code quality tools.
+	@echo "🚀 Checking Poetry lock file consistency with 'pyproject.toml': Running poetry check"
+	@poetry check
+	@echo "🚀 Linting code: Running pre-commit"
+	@poetry run pre-commit run -a
+	@echo "🚀 Static type checking: Running mypy"
+	@poetry run mypy --config-file=pyproject.toml

toolkits/asana/arcade_asana/constants.py

@@ -0,0 +1,139 @@
+import os
+from enum import Enum
+
+ASANA_BASE_URL = "https://app.asana.com/api"
+ASANA_API_VERSION = "1.0"
+
+try:
+    ASANA_MAX_CONCURRENT_REQUESTS = int(os.getenv("ASANA_MAX_CONCURRENT_REQUESTS", 3))
+except ValueError:
+    ASANA_MAX_CONCURRENT_REQUESTS = 3
+
+try:
+    ASANA_MAX_TIMEOUT_SECONDS = int(os.getenv("ASANA_MAX_TIMEOUT_SECONDS", 20))
+except ValueError:
+    ASANA_MAX_TIMEOUT_SECONDS = 20
+
+MAX_PROJECTS_TO_SCAN_BY_NAME = 1000
+MAX_TAGS_TO_SCAN_BY_NAME = 1000
+
+PROJECT_OPT_FIELDS = [
+    "gid",
+    "resource_type",
+    "name",
+    "workspace",
+    "color",
+    "created_at",
+    "current_status_update",
+    "due_on",
+    "members",
+    "notes",
+    "completed",
+    "completed_at",
+    "completed_by",
+    "owner",
+    "team",
+    "workspace",
+    "permalink_url",
+]
+
+TASK_OPT_FIELDS = [
+    "gid",
+    "name",
+    "notes",
+    "completed",
+    "completed_at",
+    "completed_by",
+    "created_at",
+    "created_by",
+    "due_on",
+    "start_on",
+    "owner",
+    "team",
+    "workspace",
+    "permalink_url",
+    "approval_status",
+    "assignee",
+    "assignee_status",
+    "dependencies",
+    "dependents",
+    "memberships",
+    "num_subtasks",
+    "resource_type",
+    "custom_type",
+    "custom_type_status_option",
+    "parent",
+    "tags",
+    "workspace",
+]
+
+
+TAG_OPT_FIELDS = [
+    "gid",
+    "name",
+    "workspace",
+]
+
+TEAM_OPT_FIELDS = [
+    "gid",
+    "name",
+    "description",
+    "organization",
+    "permalink_url",
+]
+
+USER_OPT_FIELDS = [
+    "gid",
+    "resource_type",
+    "name",
+    "email",
+    "photo",
+    "workspaces",
+]
+
+WORKSPACE_OPT_FIELDS = [
+    "gid",
+    "resource_type",
+    "name",
+    "email_domains",
+    "is_organization",
+]
+
+
+class TaskSortBy(Enum):
+    DUE_DATE = "due_date"
+    CREATED_AT = "created_at"
+    COMPLETED_AT = "completed_at"
+    MODIFIED_AT = "modified_at"
+    LIKES = "likes"
+
+
+class SortOrder(Enum):
+    ASCENDING = "ascending"
+    DESCENDING = "descending"
+
+
+class TagColor(Enum):
+    DARK_GREEN = "dark-green"
+    DARK_RED = "dark-red"
+    DARK_BLUE = "dark-blue"
+    DARK_PURPLE = "dark-purple"
+    DARK_PINK = "dark-pink"
+    DARK_ORANGE = "dark-orange"
+    DARK_TEAL = "dark-teal"
+    DARK_BROWN = "dark-brown"
+    DARK_WARM_GRAY = "dark-warm-gray"
+    LIGHT_GREEN = "light-green"
+    LIGHT_RED = "light-red"
+    LIGHT_BLUE = "light-blue"
+    LIGHT_PURPLE = "light-purple"
+    LIGHT_PINK = "light-pink"
+    LIGHT_ORANGE = "light-orange"
+    LIGHT_TEAL = "light-teal"
+    LIGHT_BROWN = "light-brown"
+    LIGHT_WARM_GRAY = "light-warm-gray"
+
+
+class ReturnType(Enum):
+    FULL_ITEMS_DATA = "full_items_data"
+    ITEMS_COUNT = "items_count"

toolkits/asana/arcade_asana/decorators.py

@@ -0,0 +1,26 @@
+from functools import wraps
+from typing import Any, Callable
+
+
+def clean_asana_response(func: Callable[..., Any]) -> Callable[..., Any]:
+    def response_cleaner(data: dict[str, Any]) -> dict[str, Any]:
+        if "gid" in data:
+            data["id"] = data["gid"]
+            del data["gid"]
+
+        for k, v in data.items():
+            if isinstance(v, dict):
+                data[k] = response_cleaner(v)
+            elif isinstance(v, list):
+                data[k] = [
+                    item if not isinstance(item, dict) else response_cleaner(item) for item in v
+                ]
+
+        return data
+
+    @wraps(func)
+    async def wrapper(*args: Any, **kwargs: Any) -> Any:
+        response = await func(*args, **kwargs)
+        return response_cleaner(response)
+
+    return wrapper

toolkits/asana/arcade_asana/exceptions.py

@@ -0,0 +1,14 @@
+from arcade.sdk.errors import ToolExecutionError
+
+
+class AsanaToolExecutionError(ToolExecutionError):
+    pass
+
+
+class PaginationTimeoutError(AsanaToolExecutionError):
+    def __init__(self, timeout_seconds: int, tool_name: str):
+        message = f"Pagination timed out after {timeout_seconds} seconds"
+        super().__init__(
+            message=message,
+            developer_message=f"{message} while calling the tool {tool_name}",
+        )