yuseok89 commented on code in PR #71922:
URL: https://github.com/apache/airflow/pull/71922#discussion_r4010904210
##########
providers/http/src/airflow/providers/http/sensors/http.py:
##########
@@ -158,22 +165,48 @@ def poke(self, context: Context) -> bool |
PokeReturnValue:
return True
def execute(self, context: Context) -> Any:
- if not self.deferrable or self.response_check:
Review Comment:
As I understand it, this condition causes the behavior reported in #40209
because setting `response_check` forces the sensor onto the synchronous path.
The check itself is still evaluated by `self.poke(context)` before deferral and
by `execute_complete()` after the trigger returns a response. A false result
defers the task again.
--
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]
