jscheffl commented on issue #47920:
URL: https://github.com/apache/airflow/issues/47920#issuecomment-2795335613
I just did a regression with current main, assuming that #49005 fixes the
problem - using EdgeExecutor, LocalExecutor and DAG
providers/edge/src/airflow/providers/edge/example_dags/integration_test.py I
still get a consistent error:
```
[2025-04-10, 22:46:22] INFO - DAG bundles loaded: dags-folder, example_dags:
source="airflow.dag_processing.bundles.manager.DagBundlesManager"
[2025-04-10, 22:46:22] INFO - Filling up the DagBag from
/files/dags/integration_test.py: source="airflow.models.dagbag.DagBag"
[2025-04-10, 22:46:22] ERROR - Task failed with exception: source="task"
RuntimeError: Direct database access via the ORM is not allowed in Airflow
3.0
File "/opt/airflow/task-sdk/src/airflow/sdk/execution_time/task_runner.py",
line 775 in run
File "/opt/airflow/task-sdk/src/airflow/sdk/execution_time/task_runner.py",
line 1038 in _execute_task
File "/opt/airflow/task-sdk/src/airflow/sdk/bases/operator.py", line 409 in
wrapper
File "/opt/airflow/task-sdk/src/airflow/sdk/bases/decorator.py", line 251 in
execute
File "/opt/airflow/task-sdk/src/airflow/sdk/bases/operator.py", line 409 in
wrapper
File
"/opt/airflow/providers/standard/src/airflow/providers/standard/operators/python.py",
line 212 in execute
File
"/opt/airflow/providers/standard/src/airflow/providers/standard/operators/python.py",
line 235 in execute_callable
File
"/opt/airflow/task-sdk/src/airflow/sdk/execution_time/callback_runner.py", line
81 in run
File "/files/dags/integration_test.py", line 101 in variable
File "/opt/airflow/airflow-core/src/airflow/utils/session.py", line 101 in
wrapper
File "/usr/local/lib/python3.12/contextlib.py", line 137 in __enter__
File "/opt/airflow/airflow-core/src/airflow/utils/session.py", line 41 in
create_session
File "/opt/airflow/task-sdk/src/airflow/sdk/execution_time/supervisor.py",
line 215 in __init__
[2025-04-10, 22:46:22] INFO - Task instance is in running state:
chan="stdout": source="task"
[2025-04-10, 22:46:22] INFO - Previous state of the Task instance: queued:
chan="stdout": source="task"
[2025-04-10, 22:46:22] INFO - Current task name:variable: chan="stdout":
source="task"
[2025-04-10, 22:46:22] INFO - Dag name:integration_test: chan="stdout":
source="task"
```
DAG code snippet:
```
@task
def variable():
Variable.set("integration_test_key", "value")
if Variable.get("integration_test_key") != "value":
raise ValueError("Variable not set as expected.")
Variable.delete("integration_test_key")
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
