abhijeets25012-tech opened a new pull request, #64238:
URL: https://github.com/apache/airflow/pull/64238

   ### What happened
   
   In triggerer context, `ExecutionAPISecretsBackend.get_connection()` may fail 
when
   `TriggerCommsDecoder.send()` raises a RuntimeError with message:
   
   "Future attached to a different loop"
   
   Currently, only the AsyncToSync RuntimeError is handled. Other RuntimeError 
variants
   fall through and return None, causing the connection lookup to silently fail.
   
   This leads to incorrect behavior in deferrable operators (e.g. AWS hooks),
   where the connection appears missing and falls back to default credentials.
   
   ### What is fixed
   
   Extended RuntimeError handling to also cover the "attached to a different 
loop"
   case and fallback to async connection retrieval using `greenback.await_`.
   
   ### Why this is safe
   
   - Maintains existing fallback behavior (`return None`)
   - Only extends handling for an additional RuntimeError variant
   - No change to behavior outside this edge case
   
   ### Reproduction
   
   Deferrable AWS hooks (e.g. S3KeySensor) in triggerer context fail to resolve
   connections and log "Unable to find AWS Connection ID" due to this issue.
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to