Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion airflow-core/docs/core-concepts/dags.rst
Original file line number Diff line number Diff line change
Expand Up @@ -367,7 +367,7 @@ The ``@task.branch`` can also be used with XComs allowing branching context to d
If you wish to implement your own operators with branching functionality, you can inherit from :class:`~airflow.operators.branch.BaseBranchOperator`, which behaves similarly to ``@task.branch`` decorator but expects you to provide an implementation of the method ``choose_branch``.

.. note::
The ``@task.branch`` decorator is recommended over directly instantiating :class:`~airflow.providers.standard.operators.python.BranchPythonOperator` in a Dag. The latter should generally only be subclassed to implement a custom operator.
The ``@task.branch`` decorator is the Taskflow equivalent of :class:`~airflow.providers.standard.operators.python.BranchPythonOperator`. The latter should generally only be subclassed to implement a custom operator.

As with the callable for ``@task.branch``, this method can return the ID of a downstream task, or a list of task IDs, which will be run, and all others will be skipped. It can also return None to skip all downstream task::

Expand Down
4 changes: 2 additions & 2 deletions providers/snowflake/docs/operators/snowpark.rst
Original file line number Diff line number Diff line change
Expand Up @@ -28,9 +28,9 @@ Use the :class:`SnowparkOperator <airflow.providers.snowflake.operators.snowpark
Currently, this operator does not support `Snowpark pandas API <https://docs.snowflake.com/en/developer-guide/snowpark/python/pandas-on-snowflake>`__ because conflicting pandas version is used in Airflow.
Consider using Snowpark pandas API with other Snowpark decorators or operators.

.. tip::
.. note::

The :doc:`@task.snowpark </decorators/snowpark>` decorator is recommended over the ``SnowparkOperator`` to run Snowpark Python code.
The :doc:`@task.snowpark </decorators/snowpark>` decorator is the Taskflow equivalent of ``SnowparkOperator`` to run Snowpark Python code.

Prerequisite Tasks
^^^^^^^^^^^^^^^^^^
Expand Down