93 Pull requests merged by 41 people

• KubernetesPodOperator: add base_container_name to the templated fields

  #47864 merged Mar 22, 2025

• docs: fix inconsistent list formatting in breeze installation guide

  #48082 merged Mar 22, 2025

• Change default executor to LocalExecutor

  #48092 merged Mar 22, 2025

• Add check=False to fix_group_permissions commands

  #48079 merged Mar 22, 2025

• Remove password extra - nothing uses those deps

  #48027 merged Mar 22, 2025

• Smaller distribution files

  #48089 merged Mar 22, 2025

• Add clarification for sql injection in Airflow security model

  #48016 merged Mar 22, 2025

• Update pre-commit setup docs to suggest uv

  #48074 merged Mar 22, 2025

• Add DNS endpoint support for GKE Hooks and Operators

  #48075 merged Mar 22, 2025

• serialize http transports contained in composite transport

  #47444 merged Mar 22, 2025

• Fix progress retrieval when parallel airflow-core tests are run

  #48100 merged Mar 22, 2025

• Remove breeze's top-level init file

  #48101 merged Mar 22, 2025

• Make the docker swarm service name customizable

  #47957 merged Mar 22, 2025

• Do not allow semicolon in partition_clause

  #48098 merged Mar 22, 2025

• Remove accidentally committed file

  #48096 merged Mar 22, 2025

• Remove unused webserver configs

  #48066 merged Mar 22, 2025

• Fixing permission for aws-credentials in pushing docs

  #48095 merged Mar 22, 2025

• Make wtforms optional for Providers Manager

  #48094 merged Mar 22, 2025

• Correcting AIRFLOW_ROOT_PATH to fix CI

  #48077 merged Mar 22, 2025

• Add dark/light mode to simple auth manager

  #48065 merged Mar 22, 2025

• Fix test directory structure for airflow-ctl distribution

  #48093 merged Mar 22, 2025

• Bump trove-classifiers from 2025.3.13.13 to 2025.3.19.19

  #48023 merged Mar 22, 2025

• Bump cadwyn min version to 5.1.3

  #48091 merged Mar 22, 2025

• Changing default_capacity to capacity for issue 47800

  #48032 merged Mar 22, 2025

• Swap contributing links to absolute links

  #48085 merged Mar 22, 2025

• Auth Manager should raise an invalid token error when the payload cann…

  #48056 merged Mar 22, 2025

