| :mod:`airflow.operators.dagrun_operator` |
| ======================================== |
| |
| .. py:module:: airflow.operators.dagrun_operator |
| |
| |
| Module Contents |
| --------------- |
| |
| .. py:class:: DagRunOrder(run_id=None, payload=None) |
| |
| Bases: :class:`object` |
| |
| |
| .. py:class:: TriggerDagRunOperator(trigger_dag_id, python_callable=None, execution_date=None, *args, **kwargs) |
| |
| Bases: :class:`airflow.models.BaseOperator` |
| |
| Triggers a DAG run for a specified ``dag_id`` |
| |
| :param trigger_dag_id: the dag_id to trigger (templated) |
| :type trigger_dag_id: str |
| :param python_callable: a reference to a python function that will be |
| called while passing it the ``context`` object and a placeholder |
| object ``obj`` for your callable to fill and return if you want |
| a DagRun created. This ``obj`` object contains a ``run_id`` and |
| ``payload`` attribute that you can modify in your function. |
| The ``run_id`` should be a unique identifier for that DAG run, and |
| the payload has to be a picklable object that will be made available |
| to your tasks while executing that DAG run. Your function header |
| should look like ``def foo(context, dag_run_obj):`` |
| :type python_callable: python callable |
| :param execution_date: Execution date for the dag (templated) |
| :type execution_date: str or datetime.datetime |
| |
| .. attribute:: template_fields |
| :annotation: = ['trigger_dag_id', 'execution_date'] |
| |
| |
| |
| .. attribute:: ui_color |
| :annotation: = #ffefeb |
| |
| |
| |
| |
| .. method:: execute(self, context) |
| |
| |
| |
| |
