Skip to content

TaskFlow API DAGs not recognized #7

Description

@monometa

Describe the bug
It seems that the library does not support TaskFlow API DAGs.

To Reproduce

Steps to reproduce the behavior:

  1. Copy the TaskFlow API DAG from the official docs: https://airflow.apache.org/docs/apache-airflow/stable/tutorial/taskflow.html#example-taskflow-api-pipeline
  2. Save it locally as example_dag.py
  3. Run the command: airflow-parse-bench --path example_dag.py
  4. Observe the error:

ERROR - No valid DAGs found in example_dag.py

Expected behavior
The library should support Airflow TaskFlow API DAGs and reflect parse time metrics

Screenshots

Image

Desktop (please complete the following information):

  • OS: Ubuntu

Metadata

Metadata

Labels

bugSomething isn't working

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions