Skip to content

[pull] develop from baserow:develop#192

Merged
pull[bot] merged 2 commits intocode:developfrom
baserow:develop
Mar 5, 2026
Merged

[pull] develop from baserow:develop#192
pull[bot] merged 2 commits intocode:developfrom
baserow:develop

Conversation

@pull
Copy link

@pull pull bot commented Mar 5, 2026

See Commits and Changes for more details.


Created by pull[bot] (v2.0.0-alpha.4)

Can you help keep this open source service alive? 💖 Please sponsor : )

jrmi and others added 2 commits March 5, 2026 09:54
* Refactor to support async node dispatch

* Store history_id and current_iterations in dispatch context

* Add simulate_until_node to AutomationWorkflowHistory

* Simplify dispatch: history is always created

* CorePeriodicServiceType should do a truthy check, since event_payload is loaded from the DB and can be {}

* Make sure current_iterations is considered for next iteration nodes.

* Initial async dispatch tests

* Simplify test

* Add trigger simulation test

* Add test for action node simulation

* Add remaining async node dispatch tests

* Add tests for dispatching async router, update, and delete nodes

* Add test for dispatch async with advanced formulas

* Remove old test_node_dispatch.py , which is replaced by the async version test_node_dispatch_async.py

* Add test for simulating complex router node

* Remove unused tests, port complex router simulation test to async module

* Fix existing tests since after_dispatch() was removed.

* Remove old workflow error history tests, they're covered in test_node_dispatch_async.py

* Refactor 'too many errors' handling.

* Refactor test; replace after_dispatch() with previous_nodes_results

* Add tests for history clean-up

* Regenerate migrations

* Ensure simulation history is excluded from get_workflow_history()

* Add test for before_run() error handling

* Add missing bool returns

* Add comment

* Add changelog

* Fix test

* Simplify allowed nodes

* Add docstring

* Make dry

* Fix error condition

* Improve comment

* Add tests for start_workflow()

* Remove unnecessary tests

* Lint fix

* Add specific iterator child dispatch test

* Optimize fetching simulate_until_node

* Use parent node to find current iteration

* Rename dispatch_node_async() to dispatch_node()

* Rename _update_previous_results to _load_previous_results

* Use Celery Canvas to dispatch nodes with support for parallel branch execution.

* WIP - fix tests

* Simplify node_dispatch() by always returning a signature.

* Refactor tests to account for Celery canvas: test_node_dispatch_async.py

* Return self.replace()

* Ensure chord callback doesn't overwrite any errors.

* Ensure an empty chain is not scheduled.

* Ensure start_workflow() uses same pattern as node dispatch task

* Fix test

* Event payload can be None

* Re-add is_test_run for ZDM

* Add db_default to new fields

* Rename get_workflow_history -> get_workflow_histories(). Refactor get_workflow_history() to return by ID.

* Clean up condition

* Add explicit else clause with comment

* use local_cache to get previous nodes results.

* Regenerate migrations

* Invalidate the cache after the dispatch() and node results are saved.

* Fix tests

* Fix test

* Make history_id mandatory

* Use cached workflow to fetch node

* Clear the cache manually in tests

* Pass in fake history_id to dispatch context
@pull pull bot locked and limited conversation to collaborators Mar 5, 2026
@pull pull bot added the ⤵️ pull label Mar 5, 2026
@pull pull bot merged commit d48df9e into code:develop Mar 5, 2026
2 of 5 checks passed
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants