airflow airbyte operator - module not found
Context
I'm using Airflow hosted on Google kubernetes engine, I've added apache-airflow-providers-airbyte 3.2.0 to the requirements.txt which is installed and appears on the Airflow - Admin > Providers" UI along with the default providers.
Blocker
A "ModuleNotFoundError: No module named 'airflow.providers.airbyte'" error appears for the following import
from airflow.providers.airbyte.operators.airbyte import AirbyteTriggerSyncOperator
from airflow.providers.airbyte.sensors.airbyte import AirbyteJobSensor
Solution
Missing dependency packages installed
- First time login to Apache Airflow asks for username and password, what is the username and password?
- Airflow - How to pass xcom variable into Python function
- Airflow versus AWS Step Functions for workflow
- How to set a number as retry condition in airflow DAG?
- Airflow timetable that combines multiple cron expressions?
- How to get jobId that was submitted using Dataproc Workflow Template
- External files in Airflow DAG
- Airflow Sync Dags from S3 Causes Dag Execution Error
- Connection error from GCP Composer (Airflow) to GCP PubSub
- airflow TriggerDagRunOperator how to change the execution date
- Access Forbidden while accessing log in airflow with CeleryExecutor
- How to manage python packages between airflow dags?
- Passing Parameters from ECS to Airflow XCom
- jinja2.exceptions.TemplateNotFound error with airflow bash operator
- [Airflow]: Dynamic Task Mapping on DockerOperator using Xcoms
- Airflow UI parameters not being passing on to DAG
- How to Trigger a DAG on the success of a another DAG in Airflow using Python?
- Airflow retry of multiple tasks as a group
- Airflow: Can't connect to ('0.0.0.0', 8080)
- Airflow - Stop DAG based on condition (skip remaining tasks after branch)
- Airflow webserver pod unable to get log from worker pod
- Datasets tab not showing in Airflow
- Altering "readtimeout" for Lambda Invoke in AirFlow
- Dynamic Task Mapping for http operator and query string
- Airflow DAG to retry if any of the Airflow Tasks fails
- Calling a Google cloud function within Airflow DAG
- Why function on_failure_callback for Airflow dag not running on task fail?
- Airflow ERROR - Error authorizing OAuth access token: Invalid JSON Web Key Set. [The request to sign in was denied.]
- How to combine multiple DAGs in Airflow
- Limiting concurrency of parallel task execution