Release 1.13.1

.airflow-registry.yaml

@@ -0,0 +1,219 @@
+# .airflow-registry.yaml — metadata for the Apache Airflow Provider Registry
+# Place this file in the root of your provider repository.
+# Docs: https://github.com/apache/airflow/blob/main/dev/registry/README.md
+
+package-name: astronomer-cosmos
+display-name: Cosmos (dbt)
+description: Run dbt projects as Airflow DAGs and Task Groups. Supports both dbt Core and dbt Fusion.
+logo: https://raw.githubusercontent.com/astronomer/astronomer-cosmos/main/docs/_static/cosmos-logo.svg
+docs-url: https://astronomer.github.io/astronomer-cosmos
+source-url: https://github.com/astronomer/astronomer-cosmos
+
+operators:
+  # Execute dbt commands using a local dbt installation, either within the Airflow Python virtual environment or as a standalone dbt binary.
+  - module: cosmos.operators.local.DbtRunLocalOperator
+    description: Run `dbt run` using a local dbt installation
+  - module: cosmos.operators.local.DbtTestLocalOperator
+    description: Run `dbt test` using a local dbt installation
+  - module: cosmos.operators.local.DbtSeedLocalOperator
+    description: Run `dbt seed` using a local dbt installation
+  - module: cosmos.operators.local.DbtSnapshotLocalOperator
+    description: Run `dbt snapshot` using a local dbt installation
+  - module: cosmos.operators.local.DbtCompileLocalOperator
+    description: Run `dbt compile` using a local dbt installation
+  - module: cosmos.operators.local.DbtLSLocalOperator
+    description: Run `dbt ls` using a local dbt installation
+  - module: cosmos.operators.local.DbtRunOperationLocalOperator
+    description: Run `dbt run-operation` using a local dbt installation
+  - module: cosmos.operators.local.DbtBuildLocalOperator
+    description: Run `dbt build` using a local dbt installation
+  - module: cosmos.operators.local.DbtCloneLocalOperator
+    description: Run `dbt clone` using a local dbt installation
+  - module: cosmos.operators.local.DbtSourceLocalOperator
+    description: Run `dbt source freshness` using a local dbt installation
+  - module: cosmos.operators.local.DbtDocsLocalOperator
+    description: Run `dbt docs generate` using a local dbt installation
+  - module: cosmos.operators.local.DbtDocsS3LocalOperator
+    description: Run `dbt docs generate` and upload the generated docs to AWS S3
+  - module: cosmos.operators.local.DbtDocsAzureStorageLocalOperator
+    description: Run `dbt docs generate` and upload the generated docs to Azure Blob Storage
+  - module: cosmos.operators.local.DbtDocsGCSLocalOperator
+    description: Run `dbt docs generate` and upload the generated docs to Google Cloud Storage (GCS)
+
+  # Execute dbt commands by running each command in its own (local) Docker container.
+  - module: cosmos.operators.docker.DbtBuildDockerOperator
+    description: Run `dbt build` inside a Docker container.
+  - module: cosmos.operators.docker.DbtCloneDockerOperator
+    description: Run `dbt clone` inside a Docker container.
+  - module: cosmos.operators.docker.DbtLSDockerOperator
+    description: Run `dbt ls` inside a Docker container.
+  - module: cosmos.operators.docker.DbtRunDockerOperator
+    description: Run `dbt run` inside a Docker container.
+  - module: cosmos.operators.docker.DbtRunOperationDockerOperator
+    description: Run `dbt run-operation` inside a Docker container.
+  - module: cosmos.operators.docker.DbtSeedDockerOperator
+    description: Run `dbt seed` inside a Docker container.
+  - module: cosmos.operators.docker.DbtSnapshotDockerOperator
+    description: Run `dbt snapshot` inside a Docker container.
+  - module: cosmos.operators.docker.DbtSourceDockerOperator
+    description: Run `dbt source freshness` inside a Docker container.
+  - module: cosmos.operators.docker.DbtTestDockerOperator
+    description: Run `dbt test` inside a Docker container.
+
+  # Execute dbt commands via dedicated Kubernetes pods
+  - module: cosmos.operators.kubernetes.DbtBuildKubernetesOperator
+    description: Run `dbt build` in a Kubernetes pod.
+  - module: cosmos.operators.kubernetes.DbtCloneKubernetesOperator
+    description: Run `dbt clone` in a Kubernetes pod.
+  - module: cosmos.operators.kubernetes.DbtLSKubernetesOperator
+    description: Run `dbt ls` in a Kubernetes pod.
+  - module: cosmos.operators.kubernetes.DbtRunKubernetesOperator
+    description: Run `dbt run` in a Kubernetes pod.
+  - module: cosmos.operators.kubernetes.DbtRunOperationKubernetesOperator
+    description: Run `dbt run-operation` in a Kubernetes pod.
+  - module: cosmos.operators.kubernetes.DbtSeedKubernetesOperator
+    description: Run `dbt seed` in a Kubernetes pod.
+  - module: cosmos.operators.kubernetes.DbtSnapshotKubernetesOperator
+    description: Run `dbt snapshot` in a Kubernetes pod.
+  - module: cosmos.operators.kubernetes.DbtSourceKubernetesOperator
+    description: Run `dbt source freshness` in a Kubernetes pod.
+  - module: cosmos.operators.kubernetes.DbtTestKubernetesOperator
+    description: Run `dbt test` in a Kubernetes pod.
+
+  # Execute dbt commands via isolated Python virtual environments created and managed by Cosmos
+  - module: cosmos.operators.virtualenv.DbtBuildVirtualenvOperator
+    description: Run `dbt build` inside a Cosmos-managed Python virtual environment.
+  - module: cosmos.operators.virtualenv.DbtCloneVirtualenvOperator
+    description: Run `dbt clone` inside a Cosmos-managed Python virtual environment.
+  - module: cosmos.operators.virtualenv.DbtDocsVirtualenvOperator
+    description: Run `dbt docs generate` inside a Cosmos-managed Python virtual environment.
+  - module: cosmos.operators.virtualenv.DbtLSVirtualenvOperator
+    description: Run `dbt ls` inside a Cosmos-managed Python virtual environment.
+  - module: cosmos.operators.virtualenv.DbtRunVirtualenvOperator
+    description: Run `dbt run` inside a Cosmos-managed Python virtual environment.
+  - module: cosmos.operators.virtualenv.DbtRunOperationVirtualenvOperator
+    description: Run `dbt run-operation` inside a Cosmos-managed Python virtual environment.
+  - module: cosmos.operators.virtualenv.DbtSeedVirtualenvOperator
+    description: Run `dbt seed` inside a Cosmos-managed Python virtual environment.
+  - module: cosmos.operators.virtualenv.DbtSnapshotVirtualenvOperator
+    description: Run `dbt snapshot` inside a Cosmos-managed Python virtual environment.
+  - module: cosmos.operators.virtualenv.DbtSourceVirtualenvOperator
+    description: Run `dbt source freshness` inside a Cosmos-managed Python virtual environment.
+  - module: cosmos.operators.virtualenv.DbtTestVirtualenvOperator
+    description: Run `dbt test` inside a Cosmos-managed Python virtual environment.
+
+  # Pre-compile the project using dbt Core and use Airflow `BigQueryInsertJobOperator` to asynchronously run the transformations.
+  - module: cosmos.operators._asynchronous.SetupAsyncOperator
+    description: Monkey-patch `dbt run` command to pre-generate the dbt models SQL and export them to XCom
+  - module: cosmos.operators.airflow_async.DbtRunAirflowAsyncOperator
+    description: Retrieve the SQL from the setup task and execute each model natively to Airflow via a subclass of `BigQueryInsertJobOperator`
+  - module: cosmos.operators._asynchronous.TeardownAsyncOperator
+    description: Clear all the SQL files related to this DAG run from corresponding XComs
+
+  # Run dbt commands as containers via the Amazon Elastic Container Service (AWS ECS)
+  - module: cosmos.operators.aws_ecs.DbtBuildAwsEcsOperator
+    description: Run `dbt build` as a task in AWS ECS.
+  - module: cosmos.operators.aws_ecs.DbtLSAwsEcsOperator
+    description: Run `dbt ls` as a task in AWS ECS.
+  - module: cosmos.operators.aws_ecs.DbtRunAwsEcsOperator
+    description: Run `dbt run` as a task in AWS ECS.
+  - module: cosmos.operators.aws_ecs.DbtRunOperationAwsEcsOperator
+    description: Run `dbt run-operation` as a task in AWS ECS.
+  - module: cosmos.operators.aws_ecs.DbtSeedAwsEcsOperator
+    description: Run `dbt seed` as a task in AWS ECS.
+  - module: cosmos.operators.aws_ecs.DbtSnapshotAwsEcsOperator
+    description: Run `dbt snapshot` as a task in AWS ECS.
+  - module: cosmos.operators.aws_ecs.DbtSourceAwsEcsOperator
+    description: Run `dbt source freshness` as a task in AWS ECS.
+  - module: cosmos.operators.aws_ecs.DbtTestAwsEcsOperator
+    description: Run `dbt test` as a task in AWS ECS.
+
+  # Run dbt commands as Kubernetes pods via the Amazon Elastic Kubernetes Service (AWS EKS).
+  - module: cosmos.operators.aws_eks.DbtBuildAwsEksOperator
+    description: Run `dbt build` in a pod on AWS EKS.
+  - module: cosmos.operators.aws_eks.DbtCloneAwsEksOperator
+    description: Run `dbt clone` in a pod on AWS EKS.
+  - module: cosmos.operators.aws_eks.DbtLSAwsEksOperator
+    description: Run `dbt ls` in a pod on AWS EKS.
+  - module: cosmos.operators.aws_eks.DbtRunAwsEksOperator
+    description: Run `dbt run` in a pod on AWS EKS.
+  - module: cosmos.operators.aws_eks.DbtRunOperationAwsEksOperator
+    description: Run `dbt run-operation` in a pod on AWS EKS.
+  - module: cosmos.operators.aws_eks.DbtSeedAwsEksOperator
+    description: Run `dbt seed` in a pod on AWS EKS.
+  - module: cosmos.operators.aws_eks.DbtSnapshotAwsEksOperator
+    description: Run `dbt snapshot` in a pod on AWS EKS.
+  - module: cosmos.operators.aws_eks.DbtTestAwsEksOperator
+    description: Run `dbt test` in a pod on AWS EKS.
+
+  # Run dbt commands as remote containers via the Azure Container Instance service.
+  - module: cosmos.operators.azure_container_instance.DbtBuildAzureContainerInstanceOperator
+    description: Run `dbt build` in an Azure Container Instance.
+  - module: cosmos.operators.azure_container_instance.DbtCloneAzureContainerInstanceOperator
+    description: Run `dbt clone` in an Azure Container Instance.
+  - module: cosmos.operators.azure_container_instance.DbtLSAzureContainerInstanceOperator
+    description: Run `dbt ls` in an Azure Container Instance.
+  - module: cosmos.operators.azure_container_instance.DbtRunAzureContainerInstanceOperator
+    description: Run `dbt run` in an Azure Container Instance.
+  - module: cosmos.operators.azure_container_instance.DbtRunOperationAzureContainerInstanceOperator
+    description: Run `dbt run-operation` in an Azure Container Instance.
+  - module: cosmos.operators.azure_container_instance.DbtSeedAzureContainerInstanceOperator
+    description: Run `dbt seed` in an Azure Container Instance.
+  - module: cosmos.operators.azure_container_instance.DbtSnapshotAzureContainerInstanceOperator
+    description: Run `dbt snapshot` in an Azure Container Instance.
+  - module: cosmos.operators.azure_container_instance.DbtSourceAzureContainerInstanceOperator
+    description: Run `dbt source freshness` in an Azure Container Instance.
+  - module: cosmos.operators.azure_container_instance.DbtTestAzureContainerInstanceOperator
+    description: Run `dbt test` in an Azure Container Instance.
+
+  # Run dbt commands as Google Cloud (GCP) Platform Cloud Run Jobs
+  - module: cosmos.operators.gcp_cloud_run_job.DbtBuildGcpCloudRunJobOperator
+    description: Run `dbt build` as a Google Cloud Run Job.
+  - module: cosmos.operators.gcp_cloud_run_job.DbtCloneGcpCloudRunJobOperator
+    description: Run `dbt clone` as a Google Cloud Run Job.
+  - module: cosmos.operators.gcp_cloud_run_job.DbtLSGcpCloudRunJobOperator
+    description: Run `dbt ls` as a Google Cloud Run Job.
+  - module: cosmos.operators.gcp_cloud_run_job.DbtRunGcpCloudRunJobOperator
+    description: Run `dbt run` as a Google Cloud Run Job.
+  - module: cosmos.operators.gcp_cloud_run_job.DbtRunOperationGcpCloudRunJobOperator
+    description: Run `dbt run-operation` as a Google Cloud Run Job.
+  - module: cosmos.operators.gcp_cloud_run_job.DbtSeedGcpCloudRunJobOperator
+    description: Run `dbt seed` as a Google Cloud Run Job.
+  - module: cosmos.operators.gcp_cloud_run_job.DbtSnapshotGcpCloudRunJobOperator
+    description: Run `dbt snapshot` as a Google Cloud Run Job.
+  - module: cosmos.operators.gcp_cloud_run_job.DbtSourceGcpCloudRunJobOperator
+    description: Run `dbt source freshness` as a Google Cloud Run Job.
+  - module: cosmos.operators.gcp_cloud_run_job.DbtTestGcpCloudRunJobOperator
+    description: Run `dbt test` as a Google Cloud Run Job.
+
+  # Watcher pattern (local)
+  # Run a single local `dbt build` or `dbt run` command per pipeline, via a producer task, and have Airflow deferrable sensors (consumers) tracking progress for individual dbt nodes.
+  - module: cosmos.operators.watcher.DbtProducerWatcherOperator
+    description: Run a single dbt command (build or run) for the entire dbt project and produce one XCom containing the status of each dbt node (model, seed, snapshot).
+  - module: cosmos.operators.watcher.DbtRunWatcherOperator
+    description: Monitor a dbt model using Airflow deferrable XCom sensors. On retry, executes `dbt run` for the specific model via `DbtRunLocalOperator`.
+  - module: cosmos.operators.watcher.DbtSeedWatcherOperator
+    description: Monitor a dbt seed using Airflow deferrable XCom sensors. On retry, executes `dbt seed` for the specific seed via `DbtSeedLocalOperator`.
+  - module: cosmos.operators.watcher.DbtSnapshotWatcherOperator
+    description: Monitor a dbt snapshot using Airflow deferrable XCom sensors. On retry, executes `dbt snapshot` for the specific snapshot via `DbtSnapshotLocalOperator`.
+  - module: cosmos.operators.watcher.DbtTestWatcherOperator
+    description: Runs `dbt test` using the local execution pattern, or acts as an `EmptyOperator` for `TestBehavior.AFTER_EACH`.
+
+  #  Watcher pattern (Kubernetes)
+  # Run a single `dbt build` or `dbt run` command per pipeline (producer), via a Kubernetes pod, and have Airflow deferrable sensors (consumers) tracking progress for individual dbt nodes.
+  - module: cosmos.operators.watcher_kubernetes.DbtProducerWatcherKubernetesOperator
+    description: Run a single dbt command (build or run) via a Kubernetes Pod Operator for the entire dbt project and produce one XCom containing the status of each dbt node (model, seed, snapshot).
+  - module: cosmos.operators.watcher_kubernetes.DbtRunWatcherKubernetesOperator
+    description: Monitor a dbt model using Airflow deferrable XCom sensors. On retry, executes `dbt run` for the specific model via `DbtRunKubernetesOperator`.
+  - module: cosmos.operators.watcher_kubernetes.DbtSeedWatcherKubernetesOperator
+    description: Monitor a dbt seed using Airflow deferrable XCom sensors. On retry, executes `dbt seed` for the specific seed via `DbtSeedKubernetesOperator`.
+  - module: cosmos.operators.watcher_kubernetes.DbtSnapshotWatcherKubernetesOperator
+    description: Monitor a dbt snapshot using Airflow deferrable XCom sensors. On retry, executes `dbt snapshot` for the specific snapshot via `DbtSnapshotKubernetesOperator`.
+  - module: cosmos.operators.watcher_kubernetes.DbtTestWatcherKubernetesOperator
+    description: Runs `dbt test` using the Kubernetes execution pattern, or acts as an `EmptyOperator` for `TestBehavior.AFTER_EACH`.
+
+other:
+  - module: cosmos.airflow.dag.DbtDag
+    description: Render a complete dbt project as an Airflow DAG
+  - module: cosmos.airflow.task_group.DbtTaskGroup
+    description: Render a dbt project as an Airflow Task Group

