This is an automated email from the ASF dual-hosted git repository.
vincbeck pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new b4744b10d70 Add redis_conn_id to RedisPublishOperator template_fields
(#72883)
b4744b10d70 is described below
commit b4744b10d70c5629da2267e1259e05429db1c32a
Author: gyeongdeok kim <[email protected]>
AuthorDate: Fri Sep 11 01:36:11 2026 +0900
Add redis_conn_id to RedisPublishOperator template_fields (#72883)
---
.../redis/src/airflow/providers/redis/operators/redis_publish.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/providers/redis/src/airflow/providers/redis/operators/redis_publish.py
b/providers/redis/src/airflow/providers/redis/operators/redis_publish.py
index abdb3f647bc..5d4f2baec1e 100644
--- a/providers/redis/src/airflow/providers/redis/operators/redis_publish.py
+++ b/providers/redis/src/airflow/providers/redis/operators/redis_publish.py
@@ -33,10 +33,10 @@ class RedisPublishOperator(BaseOperator):
:param channel: redis channel to which the message is published (templated)
:param message: the message to publish (templated)
- :param redis_conn_id: redis connection to use
+ :param redis_conn_id: redis connection to use (templated)
"""
- template_fields: Sequence[str] = ("channel", "message")
+ template_fields: Sequence[str] = ("channel", "message", "redis_conn_id")
def __init__(self, *, channel: str, message: str, redis_conn_id: str =
"redis_default", **kwargs) -> None:
super().__init__(**kwargs)
