houqp commented on a change in pull request #10917:
URL: https://github.com/apache/airflow/pull/10917#discussion_r534485274
##########
File path: airflow/executors/debug_executor.py
##########
@@ -76,10 +77,14 @@ def _run_task(self, ti: TaskInstance) -> bool:
try:
params = self.tasks_params.pop(ti.key, {})
ti._run_raw_task(job_id=ti.job_id, **params) # pylint:
disable=protected-access
+ ti.set_state(State.SUCCESS)
Review comment:
good catch, run_raw_task does update state to SUCCESS internally, it was
causing issues in previous implementation of the PR, but we have changed the
design a lot since then, so maybe it's not needed anymore. let me remove it and
rerun the tests to see if anything breaks.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
