Skip to content

Airflow Demo: Extend to show 3.x new features #223

Closed

Description

@adwk67

Description

Airflow 3.x brings with it significant changes to the architecture (UI, services, auth backends etc.) as well as new features. These (new features) do not figure in our demo and it would be good to showcase some of them e.g.

  • run a deferred DAG using the triggerer service
  • illustrate using a DAG bundle
  • incorporate Opa authorisation

Motivation

  • tests things not covered by integration tests
  • used as a basis for answering support questions
  • motivate users to migrate to 3.x+

PRs

Activity

  1. assigned and unassigned on Sep 10, 2025
  2. lfrancke commented on Sep 25, 2025

    @lfrancke
    Member

    During refinement decide the scope of the demo and the new features to demonstrate.

  3. moved this to Selected for Development in Stackable End-to-End Coordinationon Oct 7, 2025
  4. moved this from Selected for Development to In Refinement in Stackable End-to-End Coordinationon Oct 14, 2025
  5. self-assigned this
    on Oct 14, 2025
  6. moved this to Refinement: In Progress in Stackable Engineeringon Oct 14, 2025
  7. adwk67 commented on Oct 14, 2025

    @adwk67
    MemberAuthor

    Suggested Scope

    See e.g. the 3.0.0 release notes for major changes.
    Use the latest product image (3.1.0) for the demo.

    1. Run a deferred DAG using the triggerer service

    There is an integration test that uses the triggerer, and then can used as a basis for mounting a DAG that makes use of TimeDeltaTrigger (or similar), illustrating a) delayed DAG runs, and maybe b) DAG runs that persist across a re-start.

    • mount a deferrable DAG and show triggerer use (S)

    2. DAG bundles

    The documentation is a little thin regarding DAG bundles, but they are basically intended to extend previous the DAGS_FOLDER (allowing DAGs to be fetched from an S3 bucket or a git repo). We already have gitsync integration (via gitsync in our images) so it does not make much sense to use another git mechanism.

    • write a custom DAG bundle and show how its versions are displayed in the UI (S)
    • mount a DAG to S3 and load it from there (M)

    3. Validate DAGs with ruff prior to migration

    • show one or two examples of checking DAGs, similar to here (S)

    4. OPA authorizer

    We also have an integration test and documentation for this, so the demo would not need to do anything "new" but present existing functionality in a more step-by-step manner (also mentioning how the plugin works).

    • use the existing docs to display the same in a demo (S)

    5. Event-driven DAG runs

    It is now possible for DAGs to react to events external to Airflow. There is an out-of-the-box example available with 3.0, but it would be nice to Stackable-ize this and show Airflow reacting to e.g. a message being written from Nifi to Kafka.

    • (Nifi -->) Kafka --> start a DAG (M/L)

    6. (Optional): HITL workflow

    See https://airflow.apache.org/blog/airflow-3.1.0/#-human-in-the-loop-hitl-when-automation-meets-human-judgment. Can't really think of a stackable-specific example for this... (M/L)

  8. moved this from Refinement: In Progress to Refinement Acceptance: Waiting for in Stackable Engineeringon Oct 14, 2025
  9. lfrancke commented on Oct 15, 2025

    @lfrancke
    Member

    @adwk67 and I looked at the items together and decided on this plan.

    • Do (in order) items 5, 1 and 4 (integrate them into a demo)
    • Create a troubleshooting article for 3
    • Leave out/skip 2 and 6 (at least for now)

    Maintaining demos is a lot of work so we've tried focusing on things that highlight our platform and not just demonstrate Airflow features.

  10. moved this from Refinement Acceptance: Waiting for to Development: In Progress in Stackable Engineeringon Oct 15, 2025
  11. moved this from In Refinement to In Progress in Stackable End-to-End Coordinationon Oct 15, 2025
  12. moved this from Development: In Progress to Development: Waiting for Review in Stackable Engineeringon Oct 27, 2025
  13. moved this from Development: Waiting for Review to Development: In Review in Stackable Engineeringon Oct 27, 2025
  14. adwk67 commented on Oct 28, 2025

    @adwk67
    MemberAuthor

    Release notes snippet

    The Airflow scheduled-job demo has been extended to showcase some of the new Airflow 3.x features in the context of SDP i.e. event scheduling (with Kafka), triggerer actions and user authorization with OPA and the SDP OPA authorizer.

  15. moved this from Development: In Review to Development: Done in Stackable Engineeringon Oct 28, 2025
  16. moved this from Development: Done to Development: In Review in Stackable Engineeringon Oct 28, 2025
  17. moved this from Development: In Review to Development: Done in Stackable Engineeringon Oct 28, 2025
  18. moved this from In Progress to Done in Stackable End-to-End Coordinationon Oct 29, 2025
  19. moved this from Development: Done to Acceptance: In Progress in Stackable Engineeringon Nov 4, 2025
  20. added
    release-noteDenotes a PR that will be considered when it comes time to generate release notes.
    on Nov 4, 2025
  21. moved this from Acceptance: In Progress to Done in Stackable Engineeringon Nov 4, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

Labels

release-noteDenotes a PR that will be considered when it comes time to generate release notes.release/25.11.0

Type

No type

Projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions