fix(task-sdk): add greenback fallback for Variable access in triggerer

[YoannAbriel]

ExecutionAPISecretsBackend.get_variable() is missing the RuntimeError + greenback fallback that get_connection() already has (added in #57154). When a deferrable operator's trigger calls Variable.get() inside the triggerer's async event loop, SUPERVISOR_COMMS.send() raises RuntimeError from async_to_sync. The bare except Exception swallows it and returns None, so every backend returns nothing and the variable is reported as not found.

Added the same greenback portal detection and aget_variable() fallback that get_connection() uses. Added a matching unit test.

Closes: #61676

---

Was generative AI tooling used to co-author this PR?

• Yes — Claude Code (Opus 4, claude-opus-4-6)

Generated-by: Claude Code (Opus 4, claude-opus-4-6) following the guidelines

---

• Read the Pull Request Guidelines for more information. Note: commit author/co-author name and email in commits become permanently public when merged.
• For fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
• When adding dependency, check compliance with the ASF 3rd Party License Policy.
• For significant user-facing changes create newsfragment: {pr_number}.significant.rst, in airflow-core/newsfragments. You can add this file in a follow-up commit after the PR is created so you know the PR number.

[Copilot]

Pull request overview

Note

Copilot was unable to run its full agentic suite in this review.

Adds the missing greenback fallback path to ExecutionAPISecretsBackend.get_variable() so triggerer usage of Variable.get() doesn’t incorrectly return None when SUPERVISOR_COMMS.send() hits the async_to_syncRuntimeError in an async event loop.

Changes:

• Add RuntimeError detection + greenback portal fallback to get_variable() (mirroring get_connection() behavior).
• Add a unit test covering the new fallback path for variable access.

Reviewed changes

Copilot reviewed 2 out of 2 changed files in this pull request and generated 4 comments.

File	Description
task-sdk/src/airflow/sdk/execution_time/secrets/execution_api.py	Adds greenback portal detection + async fallback for get_variable() when async_to_sync fails in triggerer contexts.
task-sdk/tests/task_sdk/execution_time/test_secrets.py	Adds a regression test ensuring get_variable() uses the greenback fallback when SUPERVISOR_COMMS.send() raises the known RuntimeError.

[github-actions]

Backport successfully created: v3-2-test

Note: As of Merging PRs targeted for Airflow 3.X
the committer who merges the PR is responsible for backporting the PRs that are bug fixes (generally speaking) to the maintenance branches.

In matter of doubt please ask in #release-management Slack channel.

Status	Branch	Result
✅	v3-2-test

[YoannAbriel]

ExecutionAPISecretsBackend.get_variable() is missing the RuntimeError + greenback fallback that get_connection() already has (added in #57154). When a deferrable operator's trigger calls Variable.get() inside the triggerer's async event loop, SUPERVISOR_COMMS.send() raises RuntimeError from async_to_sync. The bare except Exception swallows it and returns None, so every backend returns nothing and the variable is reported as not found.

Added the same greenback portal detection and aget_variable() fallback that get_connection() uses. Added a matching unit test.

Closes: #61676

---

Was generative AI tooling used to co-author this PR?

• Yes — Claude Code (Opus 4, claude-opus-4-6)

Generated-by: Claude Code (Opus 4, claude-opus-4-6) following the guidelines

---

• Read the Pull Request Guidelines for more information. Note: commit author/co-author name and email in commits become permanently public when merged.
• For fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
• When adding dependency, check compliance with the ASF 3rd Party License Policy.
• For significant user-facing changes create newsfragment: {pr_number}.significant.rst, in airflow-core/newsfragments. You can add this file in a follow-up commit after the PR is created so you know the PR number.

[Copilot]

Pull request overview

Note

Copilot was unable to run its full agentic suite in this review.

Adds the missing greenback fallback path to ExecutionAPISecretsBackend.get_variable() so triggerer usage of Variable.get() doesn’t incorrectly return None when SUPERVISOR_COMMS.send() hits the async_to_syncRuntimeError in an async event loop.

Changes:

• Add RuntimeError detection + greenback portal fallback to get_variable() (mirroring get_connection() behavior).
• Add a unit test covering the new fallback path for variable access.

Reviewed changes

Copilot reviewed 2 out of 2 changed files in this pull request and generated 4 comments.

File	Description
task-sdk/src/airflow/sdk/execution_time/secrets/execution_api.py	Adds greenback portal detection + async fallback for get_variable() when async_to_sync fails in triggerer contexts.
task-sdk/tests/task_sdk/execution_time/test_secrets.py	Adds a regression test ensuring get_variable() uses the greenback fallback when SUPERVISOR_COMMS.send() raises the known RuntimeError.

[github-actions]

Backport successfully created: v3-2-test

Note: As of Merging PRs targeted for Airflow 3.X
the committer who merges the PR is responsible for backporting the PRs that are bug fixes (generally speaking) to the maintenance branches.

In matter of doubt please ask in #release-management Slack channel.

Status	Branch	Result
✅	v3-2-test

[YoannAbriel]

ExecutionAPISecretsBackend.get_variable() is missing the RuntimeError + greenback fallback that get_connection() already has (added in #57154). When a deferrable operator's trigger calls Variable.get() inside the triggerer's async event loop, SUPERVISOR_COMMS.send() raises RuntimeError from async_to_sync. The bare except Exception swallows it and returns None, so every backend returns nothing and the variable is reported as not found.

Added the same greenback portal detection and aget_variable() fallback that get_connection() uses. Added a matching unit test.

Closes: #61676

---

Was generative AI tooling used to co-author this PR?

• Yes — Claude Code (Opus 4, claude-opus-4-6)

Generated-by: Claude Code (Opus 4, claude-opus-4-6) following the guidelines

---

• Read the Pull Request Guidelines for more information. Note: commit author/co-author name and email in commits become permanently public when merged.
• For fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
• When adding dependency, check compliance with the ASF 3rd Party License Policy.
• For significant user-facing changes create newsfragment: {pr_number}.significant.rst, in airflow-core/newsfragments. You can add this file in a follow-up commit after the PR is created so you know the PR number.

[Copilot]

Pull request overview

Note

Copilot was unable to run its full agentic suite in this review.

Adds the missing greenback fallback path to ExecutionAPISecretsBackend.get_variable() so triggerer usage of Variable.get() doesn’t incorrectly return None when SUPERVISOR_COMMS.send() hits the async_to_syncRuntimeError in an async event loop.

Changes:

• Add RuntimeError detection + greenback portal fallback to get_variable() (mirroring get_connection() behavior).
• Add a unit test covering the new fallback path for variable access.

Reviewed changes

Copilot reviewed 2 out of 2 changed files in this pull request and generated 4 comments.

File	Description
task-sdk/src/airflow/sdk/execution_time/secrets/execution_api.py	Adds greenback portal detection + async fallback for get_variable() when async_to_sync fails in triggerer contexts.
task-sdk/tests/task_sdk/execution_time/test_secrets.py	Adds a regression test ensuring get_variable() uses the greenback fallback when SUPERVISOR_COMMS.send() raises the known RuntimeError.

[github-actions]

Backport successfully created: v3-2-test

Note: As of Merging PRs targeted for Airflow 3.X
the committer who merges the PR is responsible for backporting the PRs that are bug fixes (generally speaking) to the maintenance branches.

In matter of doubt please ask in #release-management Slack channel.

Status	Branch	Result
✅	v3-2-test

[YoannAbriel]

ExecutionAPISecretsBackend.get_variable() is missing the RuntimeError + greenback fallback that get_connection() already has (added in #57154). When a deferrable operator's trigger calls Variable.get() inside the triggerer's async event loop, SUPERVISOR_COMMS.send() raises RuntimeError from async_to_sync. The bare except Exception swallows it and returns None, so every backend returns nothing and the variable is reported as not found.

Added the same greenback portal detection and aget_variable() fallback that get_connection() uses. Added a matching unit test.

Closes: #61676

---

Was generative AI tooling used to co-author this PR?

• Yes — Claude Code (Opus 4, claude-opus-4-6)

Generated-by: Claude Code (Opus 4, claude-opus-4-6) following the guidelines

---

• Read the Pull Request Guidelines for more information. Note: commit author/co-author name and email in commits become permanently public when merged.
• For fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
• When adding dependency, check compliance with the ASF 3rd Party License Policy.
• For significant user-facing changes create newsfragment: {pr_number}.significant.rst, in airflow-core/newsfragments. You can add this file in a follow-up commit after the PR is created so you know the PR number.

[Copilot]

Pull request overview

Note

Copilot was unable to run its full agentic suite in this review.

Adds the missing greenback fallback path to ExecutionAPISecretsBackend.get_variable() so triggerer usage of Variable.get() doesn’t incorrectly return None when SUPERVISOR_COMMS.send() hits the async_to_syncRuntimeError in an async event loop.

Changes:

• Add RuntimeError detection + greenback portal fallback to get_variable() (mirroring get_connection() behavior).
• Add a unit test covering the new fallback path for variable access.

Reviewed changes

Copilot reviewed 2 out of 2 changed files in this pull request and generated 4 comments.

File	Description
task-sdk/src/airflow/sdk/execution_time/secrets/execution_api.py	Adds greenback portal detection + async fallback for get_variable() when async_to_sync fails in triggerer contexts.
task-sdk/tests/task_sdk/execution_time/test_secrets.py	Adds a regression test ensuring get_variable() uses the greenback fallback when SUPERVISOR_COMMS.send() raises the known RuntimeError.

[github-actions]

Backport successfully created: v3-2-test

Note: As of Merging PRs targeted for Airflow 3.X
the committer who merges the PR is responsible for backporting the PRs that are bug fixes (generally speaking) to the maintenance branches.

In matter of doubt please ask in #release-management Slack channel.

Status	Branch	Result
✅	v3-2-test

[YoannAbriel]

ExecutionAPISecretsBackend.get_variable() is missing the RuntimeError + greenback fallback that get_connection() already has (added in #57154). When a deferrable operator's trigger calls Variable.get() inside the triggerer's async event loop, SUPERVISOR_COMMS.send() raises RuntimeError from async_to_sync. The bare except Exception swallows it and returns None, so every backend returns nothing and the variable is reported as not found.

Added the same greenback portal detection and aget_variable() fallback that get_connection() uses. Added a matching unit test.

Closes: #61676

---

Was generative AI tooling used to co-author this PR?

• Yes — Claude Code (Opus 4, claude-opus-4-6)

Generated-by: Claude Code (Opus 4, claude-opus-4-6) following the guidelines

---

• Read the Pull Request Guidelines for more information. Note: commit author/co-author name and email in commits become permanently public when merged.
• For fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
• When adding dependency, check compliance with the ASF 3rd Party License Policy.
• For significant user-facing changes create newsfragment: {pr_number}.significant.rst, in airflow-core/newsfragments. You can add this file in a follow-up commit after the PR is created so you know the PR number.

[Copilot]

Pull request overview

Note

Copilot was unable to run its full agentic suite in this review.

Adds the missing greenback fallback path to ExecutionAPISecretsBackend.get_variable() so triggerer usage of Variable.get() doesn’t incorrectly return None when SUPERVISOR_COMMS.send() hits the async_to_syncRuntimeError in an async event loop.

Changes:

• Add RuntimeError detection + greenback portal fallback to get_variable() (mirroring get_connection() behavior).
• Add a unit test covering the new fallback path for variable access.

Reviewed changes

Copilot reviewed 2 out of 2 changed files in this pull request and generated 4 comments.

File	Description
task-sdk/src/airflow/sdk/execution_time/secrets/execution_api.py	Adds greenback portal detection + async fallback for get_variable() when async_to_sync fails in triggerer contexts.
task-sdk/tests/task_sdk/execution_time/test_secrets.py	Adds a regression test ensuring get_variable() uses the greenback fallback when SUPERVISOR_COMMS.send() raises the known RuntimeError.

[github-actions]

Backport successfully created: v3-2-test

Note: As of Merging PRs targeted for Airflow 3.X
the committer who merges the PR is responsible for backporting the PRs that are bug fixes (generally speaking) to the maintenance branches.

In matter of doubt please ask in #release-management Slack channel.

Status	Branch	Result
✅	v3-2-test

[YoannAbriel]

ExecutionAPISecretsBackend.get_variable() is missing the RuntimeError + greenback fallback that get_connection() already has (added in #57154). When a deferrable operator's trigger calls Variable.get() inside the triggerer's async event loop, SUPERVISOR_COMMS.send() raises RuntimeError from async_to_sync. The bare except Exception swallows it and returns None, so every backend returns nothing and the variable is reported as not found.

Added the same greenback portal detection and aget_variable() fallback that get_connection() uses. Added a matching unit test.

Closes: #61676

---

Was generative AI tooling used to co-author this PR?

• Yes — Claude Code (Opus 4, claude-opus-4-6)

Generated-by: Claude Code (Opus 4, claude-opus-4-6) following the guidelines

---

• Read the Pull Request Guidelines for more information. Note: commit author/co-author name and email in commits become permanently public when merged.
• For fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
• When adding dependency, check compliance with the ASF 3rd Party License Policy.
• For significant user-facing changes create newsfragment: {pr_number}.significant.rst, in airflow-core/newsfragments. You can add this file in a follow-up commit after the PR is created so you know the PR number.

[Copilot]

Pull request overview

Note

Copilot was unable to run its full agentic suite in this review.

Adds the missing greenback fallback path to ExecutionAPISecretsBackend.get_variable() so triggerer usage of Variable.get() doesn’t incorrectly return None when SUPERVISOR_COMMS.send() hits the async_to_syncRuntimeError in an async event loop.

Changes:

• Add RuntimeError detection + greenback portal fallback to get_variable() (mirroring get_connection() behavior).
• Add a unit test covering the new fallback path for variable access.

Reviewed changes

Copilot reviewed 2 out of 2 changed files in this pull request and generated 4 comments.

File	Description
task-sdk/src/airflow/sdk/execution_time/secrets/execution_api.py	Adds greenback portal detection + async fallback for get_variable() when async_to_sync fails in triggerer contexts.
task-sdk/tests/task_sdk/execution_time/test_secrets.py	Adds a regression test ensuring get_variable() uses the greenback fallback when SUPERVISOR_COMMS.send() raises the known RuntimeError.

[github-actions]

Backport successfully created: v3-2-test

Note: As of Merging PRs targeted for Airflow 3.X
the committer who merges the PR is responsible for backporting the PRs that are bug fixes (generally speaking) to the maintenance branches.

In matter of doubt please ask in #release-management Slack channel.

Status	Branch	Result
✅	v3-2-test

[YoannAbriel]

ExecutionAPISecretsBackend.get_variable() is missing the RuntimeError + greenback fallback that get_connection() already has (added in #57154). When a deferrable operator's trigger calls Variable.get() inside the triggerer's async event loop, SUPERVISOR_COMMS.send() raises RuntimeError from async_to_sync. The bare except Exception swallows it and returns None, so every backend returns nothing and the variable is reported as not found.

Added the same greenback portal detection and aget_variable() fallback that get_connection() uses. Added a matching unit test.

Closes: #61676

---

Was generative AI tooling used to co-author this PR?

• Yes — Claude Code (Opus 4, claude-opus-4-6)

Generated-by: Claude Code (Opus 4, claude-opus-4-6) following the guidelines

---

• Read the Pull Request Guidelines for more information. Note: commit author/co-author name and email in commits become permanently public when merged.
• For fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
• When adding dependency, check compliance with the ASF 3rd Party License Policy.
• For significant user-facing changes create newsfragment: {pr_number}.significant.rst, in airflow-core/newsfragments. You can add this file in a follow-up commit after the PR is created so you know the PR number.

[Copilot]

Pull request overview

Note

Copilot was unable to run its full agentic suite in this review.

Adds the missing greenback fallback path to ExecutionAPISecretsBackend.get_variable() so triggerer usage of Variable.get() doesn’t incorrectly return None when SUPERVISOR_COMMS.send() hits the async_to_syncRuntimeError in an async event loop.

Changes:

• Add RuntimeError detection + greenback portal fallback to get_variable() (mirroring get_connection() behavior).
• Add a unit test covering the new fallback path for variable access.

Reviewed changes

Copilot reviewed 2 out of 2 changed files in this pull request and generated 4 comments.

File	Description
task-sdk/src/airflow/sdk/execution_time/secrets/execution_api.py	Adds greenback portal detection + async fallback for get_variable() when async_to_sync fails in triggerer contexts.
task-sdk/tests/task_sdk/execution_time/test_secrets.py	Adds a regression test ensuring get_variable() uses the greenback fallback when SUPERVISOR_COMMS.send() raises the known RuntimeError.

[github-actions]

Backport successfully created: v3-2-test

Note: As of Merging PRs targeted for Airflow 3.X
the committer who merges the PR is responsible for backporting the PRs that are bug fixes (generally speaking) to the maintenance branches.

In matter of doubt please ask in #release-management Slack channel.

Status	Branch	Result
✅	v3-2-test

[YoannAbriel]

ExecutionAPISecretsBackend.get_variable() is missing the RuntimeError + greenback fallback that get_connection() already has (added in #57154). When a deferrable operator's trigger calls Variable.get() inside the triggerer's async event loop, SUPERVISOR_COMMS.send() raises RuntimeError from async_to_sync. The bare except Exception swallows it and returns None, so every backend returns nothing and the variable is reported as not found.

Added the same greenback portal detection and aget_variable() fallback that get_connection() uses. Added a matching unit test.

Closes: #61676

---

Was generative AI tooling used to co-author this PR?

• Yes — Claude Code (Opus 4, claude-opus-4-6)

Generated-by: Claude Code (Opus 4, claude-opus-4-6) following the guidelines

---

• Read the Pull Request Guidelines for more information. Note: commit author/co-author name and email in commits become permanently public when merged.
• For fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
• When adding dependency, check compliance with the ASF 3rd Party License Policy.
• For significant user-facing changes create newsfragment: {pr_number}.significant.rst, in airflow-core/newsfragments. You can add this file in a follow-up commit after the PR is created so you know the PR number.

[Copilot]

Pull request overview

Note

Copilot was unable to run its full agentic suite in this review.

Adds the missing greenback fallback path to ExecutionAPISecretsBackend.get_variable() so triggerer usage of Variable.get() doesn’t incorrectly return None when SUPERVISOR_COMMS.send() hits the async_to_syncRuntimeError in an async event loop.

Changes:

• Add RuntimeError detection + greenback portal fallback to get_variable() (mirroring get_connection() behavior).
• Add a unit test covering the new fallback path for variable access.

Reviewed changes

Copilot reviewed 2 out of 2 changed files in this pull request and generated 4 comments.

File	Description
task-sdk/src/airflow/sdk/execution_time/secrets/execution_api.py	Adds greenback portal detection + async fallback for get_variable() when async_to_sync fails in triggerer contexts.
task-sdk/tests/task_sdk/execution_time/test_secrets.py	Adds a regression test ensuring get_variable() uses the greenback fallback when SUPERVISOR_COMMS.send() raises the known RuntimeError.

[github-actions]

Backport successfully created: v3-2-test

Note: As of Merging PRs targeted for Airflow 3.X
the committer who merges the PR is responsible for backporting the PRs that are bug fixes (generally speaking) to the maintenance branches.

In matter of doubt please ask in #release-management Slack channel.

Status	Branch	Result
✅	v3-2-test