remove callable functions parameter from kafka operator template_fields

apache · Sep 28, 2024 · 7f03fb2 · 7f03fb2
1 parent dc5d56b
commit 7f03fb2
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 2 deletions.
diff --git a/airflow/providers/apache/kafka/operators/consume.py b/airflow/providers/apache/kafka/operators/consume.py
@@ -68,7 +68,6 @@ class ConsumeFromTopicOperator(BaseOperator):
     ui_color = BLUE
     template_fields = (
         "topics",
-        "apply_function",
         "apply_function_args",
         "apply_function_kwargs",
         "kafka_config_id",

diff --git a/airflow/providers/apache/kafka/operators/produce.py b/airflow/providers/apache/kafka/operators/produce.py
@@ -67,7 +67,6 @@ class ProduceToTopicOperator(BaseOperator):
 
     template_fields = (
         "topic",
-        "producer_function",
         "producer_function_args",
         "producer_function_kwargs",
         "kafka_config_id",