Ekansh Verma
10/11/2023, 7:59 AMkapa.ai
10/11/2023, 8:00 AMEkansh Verma
10/11/2023, 8:02 AMkapa.ai
10/11/2023, 8:02 AMairbyte_conn_id parameter is required when configuring the AirbyteTriggerSyncOperator. This parameter is used to specify the name of the Airflow HTTP Connection pointing at the Airbyte API, which tells Airflow where the Airbyte API is located. Without this parameter, Airflow would not know where to find the Airbyte API. Here is an example of how to use it in a DAG: python from airflow import DAG from airflow.utils.dates import days_ago from airflow.providers.airbyte.operators.airbyte import AirbyteTriggerSyncOperator with DAG(dag_id='trigger_airbyte_job_example', default_args={'owner': 'airflow'}, schedule_interval='@daily', start_date=days_ago(1) ) as dag: money_to_json = AirbyteTriggerSyncOperator( task_id='airbyte_money_json_example', airbyte_conn_id='airbyte_conn_example', connection_id='1e3b5a72-7bfd-4808-a13c-204505490110', asynchronous=False, timeout=3600, wait_seconds=3 ) In this example, airbyte_conn_id is set to 'airbyte_conn_example'. This should be replaced with the name of your Airflow HTTP Connection that points to your Airbyte API. For more information, you can refer to the [Airbyte documentation](https://docs.airbyte.com/operator-guides/using-the-airflow-airbyte-operator).