.codespell-ignore-words

@@ -0,0 +1 @@
+rin

.pre-commit-config.yaml

@@ -65,6 +65,7 @@ repos:
           - --exclude-file=tests/sample/manifest_model_version.json
           - --skip=**/manifest.json,**.min.js,**/manifest_source.json
           - -L connexion,aci
+          - --ignore-words=.codespell-ignore-words
   - repo: https://github.com/pre-commit/pygrep-hooks
     rev: v1.10.0
     hooks:

CHANGELOG.rst

@@ -1,6 +1,37 @@
 Changelog
 =========
 
+1.13.1 (2026-02-25)
+-------------------
+
+Enhancements
+
+* Change Snowflake profile mappings to default to four threads by @tatiana in #2374
+* Refactor to avoid potential future ``UnboundLocalError`` for ``producer_task`` in ``calculate_tasks_map`` by @rin in #2309
+
+Bug Fixes
+
+* Fix graph selector when using + selector with ``dbt-loom`` by @award1230 in #2389
+* Populate ``compiled_sql`` for ``InvocationMode.SUBPROCESS`` in ``ExecutionMode.WATCHER`` by @pankajkoti in #2319
+* Preserve ``extra_context`` for watcher consumer task instances by @pankajkoti in #2381
+* Fix watcher: respect ``deferrable=False`` from ``operator_args`` on consumer sensor by @pankajkoti in #2384
+* Error handle invalid YAML with ``LoadMode.DBT_MANIFEST`` and ``RenderConfig.selector`` by @jonbillings in #2316
+* Fix selecting model when it has the same name as folder by @pankajastro in #2328
+* Handle Param Validation errors by @tatiana in #2358
+* Fix cache swap issue by @jonbillings in #2332
+* Fix leaked semaphore warnings in Airflow 3 by resetting dbt adapters by @pankajkoti in #2335
+
+Docs
+
+* Document ``ExecutionMode.KUBERNETES`` limitations by @tatiana in #2326
+
+Others
+
+* Add .airflow-registry.yaml for Airflow Provider Registry by @kaxil in #2387
+* Improve test coverage for PR #2307 by @tatiana in #2308
+* Address feedback from code review #2389 by @evanvolgas in #2394
+
+
 1.13.0 (2026-01-30)
 ---------------------
 

