(airflow) branch main updated: Delete get_python_source from Kubernetes decorator after bumping min airflow version to 2.6.0 (#36426)

[taragolis]

This is an automated email from the ASF dual-hosted git repository.

taragolis 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 ee219e658d Delete get_python_source from Kubernetes decorator after 
bumping min airflow version to 2.6.0 (#36426)
ee219e658d is described below

commit ee219e658da34d1ef6479c853338e9a33ae983ff
Author: Hussein Awala <huss...@awala.fr>
AuthorDate: Tue Dec 26 09:57:47 2023 +0100

    Delete get_python_source from Kubernetes decorator after bumping min 
airflow version to 2.6.0 (#36426)
---
 airflow/providers/cncf/kubernetes/decorators/kubernetes.py | 10 ----------
 1 file changed, 10 deletions(-)

diff --git a/airflow/providers/cncf/kubernetes/decorators/kubernetes.py 
b/airflow/providers/cncf/kubernetes/decorators/kubernetes.py
index a71905c97d..6e914a2d1f 100644
--- a/airflow/providers/cncf/kubernetes/decorators/kubernetes.py
+++ b/airflow/providers/cncf/kubernetes/decorators/kubernetes.py
@@ -17,10 +17,8 @@
 from __future__ import annotations
 
 import base64
-import inspect
 import os
 import pickle
-import textwrap
 import uuid
 from shlex import quote
 from tempfile import TemporaryDirectory
@@ -32,7 +30,6 @@ from kubernetes.client import models as k8s
 from airflow.decorators.base import DecoratedOperator, TaskDecorator, 
task_decorator_factory
 from airflow.providers.cncf.kubernetes.operators.pod import 
KubernetesPodOperator
 from airflow.providers.cncf.kubernetes.python_kubernetes_script import (
-    remove_task_decorator,
     write_python_script,
 )
 
@@ -77,13 +74,6 @@ class _KubernetesDecoratedOperator(DecoratedOperator, 
KubernetesPodOperator):
             **kwargs,
         )
 
-    # TODO: Remove me once this provider min supported Airflow version is 2.6
-    def get_python_source(self):
-        raw_source = inspect.getsource(self.python_callable)
-        res = textwrap.dedent(raw_source)
-        res = remove_task_decorator(res, self.custom_operator_name)
-        return res
-
     def _generate_cmds(self) -> list[str]:
         script_filename = "/tmp/script.py"
         input_filename = "/tmp/script.in"