This is an automated email from the ASF dual-hosted git repository.
ash 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 1e1b212 Updating Airbyte example DAG to use XComArgs (#16867)
1e1b212 is described below
commit 1e1b212417e089b43474bc19eec05b654afe98fb
Author: josh-fell <[email protected]>
AuthorDate: Thu Jul 8 06:18:51 2021 -0400
Updating Airbyte example DAG to use XComArgs (#16867)
---
.../airbyte/example_dags/example_airbyte_trigger_job.py | 10 +++-------
1 file changed, 3 insertions(+), 7 deletions(-)
diff --git
a/airflow/providers/airbyte/example_dags/example_airbyte_trigger_job.py
b/airflow/providers/airbyte/example_dags/example_airbyte_trigger_job.py
index 1ac62a8..ff6d711 100644
--- a/airflow/providers/airbyte/example_dags/example_airbyte_trigger_job.py
+++ b/airflow/providers/airbyte/example_dags/example_airbyte_trigger_job.py
@@ -25,13 +25,8 @@ from airflow.providers.airbyte.operators.airbyte import
AirbyteTriggerSyncOperat
from airflow.providers.airbyte.sensors.airbyte import AirbyteJobSensor
from airflow.utils.dates import days_ago
-args = {
- 'owner': 'airflow',
-}
-
with DAG(
dag_id='example_airbyte_operator',
- default_args=args,
schedule_interval=None,
start_date=days_ago(1),
dagrun_timeout=timedelta(minutes=60),
@@ -56,9 +51,10 @@ with DAG(
airbyte_sensor = AirbyteJobSensor(
task_id='airbyte_sensor_source_dest_example',
-
airbyte_job_id="{{task_instance.xcom_pull(task_ids='airbyte_async_source_dest_example')}}",
+ airbyte_job_id=async_source_destination.output,
airbyte_conn_id='airbyte_default',
)
# [END howto_operator_airbyte_asynchronous]
- async_source_destination >> airbyte_sensor
+ # Task dependency created via `XComArgs`:
+ # async_source_destination >> airbyte_sensor
