You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by el...@apache.org on 2023/12/31 09:09:16 UTC
(airflow) branch main updated: docs: `Add AzureSynapseRunPipelineOperator` (#36495)
This is an automated email from the ASF dual-hosted git repository.
eladkal 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 876b3fa372 docs: `Add AzureSynapseRunPipelineOperator` (#36495)
876b3fa372 is described below
commit 876b3fa372e4b8f6f10e3e736e6648195144a628
Author: Lymah123 <fi...@gmail.com>
AuthorDate: Sun Dec 31 10:09:09 2023 +0100
docs: `Add AzureSynapseRunPipelineOperator` (#36495)
* docs: `Add AzureSynapseRunPipelineOperator`
---------
Co-authored-by: Elad Kalif <45...@users.noreply.github.com>
---
.../operators/azure_synapse.rst | 11 +++++++++++
.../providers/microsoft/azure/example_synapse_run_pipeline.py | 4 ++--
2 files changed, 13 insertions(+), 2 deletions(-)
diff --git a/docs/apache-airflow-providers-microsoft-azure/operators/azure_synapse.rst b/docs/apache-airflow-providers-microsoft-azure/operators/azure_synapse.rst
index 41740c8b75..440e173d04 100644
--- a/docs/apache-airflow-providers-microsoft-azure/operators/azure_synapse.rst
+++ b/docs/apache-airflow-providers-microsoft-azure/operators/azure_synapse.rst
@@ -41,6 +41,17 @@ Below is an example of using this operator to execute a Spark application on Azu
:end-before: [END howto_operator_azure_synapse]
+AzureSynapseRunPipelineOperator
+-----------------------------------
+Use the: class:`~airflow.providers.microsoft.azure.operators.synapse.AzureSynapseRunPipelineOperator` to execute a pipeline application within Synapse Analytics.
+The operator will Execute a Synapse Pipeline.
+
+.. exampleinclude:: /../../tests/system/providers/microsoft/azure/example_synapse_run_pipeline.py
+ :language: python
+ :dedent: 4
+ :start-after: [START howto_operator_azure_synapse_run_pipeline]
+ :end-before: [END howto_operator_azure_synapse_run_pipeline]
+
Reference
---------
diff --git a/tests/system/providers/microsoft/azure/example_synapse_run_pipeline.py b/tests/system/providers/microsoft/azure/example_synapse_run_pipeline.py
index be11a665c4..659b5f7912 100644
--- a/tests/system/providers/microsoft/azure/example_synapse_run_pipeline.py
+++ b/tests/system/providers/microsoft/azure/example_synapse_run_pipeline.py
@@ -37,14 +37,14 @@ with DAG(
tags=["synapse", "example"],
) as dag:
begin = EmptyOperator(task_id="begin")
-
+ # [START howto_operator_azure_synapse_run_pipeline]
run_pipeline1 = AzureSynapseRunPipelineOperator(
task_id="run_pipeline1",
azure_synapse_conn_id="azure_synapse_connection",
pipeline_name="Pipeline 1",
azure_synapse_workspace_dev_endpoint="azure_synapse_workspace_dev_endpoint",
)
-
+ # [END howto_operator_azure_synapse_run_pipeline]
begin >> run_pipeline1
from tests.system.utils.watcher import watcher