diff --git a/task-sdk/src/airflow/sdk/definitions/_internal/templater.py b/task-sdk/src/airflow/sdk/definitions/_internal/templater.py index faf97bdd3f8eb..f094ccd6b2880 100644 --- a/task-sdk/src/airflow/sdk/definitions/_internal/templater.py +++ b/task-sdk/src/airflow/sdk/definitions/_internal/templater.py @@ -19,6 +19,7 @@ import datetime import logging +import os from collections.abc import Collection, Iterable, Sequence from dataclasses import dataclass from typing import TYPE_CHECKING, Any @@ -186,7 +187,7 @@ def render_template( if isinstance(value, ObjectStoragePath): return self._render_object_storage_path(value, context, jinja_env) - if resolve := getattr(value, "resolve", None): + if not isinstance(value, os.PathLike) and (resolve := getattr(value, "resolve", None)): return resolve(context) # Fast path for common built-in collections. diff --git a/task-sdk/tests/task_sdk/definitions/_internal/test_templater.py b/task-sdk/tests/task_sdk/definitions/_internal/test_templater.py index 5f37a71712bcc..bcce3c895470c 100644 --- a/task-sdk/tests/task_sdk/definitions/_internal/test_templater.py +++ b/task-sdk/tests/task_sdk/definitions/_internal/test_templater.py @@ -81,6 +81,26 @@ def test_not_render_literal_value(self): assert rendered_content == "Hello {{ name }}" + def test_render_template_pathlib_path_not_resolved(self): + """Test that pathlib.Path objects are not incorrectly resolved via their resolve() method. + + pathlib.Path has a resolve() method for filesystem resolution, which should not be + confused with the Resolvable.resolve(context) protocol used by the templater. + See: https://github.com/apache/airflow/issues/55412 + """ + import pathlib + + templater = Templater() + templater.template_ext = [] + context = {"ds": "2006-02-01"} + path = pathlib.PurePosixPath("/some/path/to/file.txt") + + rendered = templater.render_template(path, context) + + # The path should be returned as-is, not passed through resolve(context) + assert rendered == path + assert isinstance(rendered, pathlib.PurePosixPath) + def test_not_render_file_literal_value(self): templater = Templater() templater.template_ext = [".txt"]