Skip to content

Conversation

@kaxil
Copy link
Member

@kaxil kaxil commented Oct 24, 2025

…7154)

When deferrable operators run in the triggerer's async event loop and
synchronously access connections (e.g., via @cached_property), the
`ExecutionAPISecretsBackend` failed silently. This occurred because
`SUPERVISOR_COMMS.send()` uses `async_to_sync`, which raises `RuntimeError`
when called within an existing event loop in a greenback portal context.

Add specific RuntimeError handling in `ExecutionAPISecretsBackend` that
detects this scenario and uses `greenback.await_()` to call the async
versions (aget_connection/aget_variable) as a fallback.

It was originally fixed in apache#55799 for 3.1.0
but apache#56602 introduced a bug.

Ideally all providers handle this better and have better written Triggers. Example
PR for Databricks: apache#55568

Fixes apache#57145

(cherry picked from commit da32b68)
@kaxil kaxil marked this pull request as ready for review October 24, 2025 09:44
@kaxil kaxil merged commit f969e63 into apache:v3-1-stable Oct 24, 2025
46 of 49 checks passed
@kaxil kaxil deleted the changes-3.1.1rc2- branch October 24, 2025 09:45
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants