Please note that I added two log lines in default_engine.py
In the _on_task_state_change method, before and after the line “cmds = wf_ctrl.continue_workflow()”
LOG.info("_on_task_state_change BEFORE NEXT TASK with task = %s", task_ex)
LOG.info("_on_task_state_change AFTER NEXT TASK with task = %s", task_ex)
In order to see which task called which.
Please note that I added two log lines in default_engine.py state_change method, before and after the line “cmds = wf_ctrl. continue_ workflow( )” "_on_task_ state_change BEFORE NEXT TASK with task = %s", task_ex) "_on_task_ state_change AFTER NEXT TASK with task = %s", task_ex)
In the _on_task_
LOG.info(
LOG.info(
In order to see which task called which.