Skip to content

Triggerer code does not seem to be able to use an Airflow connection & variable  #48183

Description

@pankajkoti

Apache Airflow version

main (development)

If "Other Airflow 2 version" selected, which one?

No response

What happened?

I am building a new deferrable operator in the databricks provider. Although the synchronous version of the operator seems to work fine, when using deferrable=True, it's complaining that the Airflow connection isn't defined. Likely it appears that the Triggerer is not fetching the Airflow connection or is failing to fetch the connection.

What you think should happen instead?

The Triggerer code should be able to use the Airflow connections so that the deferrable operators work fine.

How to reproduce

Run an example DAG with an Airflow operator with deferrable=True that tries to use an Airflow connection

Operating System

Darwin

Versions of Apache Airflow Providers

No response

Deployment

Virtualenv installation

Deployment details

Locally using latest code from main using Breeze

Anything else?

No response

Are you willing to submit PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Metadata

Metadata

Type

Fields

No fields configured for Bug.

Projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions