This is an automated email from the ASF dual-hosted git repository.
potiuk 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 2bc86179773 Remove internal api call decorator from trigger_dag.py
(#44490)
2bc86179773 is described below
commit 2bc8617977375f6b90f2bab7cfc1685e6894ec96
Author: Shahar Epstein <60007259+shah...@users.noreply.github.com>
AuthorDate: Fri Nov 29 23:59:43 2024 +0200
Remove internal api call decorator from trigger_dag.py (#44490)
---
airflow/api/common/trigger_dag.py | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/airflow/api/common/trigger_dag.py
b/airflow/api/common/trigger_dag.py
index 6891cc1df78..054e9a5c2ac 100644
--- a/airflow/api/common/trigger_dag.py
+++ b/airflow/api/common/trigger_dag.py
@@ -22,7 +22,6 @@ from __future__ import annotations
import json
from typing import TYPE_CHECKING
-from airflow.api_internal.internal_api_call import internal_api_call
from airflow.exceptions import DagNotFound, DagRunAlreadyExists
from airflow.models import DagBag, DagModel, DagRun
from airflow.models.dag_version import DagVersion
@@ -108,7 +107,6 @@ def _trigger_dag(
return dag_run
-@internal_api_call
@provide_session
def trigger_dag(
dag_id: str,
@@ -124,12 +122,12 @@ def trigger_dag(
Triggers execution of DAG specified by dag_id.
:param dag_id: DAG ID
+ :param triggered_by: the entity which triggers the dag_run
:param run_id: ID of the dag_run
:param conf: configuration
:param logical_date: date of execution
:param replace_microseconds: whether microseconds should be zeroed
:param session: Unused. Only added in compatibility with database
isolation mode
- :param triggered_by: the entity which triggers the dag_run
:return: first dag run triggered - even if more than one Dag Runs were
triggered or None
"""
dag_model = DagModel.get_current(dag_id)