• Backport 2.10: Unquote executor airflow.cfg variable to fix (#48064)

  #48084 merged Mar 21, 2025

• Fixing new update installer check errors in CI

  #48081 merged Mar 21, 2025

• Unquote executor airflow.cfg variable to fix #48042

  #48064 merged Mar 21, 2025

• [Metric] New ti.running metric with queue field label

  #47773 merged Mar 21, 2025

• [Internal API][only 2.10] Fix issue that task instance note field not possible to set via the internal api.

  #47769 merged Mar 21, 2025

• Update CODEOWNERS

  #48080 merged Mar 21, 2025

• Fix python operators errors when initialising plugins in virtualenv jinja script

  #48035 merged Mar 21, 2025

• Adding .vite from auth/managers to gitignore

  #48078 merged Mar 21, 2025

• Link graph to assets

  #48022 merged Mar 21, 2025

• initdb has been gone for a while. Log the correct command

  #48038 merged Mar 21, 2025

• Support @task.bash with Task SDK

  #48060 merged Mar 21, 2025

• Fixing upgrade checks on main

  #48073 merged Mar 21, 2025

• Handle none logical date and show dependency check for the relevant state

  #48067 merged Mar 21, 2025

• Fixes dag version interpolation in UI

  #48072 merged Mar 21, 2025

• Updating EC2 Operators and Sensors with AWS Base classes

  #47931 merged Mar 21, 2025

• Config improvments to using JWKS with the JWT code

  #48054 merged Mar 21, 2025

• Calculate retry eligibility before task runs

  #47996 merged Mar 21, 2025

• Move newsfragment about secret backends on workers to AIP-72 one

  #48069 merged Mar 21, 2025

• Update code owners to new airflow-core structure

  #48068 merged Mar 21, 2025

• Adding codeowners to task execution API

  #48053 merged Mar 21, 2025

• Add download button to export flowchart

  #47890 merged Mar 21, 2025

• Fix execution api server url in docker-compose

  #48061 merged Mar 21, 2025

• Fix api server command

  #48062 merged Mar 21, 2025

• Use SimpleAuthManager for standalone

  #48036 merged Mar 21, 2025

• Setting Airflow context Environment variables for operators

  #47644 merged Mar 21, 2025

• Move airflow sources to airflow-core package

  #47798 merged Mar 21, 2025

• Adding newsfragment for workers secrets backend

  #48047 merged Mar 21, 2025

• fix: Re-add configuring orm for OpenLineage's listener on scheduler

  #48049 merged Mar 21, 2025

• Adding codeowners to task sdk

  #48048 merged Mar 21, 2025

• add kalyan in CODEOWNERS

  #48045 merged Mar 21, 2025

• feat(api_fastapi): include asset id in asset nodes when calling "/ui/dependencies" and "/ui/structure/structure_data"

  #47381 merged Mar 21, 2025

• AIP-38 Fix SimpleAuthManager prefix

  #48025 merged Mar 21, 2025

• Refactor container image to persist msodbcsql18 eula acceptance

  #47982 merged Mar 21, 2025

• Move "create db from orm" to be a public method in db manager interface

  #48000 merged Mar 21, 2025

• Remove not needed mypy exception for airflowctl

  #48039 merged Mar 21, 2025

• Rename and Resolve conflict in airflowctl

  #48041 merged Mar 21, 2025

• fix inconsistence between the get_conn and run in WinRMHook

  #47229 merged Mar 20, 2025

• Export chain, chain_linear & cross_downstream

  #48033 merged Mar 20, 2025

• Reflect new base_container_status_polling_interval kwarg in the TaskDecoratorCollection type

  #47833 merged Mar 20, 2025

• Don't expect default connections to be present

  #47968 merged Mar 20, 2025

• Rename Breeze variables.env file to environment_variables.env

  #47998 merged Mar 20, 2025

• Improve handling around stopping/killing individual dag file processors

  #48019 merged Mar 20, 2025

• Bump various providers in preparation for Airflow 3.0.0b4

  #48013 merged Mar 20, 2025

• Fix check for asset expression in Schedule component

  #48020 merged Mar 20, 2025

• AIP-81 Move remote CLI code to airflowctl

  #47981 merged Mar 20, 2025

• Improve the error message when a DAG tries to access the DB.

  #48015 merged Mar 20, 2025

• Call init from auth managers only once

  #47869 merged Mar 20, 2025

• Bump OL provider for Airflow 3.0.0b4 release

  #48011 merged Mar 20, 2025

• AIP-38 Improve handling of mapped task group

  #48010 merged Mar 20, 2025

• fix: compat test test_provider_not_installed failing on main

  #48012 merged Mar 20, 2025

• Replace DAGs with dags in docs

  #47959 merged Mar 20, 2025

• Fix apache#47555: PostgreSQL URI driver issue

  #47709 merged Mar 20, 2025

• Set simple auth manager as default

  #47691 merged Mar 20, 2025

• Move Secrets Backend for Variables & Connections support to Task SDK

  #47946 merged Mar 20, 2025

• docs(newsfragments): migration rules format/content fix

  #47991 merged Mar 20, 2025

• fix(asset): allow extra in Metadata to be optional

  #47997 merged Mar 20, 2025

• feat: Add helper for any provider version check

  #47909 merged Mar 20, 2025

• Introduce API versioning into the Execution API

  #47951 merged Mar 20, 2025

• Add lower-binding for microsoft azure/winrm providers

  #47990 merged Mar 20, 2025

• Implement on_execute_callback in task sdk

  #47989 merged Mar 20, 2025

• Xcoms object storage doc clean

  #47924 merged Mar 20, 2025

• Update task lifecycle diagram for missing states

  #46056 merged Mar 20, 2025

• Add Create Connection button and form on connection page

  #47868 merged Mar 20, 2025

• docs: fix numbered list

  #47978 merged Mar 20, 2025

• AIP-84 Move public api under /api/v2

  #47760 merged Mar 19, 2025

• Default to the FabAuthManager in the chart

  #47976 merged Mar 19, 2025

• AIP-81 - API Communication Mechanism

  #45300 merged Mar 19, 2025

27 Pull requests opened by 22 people

• Added step to install docker compose in MacOs

  #47979 opened Mar 20, 2025

• Update taskflow.rst

  #47984 opened Mar 20, 2025

• feat(providers): add infisical secret backend

  #47986 opened Mar 20, 2025

• Add new DataflowJobStateCompleteTrigger

  #47993 opened Mar 20, 2025

• Fix #47671: Task name and status overlap in Airflow 3 grid view

  #47994 opened Mar 20, 2025

• Improve DatabricksRunNowOperator docs and document job parameter support

  #47995 opened Mar 20, 2025

• fix: add explicit requirement for OpenLineage provider>=2.0.0 on OL function

  #47999 opened Mar 20, 2025

• Implement on-success and -on-skipped callbacks

  #48002 opened Mar 20, 2025

• Use time.time() for dag file process start time

  #48004 opened Mar 20, 2025

• Disable starting a mapped task from trigger

  #48006 opened Mar 20, 2025

• (Re)move old dependencies from the old FAB UI

  #48007 opened Mar 20, 2025

• Move BaseNotifier to Task SDK

  #48008 opened Mar 20, 2025

• Update example dags to import `DAG`, `Asset` etc from Task SDK

  #48014 opened Mar 20, 2025

• Remove deprecated for February and March 2025 in providers/google.

  #48018 opened Mar 20, 2025

• Backfill "get existing run" query did not filter by dag_id

  #48029 opened Mar 20, 2025

• docs(deferring): Example of deferring multiple times

  #48030 opened Mar 20, 2025

• fix broken link - Update dynamic-dag-generation.rst

  #48031 opened Mar 20, 2025

• test: k8s set [api/base_url] with Helm in Breeze

  #48040 opened Mar 20, 2025

• Fix float overflow for retry_exponential_backoff

  #48051 opened Mar 21, 2025

• Fix exponential backoff float overflow

  #48057 opened Mar 21, 2025

• Checking modification timestamps only when `newer_than` is present

  #48063 opened Mar 21, 2025

• Remove FAB db manager as an `external_db_managers` default

  #48070 opened Mar 21, 2025

• Add backwards compatibility for `DatasetOrTimeSchedule`

  #48097 opened Mar 22, 2025

• AIP-81 airflowctl Include CI/breeze unit-testing and some distribution commands

  #48099 opened Mar 22, 2025

• Add Edit connection button on list connection page

  #48102 opened Mar 22, 2025

• Minifix close BaseK8STest.session only if session is set

  #48103 opened Mar 22, 2025

• Properly set JWT token in breeze

  #48106 opened Mar 22, 2025

26 Issues closed by 17 people

• Add support for active session timeout in Airflow Web UI

  #48076 closed Mar 22, 2025

• xmlsec==1.3.15 update on March 11/2025 breaks apache-airflow-providers-amazon builds in Ubuntu running Python 3.11+

  #48083 closed Mar 22, 2025

• Configuration default should now be LocalExecutor instead of SequentialExecutor

  #48086 closed Mar 22, 2025

• Kubernetes executor pod reconcilation is slow due to recurssive deep copy

  #37131 closed Mar 22, 2025

• DAG version is not interpolated in UI

  #48058 closed Mar 22, 2025

• Rename the triggerer's `default_capacity` config to just `capacity`

  #47800 closed Mar 22, 2025

• API sever crashing when used FabAuthManager

  #48044 closed Mar 22, 2025

• Core Executor shouldn't be in quotes when using multiple executors concurrently

  #48042 closed Mar 21, 2025

• Get `BranchExternalPythonOperator` with Task SDK

  #47854 closed Mar 21, 2025

• Support `@task.bash` with Task SDK

  #45639 closed Mar 21, 2025

• Export react-flow dag graph

  #46285 closed Mar 21, 2025

• Airflow context Env variables are not set when using PythonOperator

  #46418 closed Mar 21, 2025

• AIP-84 Add asset.id to Dag Dependencies Graph

  #47163 closed Mar 21, 2025

• @dag imported from airflow.sdk fails with `AttributeError: 'DAG' object has no attribute 'get_run_data_interval'`

  #48034 closed Mar 21, 2025

• Move "create db from orm" to be a public method in db manager interface

  #47975 closed Mar 21, 2025

• Winrm hook, run can't be called twice

  #46668 closed Mar 20, 2025

• AIP-38 | Connections Add

  #47496 closed Mar 20, 2025

• Getting 403 forbidden while creating namespaced pod

  #48024 closed Mar 20, 2025

• AIP-81 Airflow CLI - Move Outside from Airflow Core

  #47972 closed Mar 20, 2025

• Clicking on Task inside a Mapped Task Group fails on the UI

  #47784 closed Mar 20, 2025

• PostgreSQL Connection URI Incorrectly Formatted in BaseHook.get_connection('conn_id').get_uri()

  #47555 closed Mar 20, 2025

• Move Secrets Backend for Variables & Connections support to Task SDK

  #45435 closed Mar 20, 2025

• clean duplications of Xcom backend docs from core

  #47891 closed Mar 20, 2025

• Missing states in task state lifecycle diagram

  #40185 closed Mar 20, 2025

• AIP-84 Move `public` api under `/v2`

  #47624 closed Mar 19, 2025

• AIP-81 Central API Communication Mechanism for CLI

  #42561 closed Mar 19, 2025

15 Issues opened by 11 people

• Secrets Masker also applies masking to fields not in scope

  #48105 opened Mar 22, 2025

• Order Variables, Pools and Connections lists by ID as default

  #48104 opened Mar 22, 2025

• Error in example_dags because of base sensor change

  #48088 opened Mar 22, 2025

• Import error with DatasetOrTimeSchedule

  #48087 opened Mar 21, 2025

• Add connection button taking some time to get enabled

  #48050 opened Mar 21, 2025

• KPO mapped task failing

  #48026 opened Mar 20, 2025

• Task Execution API: Implement default version handling for no header

  #48021 opened Mar 20, 2025

• Display asset watchers in Dag graph

  #48017 opened Mar 20, 2025

• Restore support of starting mapped tasks from triggerer

  #48009 opened Mar 20, 2025

• Result of expanded task is None instead of empty list when all mapped tasks return None

  #48005 opened Mar 20, 2025

• Add more fields to XCom View

  #48003 opened Mar 20, 2025

• Airflow not retrying when capacity not available at AWS ECS hook

  #48001 opened Mar 20, 2025

• Task instance state metrics (ti.start/finish) not appearing in Prometheus via OpenTelemetry

  #47992 opened Mar 20, 2025

• Do not call runtime-checks api from the task sdk anymore

  #47988 opened Mar 20, 2025

• DatabricksNotebookOperator generating invalid dependency graph

  #47983 opened Mar 20, 2025

73 Unresolved conversations

Sometimes conversations happen on old items that aren’t yet closed. Here is a list of all the Issues and Pull Requests with unresolved conversations.

• Provide an alternative OpenTelemetry implementation for traces that follows standard otel practices

  #43941 commented on Mar 22, 2025 • 9 new comments

• Render stacktraces properly

  #47965 commented on Mar 21, 2025 • 5 new comments

• Fix #44443: DAGs state change from running to queued, when paused, to avoid the increment of their duration

  #47557 commented on Mar 21, 2025 • 4 new comments

• Remove `subdir` command from task commands

  #47837 commented on Mar 21, 2025 • 2 new comments

• Adds support for hiding columns in datatable

  #47826 commented on Mar 20, 2025 • 2 new comments

• feat: implementation of BaseOperatorLink for cloud run jobs to expose the GCP cloud logging url

  #46911 commented on Mar 21, 2025 • 1 new comment

• feat: inject OpenLineage configuration to SparkSubmitOperator

  #47508 commented on Mar 21, 2025 • 0 new comments

• Create Apache TinkerPop provider

  #47446 commented on Mar 21, 2025 • 0 new comments

• Create operators for working with Ray for VertexAI

  #47340 commented on Mar 20, 2025 • 0 new comments

• improve(xcom): validate key in XCom.set() to prevent empty strings

  #46929 commented on Mar 21, 2025 • 0 new comments

• Add Branch Protection for v3-0-stable and v3-0-test

  #46305 commented on Mar 22, 2025 • 0 new comments

• Add v3-0-stable and v3-0-test branches to codecov

  #46304 commented on Mar 22, 2025 • 0 new comments

• Refactoring : adding extension to INSTALL file

  #46174 commented on Mar 22, 2025 • 0 new comments

• Pass specific env vars to logGroomerSideCar

  #45483 commented on Mar 22, 2025 • 0 new comments

• [OpenLineage] Added Openlineage support for DatabricksCopyIntoOperator

  #45257 commented on Mar 22, 2025 • 0 new comments

• Use custom dag_folder not settings.DAGS_FOLDER for FileLoadStat

  #45073 commented on Mar 22, 2025 • 0 new comments

• Add request-reply operator to Microsoft Azure provider

  #44675 commented on Mar 21, 2025 • 0 new comments

• Remove call to metadata API

  #47956 commented on Mar 20, 2025 • 0 new comments

• Update min version of Celery library to 5.5.0

  #43777 commented on Mar 21, 2025 • 0 new comments

• K8S Test: Set `[api/base_url]` with Helm in `Breeze`

  #47939 commented on Mar 22, 2025 • 0 new comments

• Airflow Scheduler Error with LocalExecutor: 'QueuedLocalWorker' object has no attribute 'wrapper'

  #45235 commented on Mar 22, 2025 • 0 new comments

• add message_id, reply_to, and message_headers to send message operator

  #47522 commented on Mar 21, 2025 • 0 new comments

• Implement middleware to prevent regexp parameters and payload

  #47543 commented on Mar 21, 2025 • 0 new comments

• Added Fastapi endpoint for reserialize_dags

  #47943 commented on Mar 22, 2025 • 0 new comments

• Remove google provider dependencies from apache-kafka provider

  #47563 commented on Mar 20, 2025 • 0 new comments

• feat: inject OpenLineage configuration to LivyOperator

  #47564 commented on Mar 21, 2025 • 0 new comments

• Move `GitDagBundle` to providers

  #47636 commented on Mar 22, 2025 • 0 new comments

• feat: Send dedicated OpenLineage events for each Snowflake query_id

  #47736 commented on Mar 20, 2025 • 0 new comments

• Add S3 docs publishing scripts

  #47814 commented on Mar 22, 2025 • 0 new comments

• AIP-38 :: created new dag warning banner added to dag details page

  #47821 commented on Mar 21, 2025 • 0 new comments

• Feature/aip 38 47429 add expand collapse

  #47843 commented on Mar 21, 2025 • 0 new comments

• Implement multisort in DAGs table

  #47849 commented on Mar 21, 2025 • 0 new comments

• Add documentation on handling PGBouncer with separate Schema

  #47910 commented on Mar 20, 2025 • 0 new comments

• Document working with "sqlalchemy>0.2.0" in virtualenvs and the induced side-effects

  #47914 commented on Mar 20, 2025 • 0 new comments

• tests: Add more tests to verify how OpenLineage is serializing Airflow models

  #47915 commented on Mar 20, 2025 • 0 new comments

• Add support for changing graph orientation

  #47923 commented on Mar 20, 2025 • 0 new comments

• Handle missing container_statuses in pod_manager.get_container_status

  #47936 commented on Mar 20, 2025 • 0 new comments

• Make Open Telemetry the default instead of StatsD for monitoring

  #40800 commented on Mar 20, 2025 • 0 new comments

• Dependency to FAB is removed in Connection Forms

  #42016 commented on Mar 20, 2025 • 0 new comments

• Port Taskflow decorators over to Task SDK

  #45436 commented on Mar 20, 2025 • 0 new comments

• Task SDK cannot upload remote logs due to missing handlers

  #47634 commented on Mar 20, 2025 • 0 new comments

• Ensure Notifiers and task callbacks work with Task SDK

  #45424 commented on Mar 20, 2025 • 0 new comments

• DAG Version history not showing in GRID view

  #47857 commented on Mar 20, 2025 • 0 new comments

• AIP-84 Add GET User Permissions endpoint

  #47412 commented on Mar 20, 2025 • 0 new comments

• Provide users choice of timezone to `FileTaskHandler`, for log timestamp formatting

  #44376 commented on Mar 20, 2025 • 0 new comments

• Add functionality to DatabricksHook to create notebooks

  #22330 commented on Mar 20, 2025 • 0 new comments

• DatabricksWorkflowOperator do not update ACL on workflow reset

  #45738 commented on Mar 20, 2025 • 0 new comments

• ExternalTaskSensor is failing when logical_date is null

  #47447 commented on Mar 20, 2025 • 0 new comments

• Refactor `BaseSensorOperator` to support Reschedule mode with Task SDK

  #45580 commented on Mar 20, 2025 • 0 new comments

• Function decorated by 'asset.multi' is not asset alias

  #47846 commented on Mar 20, 2025 • 0 new comments

• EmrServerlessStartJobOperator does not cancel EMR Serverless job when waiter_max_attempts is reached

  #42401 commented on Mar 20, 2025 • 0 new comments

• Add pre-commit to format chart templates

  #30546 commented on Mar 20, 2025 • 0 new comments

• Dataset extra fields set in Task outlets are not accessible

  #35297 commented on Mar 20, 2025 • 0 new comments

• Generate database ERD using chartdb

  #46057 commented on Mar 20, 2025 • 0 new comments

• job table missing `dag_id` and `executor_class` for BackfillJob type

  #40055 commented on Mar 20, 2025 • 0 new comments

• AIP-38 | Connections Edit

  #47497 commented on Mar 22, 2025 • 0 new comments

• Retry exponential backoff max float overflow

  #47971 commented on Mar 22, 2025 • 0 new comments

• Refactor core_api `test_client` to add api prefix automatically

  #47977 commented on Mar 22, 2025 • 0 new comments

• AIP-81 Trasition of Remote Commands

  #45661 commented on Mar 22, 2025 • 0 new comments

• Setting a variable in Dag is failing due to 'Direct database access via the ORM is not allowed in Airflow 3.0'

  #47920 commented on Mar 22, 2025 • 0 new comments

• LocalExecutor causes scheduler crash when API server returns error response

  #47873 commented on Mar 22, 2025 • 0 new comments

• Scheduler crashes on expanding a task with a literal list

  #47735 commented on Mar 22, 2025 • 0 new comments

• AIP-84 Custom list assets endpoint with latest event

  #47164 commented on Mar 22, 2025 • 0 new comments

• AIP-38 | Serialize connection types to database

  #47502 commented on Mar 21, 2025 • 0 new comments

• remove pickle_id column (and other related stuff?)

  #42276 commented on Mar 21, 2025 • 0 new comments

• Dagrun with null logical date results in task-sdk API error

  #47612 commented on Mar 21, 2025 • 0 new comments

• get_uri() is not implemented in task sdk

  #47919 commented on Mar 21, 2025 • 0 new comments

• Issues while reading Xcom values

  #46513 commented on Mar 21, 2025 • 0 new comments

• 3.10.3 apache-airflow-providers-celery release is broken

  #47781 commented on Mar 21, 2025 • 0 new comments

• [Regression] Argument 'extra' should be optional when pushing metadata to alias

  #47779 commented on Mar 21, 2025 • 0 new comments

• Support deferral mode for `TriggerDagRunOperator` with Task SDK

  #47949 commented on Mar 21, 2025 • 0 new comments

• Switch all example DAGs and docs to use `from airflow.sdk import DAG`

  #47851 commented on Mar 21, 2025 • 0 new comments

• Too many requests

  #47950 commented on Mar 21, 2025 • 0 new comments