You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I am trying to use the test_dag_integrity.py code on my own project.
Here is my directory structure:
root/
dags/
dag1.py
tests/
test_dag_integrity.py
In dag1.py, it imports several airflow operator like BigQueryOperator, SlackOperator, etc.
In test_dag_integrity.py, I modified the DAG_PATH = os.path.join(os.path.dirname(__file__), "..", "..", "dags/**.py")
-> DAG_PATH = os.path.join(os.path.dirname(__file__), "..", "dags/**.py")
to meet my directory structure.
Then I run pytest test_dag_integrity.py, it failed and the summary info is like: FAILED test_daily_pipeline_integration.py::test_dag_integrity[PATH\\TO\\MY\\DIRECTORY\\..\\dags\\ip_address_mapping.py] - ModuleNotFoundError: No module named 'airflow.providers.google'
Is there anything I missed?
Thanks !
The text was updated successfully, but these errors were encountered:
Hi,
I am trying to use the
test_dag_integrity.py
code on my own project.Here is my directory structure:
root/
In
dag1.py
, it imports several airflow operator like BigQueryOperator, SlackOperator, etc.In
test_dag_integrity.py
, I modified theDAG_PATH = os.path.join(os.path.dirname(__file__), "..", "..", "dags/**.py")
->
DAG_PATH = os.path.join(os.path.dirname(__file__), "..", "dags/**.py")
to meet my directory structure.
Then I run
pytest test_dag_integrity.py
, it failed and the summary info is like:FAILED test_daily_pipeline_integration.py::test_dag_integrity[PATH\\TO\\MY\\DIRECTORY\\..\\dags\\ip_address_mapping.py] - ModuleNotFoundError: No module named 'airflow.providers.google'
Is there anything I missed?
Thanks !
The text was updated successfully, but these errors were encountered: