You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I dont think the method execute_callbacks needs to be converted itself but rather the submethods _execute_task_callbacks and _execute_dag_callbacks. What do you think? The submethod manage_slas has already its own issue
Right, I should have been more descriptive:
The problem about this task is that executing the callback itself must be still done in the DagProcessor (not Internal API) component.
One the other hand all requests to DB must be done through Internal API. E.g. _execute_task_callbacks first read data from DB then call ti.handle_failure(which unfortunatelly also tasks session in the arguments and ameks some additional DB calls.).
This all must be untangled - even with refactoring of some methods/introducing new
Note that Callback execution must be still done in DagProcessor
The text was updated successfully, but these errors were encountered: