Fix tests

Author: pankajastro

dagfactory/dagbuilder.py

@@ -354,7 +354,7 @@ def _clean_kpo_task_params(task_params: dict) -> dict:
     @staticmethod
     def _handle_http_sensor(operator_obj, task_params):
         # Only handle if HttpOperator/HttpSensor are available
-        if HTTP_OPERATOR_CLASS and isinstance(operator_obj, HTTP_OPERATOR_CLASS):
+        if HTTP_OPERATOR_CLASS and issubclass(operator_obj, HTTP_OPERATOR_CLASS):
             headers = task_params.get("headers", {})
             content_type = headers.get("Content-Type", "").lower()
 
@@ -388,7 +388,7 @@ def _handle_http_sensor(operator_obj, task_params):
                 # remove dag-factory specific parameters
                 # Airflow 2.0 doesn't allow these to be passed to operator
                 del task_params["response_check_lambda"]
-            return task_params
+        return task_params
 
     # pylint: disable=too-many-branches
     # pylint: disable=too-many-statements

scripts/test/pre-install-airflow.sh

@@ -36,7 +36,6 @@ if [ "$AIRFLOW_VERSION" = "3.0" ]; then
   uv pip install "apache-airflow>=3.0.2" --constraint /tmp/constraint.txt
 else
   uv pip install "apache-airflow==$AIRFLOW_VERSION" --constraint /tmp/constraint.txt
-  uv pip install apache-airflow-providers-cncf-kubernetes --constraint /tmp/constraint.txt
 fi;
 
 rm /tmp/constraint.txt