summaryrefslogtreecommitdiff
path: root/benchmarks/cluster_async_pipeline.py
Commit message (Collapse)AuthorAgeFilesLines
* async_cluster: optimisations (#2205)Utkarsh Gupta2022-06-011-0/+107
- return true from execute_pipeline if there are any errors - use todo list to speedup retries - store initialisation node in CommandsParser object - add sync context manager for pipeline - use if/else instead of try/except - make command a function argument in _determine_nodes & _determine_slot - add async cluster pipeline benchmark script