Merge pull request #3191 from airbytehq/publish/asana-v0.19.135

chore(asana): bump to 0.19.135

Author: octavia-bot-hoard[bot]

connectors/asana/CHANGELOG.md

@@ -1,5 +1,10 @@
 # Asana changelog
 
+## [0.19.135] - 2026-04-09
+- Updated connector definition (YAML version 0.1.20)
+- Source commit: 6bf360a5
+- SDK version: 0.1.0
+
 ## [0.19.134] - 2026-04-09
 - Updated connector definition (YAML version 0.1.19)
 - Source commit: 3cecc817

connectors/asana/README.md

@@ -130,7 +130,7 @@ See the official [Asana API reference](https://developers.asana.com/reference/re
 
 ## Version information
 
-- **Package version:** 0.19.134
-- **Connector version:** 0.1.19
-- **Generated with Connector SDK commit SHA:** 3cecc817f060335c13c5d88bc9ad34a4dace961f
+- **Package version:** 0.19.135
+- **Connector version:** 0.1.20
+- **Generated with Connector SDK commit SHA:** 6bf360a546d577c9f76e8a6b8abf9ffc4dbfcf3a
 - **Changelog:** [View changelog](https://github.com/airbytehq/airbyte-agent-connectors/blob/main/connectors/asana/CHANGELOG.md)

connectors/asana/airbyte_agent_asana/__init__.py

@@ -15,14 +15,14 @@
     TasksList,
     ProjectCompact,
     ProjectOwner,
+    ProjectCurrentStatusUpdate,
     ProjectWorkspace,
-    ProjectCurrentStatusCreatedBy,
+    ProjectTeam,
+    ProjectFollowersItem,
     ProjectCurrentStatusAuthor,
+    ProjectCurrentStatusCreatedBy,
     ProjectCurrentStatus,
-    ProjectFollowersItem,
     ProjectMembersItem,
-    ProjectTeam,
-    ProjectCurrentStatusUpdate,
     Project,
     ProjectResponse,
     ProjectsListNextPage,
@@ -192,14 +192,14 @@
     "TasksList",
     "ProjectCompact",
     "ProjectOwner",
+    "ProjectCurrentStatusUpdate",
     "ProjectWorkspace",
-    "ProjectCurrentStatusCreatedBy",
+    "ProjectTeam",
+    "ProjectFollowersItem",
     "ProjectCurrentStatusAuthor",
+    "ProjectCurrentStatusCreatedBy",
     "ProjectCurrentStatus",
-    "ProjectFollowersItem",
     "ProjectMembersItem",
-    "ProjectTeam",
-    "ProjectCurrentStatusUpdate",
     "Project",
     "ProjectResponse",
     "ProjectsListNextPage",

connectors/asana/airbyte_agent_asana/_vendored/connector_sdk/connector_model_loader.py

@@ -238,7 +238,7 @@ def _dedupe_strings(values: list[str]) -> list[str]:
 
 
 def _extract_search_field_paths(spec: OpenAPIConnector) -> dict[str, list[str]]:
-    cache_config = getattr(spec.info, "x_airbyte_cache", None)
+    cache_config = getattr(spec.info, "x_airbyte_context_store", None)
     entities = getattr(cache_config, "entities", None)
     if not isinstance(entities, list):
         return {}

connectors/asana/airbyte_agent_asana/_vendored/connector_sdk/introspection.py

@@ -169,7 +169,7 @@ def _collect_search_field_paths(model: ConnectorModelProtocol) -> dict[str, list
 
     openapi_spec = getattr(model, "openapi_spec", None)
     info = getattr(openapi_spec, "info", None)
-    cache_config = getattr(info, "x_airbyte_cache", None)
+    cache_config = getattr(info, "x_airbyte_context_store", None)
     entities = getattr(cache_config, "entities", None)
     if not isinstance(entities, list):
         return {}

connectors/asana/airbyte_agent_asana/_vendored/connector_sdk/schema/base.py

@@ -119,7 +119,7 @@ class Info(BaseModel):
     - x-airbyte-external-documentation-urls: List of external documentation URLs (Airbyte extension)
     - x-airbyte-retry-config: Retry configuration for transient errors (Airbyte extension)
     - x-airbyte-example-questions: Example questions for AI connector README (Airbyte extension)
-    - x-airbyte-cache: Cache configuration for field mapping between API and cache schemas (Airbyte extension)
+    - x-airbyte-context-store: Cache configuration for field mapping between API and cache schemas (Airbyte extension)
     - x-airbyte-replication-config: Replication configuration for MULTI mode connectors (Airbyte extension)
     - x-airbyte-entity-relationships: Entity relationship declarations (Airbyte extension)
     - x-airbyte-scoping: Scoping parameter resolution from config (Airbyte extension)
@@ -140,7 +140,7 @@ class Info(BaseModel):
     x_airbyte_external_documentation_urls: list[DocUrl] = Field(..., alias="x-airbyte-external-documentation-urls")
     x_airbyte_retry_config: RetryConfig | None = Field(None, alias="x-airbyte-retry-config")
     x_airbyte_example_questions: ExampleQuestions | None = Field(None, alias="x-airbyte-example-questions")
-    x_airbyte_cache: CacheConfig | None = Field(None, alias="x-airbyte-cache")
+    x_airbyte_context_store: CacheConfig | None = Field(None, alias="x-airbyte-context-store")
     x_airbyte_entity_relationships: list[EntityRelationshipConfig] = Field(
         default_factory=list, alias="x-airbyte-entity-relationships"
     )
@@ -167,6 +167,12 @@ class Info(BaseModel):
         description="List of Airbyte auth methods to skip when validating auth compatibility. "
         "Use the SelectiveAuthenticator option key (e.g., 'Private App Credentials', 'oauth2.0')",
     )
+    x_airbyte_skip_context_store: str | None = Field(
+        default=None,
+        alias="x-airbyte-skip-context-store",
+        description="Reason why this connector does not define x-airbyte-context-store. "
+        "Connectors must have either x-airbyte-context-store or x-airbyte-skip-context-store with a justification.",
+    )
 
 
 class ServerVariable(BaseModel):

connectors/asana/airbyte_agent_asana/_vendored/connector_sdk/schema/extensions.py

@@ -87,7 +87,7 @@ class CacheFieldConfig(BaseModel):
     For object-type fields, supports nested properties to define the internal structure
     of complex nested schemas.
 
-    Used in x-airbyte-cache extension for api_search operations.
+    Used in x-airbyte-context-store extension for api_search operations.
     """
 
     model_config = ConfigDict(populate_by_name=True, extra="forbid")
@@ -111,7 +111,7 @@ class CacheEntityConfig(BaseModel):
     Defines a cache-enabled entity with its fields and optional name aliasing
     to map between user-facing entity names and cache storage names.
 
-    Used in x-airbyte-cache extension for api_search operations.
+    Used in x-airbyte-context-store extension for api_search operations.
     """
 
     model_config = ConfigDict(populate_by_name=True, extra="forbid")
@@ -237,7 +237,7 @@ def validate_replication_config_key_mapping(self) -> "ReplicationConfig":
 
 class CacheConfig(BaseModel):
     """
-    Cache configuration extension (x-airbyte-cache).
+    Cache configuration extension (x-airbyte-context-store).
 
     Defines cache-enabled entities and their field mappings for api_search operations.
     Supports optional name aliasing via x-airbyte-name for both entities and fields,
@@ -249,7 +249,7 @@ class CacheConfig(BaseModel):
     Example YAML usage:
         info:
           title: Stripe API
-          x-airbyte-cache:
+          x-airbyte-context-store:
             entities:
               - entity: customers
                 stream: customers

connectors/asana/airbyte_agent_asana/_vendored/connector_sdk/validation/__init__.py

@@ -3,7 +3,7 @@
 This module provides validation for connector definitions, including:
 - Readiness validation (cassettes, schemas, auth coverage)
 - Replication compatibility validation (Airbyte registry mappings)
-- Cache schema validation (x-airbyte-cache vs manifest)
+- Cache schema validation (x-airbyte-context-store vs manifest)
 - Connector overview (structured status reporting)
 """
 

connectors/asana/airbyte_agent_asana/_vendored/connector_sdk/validation/cache.py

@@ -1,5 +1,5 @@
 """
-Validate x-airbyte-cache entities against the Airbyte source connector manifest.
+Validate x-airbyte-context-store entities against the Airbyte source connector manifest.
 
 Checks that each cache entity name corresponds to a real stream in the manifest,
 and that cache field names exist as properties in the manifest stream schema.
@@ -61,9 +61,9 @@ def validate_cache_against_manifest(
     connector_yaml_path: str | Path,
     connector_def: dict[str, Any] | None = None,
 ) -> dict[str, Any]:
-    """Validate that x-airbyte-cache entities match the Airbyte manifest.
+    """Validate that x-airbyte-context-store entities match the Airbyte manifest.
 
-    For each entity in x-airbyte-cache, checks:
+    For each entity in x-airbyte-context-store, checks:
     1. A stream with a matching name exists in the manifest.  If the entity has
        an ``x-airbyte-name`` field, that value is used for the manifest lookup;
        otherwise the ``entity`` name is used.
@@ -89,12 +89,12 @@ def validate_cache_against_manifest(
             return {"errors": [f"Failed to load connector.yaml: {e}"], "warnings": []}
 
     info = connector_def.get("info", {})
-    cache_entities: list[dict[str, Any]] = info.get("x-airbyte-cache", {}).get("entities", [])
+    cache_entities: list[dict[str, Any]] = info.get("x-airbyte-context-store", {}).get("entities", [])
 
     if not cache_entities:
         return {
             "errors": [],
-            "warnings": ["No x-airbyte-cache entities found in connector.yaml — skipping cache validation"],
+            "warnings": ["No x-airbyte-context-store entities found in connector.yaml — skipping cache validation"],
             "entities_checked": 0,
             "manifest_streams": [],
         }

connectors/asana/airbyte_agent_asana/_vendored/connector_sdk/validation/overview.py

@@ -293,6 +293,7 @@ def _extract_auth_schemes(config) -> Dict[str, Any]:
 def _extract_exceptions(info: dict, config) -> Dict[str, Any]:
     skip_streams = info.get("x-airbyte-skip-suggested-streams", []) or []
     skip_auth = info.get("x-airbyte-skip-auth-methods", []) or []
+    skip_context_store = info.get("x-airbyte-skip-context-store") or None
 
     untested_ops = []
     for entity in config.entities:
@@ -304,10 +305,13 @@ def _extract_exceptions(info: dict, config) -> Dict[str, Any]:
     untested_auth = [opt.scheme_name for opt in (config.auth.options or []) if opt.untested]
 
     total = len(skip_streams) + len(skip_auth) + len(untested_ops) + len(untested_auth)
+    if skip_context_store:
+        total += 1
 
     return {
         "skip_suggested_streams": skip_streams,
         "skip_auth_methods": skip_auth,
+        "skip_context_store": skip_context_store,
         "untested_operations": untested_ops,
         "untested_auth_schemes": untested_auth,
         "total_count": total,
@@ -558,6 +562,16 @@ def diff_overviews(base: Dict[str, Any] | None, head: Dict[str, Any]) -> Dict[st
         if removed:
             changes[f"removed_{key}"] = sorted(removed)
 
+    base_skip_context_store = base_exc.get("skip_context_store")
+    head_skip_context_store = head_exc.get("skip_context_store")
+    if base_skip_context_store != head_skip_context_store:
+        if head_skip_context_store and not base_skip_context_store:
+            changes["skip_context_store_added"] = head_skip_context_store
+        elif base_skip_context_store and not head_skip_context_store:
+            changes["skip_context_store_removed"] = base_skip_context_store
+        else:
+            changes["skip_context_store_changed"] = {"from": base_skip_context_store, "to": head_skip_context_store}
+
     base_readiness = base.get("readiness", {}).get("success", False)
     head_readiness = head.get("readiness", {}).get("success", False)
     if base_readiness != head_readiness:
@@ -762,6 +776,16 @@ def _format_diff_section(diff: Dict[str, Any] | None) -> str:
         if removed:
             items.append(f"✅ Removed {label}: {', '.join(f'`{v}`' for v in removed)}")
 
+    skip_context_store_added = diff.get("skip_context_store_added")
+    if skip_context_store_added:
+        items.append(f"🔇 Added skip-cache exception: {skip_context_store_added}")
+    skip_context_store_removed = diff.get("skip_context_store_removed")
+    if skip_context_store_removed:
+        items.append("✅ Removed skip-cache exception")
+    skip_context_store_changed = diff.get("skip_context_store_changed")
+    if skip_context_store_changed:
+        items.append(f"🔇 Skip-cache reason changed: {skip_context_store_changed['to']}")
+
     errors_delta = diff.get("errors_delta")
     if errors_delta is not None and errors_delta != 0:
         if errors_delta > 0:
@@ -815,6 +839,10 @@ def _format_exceptions_section(overview: dict) -> str:
         auth_str = ", ".join(f"`{a}`" for a in skip_auth)
         lines.append(f"> - 🔇 Skipped auth methods: {auth_str}")
 
+    skip_context_store = exceptions.get("skip_context_store")
+    if skip_context_store:
+        lines.append(f"> - 🔇 Skipped cache: {skip_context_store}")
+
     untested_ops = exceptions.get("untested_operations", [])
     if untested_ops:
         ops_str = ", ".join(f"`{o}`" for o in untested_ops)