remove callable functions parameter from kafka operator template_fiel…

…ds (apache#42555)
joaopamaral · Oct 21, 2024 · a4f8faa · a4f8faa
1 parent d12b835
commit a4f8faa
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",