How to resolve this AirflowProviderDeprecationWarning? #41326
Unanswered
shreyateeza
asked this question in
Q&A
Replies: 1 comment 6 replies
-
@shreyateeza in your DAG, you'll need to check for places in code where You'd simply need to replace those Update: For your reference, this deprecation warning was added in this PR. |
Beta Was this translation helpful? Give feedback.
6 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
ardvarc-airflow-worker-5db894c465-nr7l6
*** Found local files:
*** * /opt/airflow/logs/dag_id=spark_sql_operator_dag_2/run_id=manual__2024-08-08T08:47:20.718907+00:00/task_id=create_table_job/attempt=1.log
[2024-08-08, 08:47:32 UTC] {local_task_job_runner.py:120} ▶ Pre task execution logs
[2024-08-08, 08:47:32 UTC] {warnings.py:110} WARNING - /home/airflow/.local/lib/python3.12/site-packages/airflow/providers/apache/spark/operators/spark_sql.py:119: AirflowProviderDeprecationWarning: Call to deprecated function (or staticmethod) _sql. (
_sql
is deprecated and will be removed in the future. Please usesql
instead.)sql=self._sql,
[2024-08-08, 08:47:33 UTC] {taskinstance.py:441} ▶ Post task execution logs
Beta Was this translation helpful? Give feedback.
All reactions