README.rst

@@ -1,3 +1,9 @@
+.. License badge
+.. |license| image:: https://img.shields.io/:license-Apache%202-blue.svg
+    :target: https://www.apache.org/licenses/LICENSE-2.0.txt
+    :alt: License
+
+.. PyPI badges
 .. |fury| image:: https://badge.fury.io/py/astronomer-cosmos.svg
     :target: https://badge.fury.io/py/astronomer-cosmos
 

cosmos/__init__.py

@@ -10,7 +10,7 @@
 
 from cosmos import settings
 
-__version__ = "1.13.0"
+__version__ = "1.13.1"
 
 
 if not settings.enable_memory_optimised_imports:

cosmos/airflow/graph.py

@@ -288,7 +288,7 @@ def create_dbt_resource_to_class(test_behavior: TestBehavior) -> dict[str, str]:
     return dbt_resource_to_class
 
 
-def create_task_metadata(
+def create_task_metadata(  # noqa: C901
     node: DbtNode,
     execution_mode: ExecutionMode,
     args: dict[str, Any],
@@ -340,7 +340,10 @@ def create_task_metadata(
         models_select_key = "models" if settings.pre_dbt_fusion else "select"
 
         if render_config.test_behavior == TestBehavior.BUILD and node.resource_type in SUPPORTED_BUILD_RESOURCES:
-            args[models_select_key] = f"{node.resource_name}"
+            if node.fqn and len(node.fqn) > 0:
+                args[models_select_key] = f"fqn:{'.'.join(node.fqn)}"
+            else:
+                args[models_select_key] = f"{node.resource_name}"
             if test_indirect_selection != TestIndirectSelection.EAGER:
                 args["indirect_selection"] = test_indirect_selection.value
             args["on_warning_callback"] = on_warning_callback
@@ -390,7 +393,10 @@ def create_task_metadata(
                     args = {}
                 return TaskMetadata(id=task_id, operator_class="airflow.operators.empty.EmptyOperator", arguments=args)
         else:  # DbtResourceType.MODEL, DbtResourceType.SEED and DbtResourceType.SNAPSHOT
-            args[models_select_key] = node.resource_name
+            if node.fqn and len(node.fqn) > 0:
+                args[models_select_key] = f"fqn:{'.'.join(node.fqn)}"
+            else:
+                args[models_select_key] = node.resource_name
             task_id, args = _get_task_id_and_args(
                 node=node,
                 args=args,
@@ -853,6 +859,7 @@ def build_airflow_graph(  # noqa: C901 TODO: https://github.com/astronomer/astro
     """
     tasks_map: dict[str, TaskGroup | BaseOperator] = {}
     task_or_group: TaskGroup | BaseOperator | None
+    producer_task: BaseOperator | None = None
 
     # Identify test nodes that should be run detached from the associated dbt resource nodes because they
     # have multiple parents
@@ -947,8 +954,7 @@ def build_airflow_graph(  # noqa: C901 TODO: https://github.com/astronomer/astro
 
     create_airflow_task_dependencies(nodes, tasks_map)
 
-    if execution_mode in (ExecutionMode.WATCHER, ExecutionMode.WATCHER_KUBERNETES):
-        setup_operator_args = getattr(execution_config, "setup_operator_args", None) or {}
+    if producer_task:
         _add_watcher_dependencies(
             dag=dag,
             producer_airflow_task=producer_task,