bamboo-engine icon indicating copy to clipboard operation
bamboo-engine copied to clipboard

A event-driven workflow engine for Python

Results 33 bamboo-engine issues
Sort by recently updated
recently updated
newest added

BambooDjangoRuntime的集合多个mixin 正常来说, 如果我想更改其中某一个功能, 例如Process的某些行为, 例如die 的方法, 我可以 ```python class BambooDjangoRuntime( CustomProcessMixin, ) ``` 或者 ```python class CustomeRuntime(BambooDjangoRuntime): def die(self, process_id: int): do something() ``` 但是经过测试这不符合预期。 因为我发现在`pipeline/eri/celery/tasks.py` 里面`execute` 和 `schedule` 的方法里面:`runtime...

要预约暂停必先要在run_pipeline 保存数据库后才能调用,即流程运行后才能预约, 这样子节点跑的快的话可能还没预约已经结束。

https://github.com/TencentBlueKing/bamboo-engine/blob/fd3ab84d43e81f04473c29d31765221a7965be8a/runtime/bamboo-pipeline/pipeline/tests/test_apps.py#L45 一个小问题~

we need more feature in tree builder to help developer to address issue and debug 1. param type check 2. data validation

type/optimization

在代码中输出流程执行结果。 ``` result = api.get_pipeline_states(runtime=runtime, root_id=pipeline["id"]) ``` print(result.data) 在输出中缺失name条目,直接导致无法详细调试。 , 'ed8ca0822e6c3490192bee69c4f7c1e76': {'id': 'ed8ca0822e6c3490192bee69c4f7c1e76', 'state': 'FINISHED', 'root_id:': 'pe20b2e4e17674134924382e1985ba4f5', 'parent_id': 'pe20b2e4e17674134924382e1985ba4f5', 'version': 'vb8feada2bf0643e193bbd4d0dd5bb133', 'loop': 1, 'retry': 0, 'skip': False, 'error_ignorable': False, 'error_ignored':...

question

2022-03-22 17:03:48,144: ERROR/ForkPoolWorker-7] [p153b291216b64dbf93aab8d7bc79dfac]execute node(e9d1bf39b2ed347d6826feea3ae14aa55) prepare fail Traceback (most recent call last): File "/usr/local/lib/python3.6/site-packages/bamboo_engine/engine.py", line 566, in execute process_info = self.runtime.get_process_info(process_id) File "/usr/local/lib/python3.6/site-packages/bamboo_engine/metrics.py", line 81, in _wrapper return func(*args, **kwargs)...

help wanted

背景:在pipeline中有时会由于基础组件(如网络、DB、mq)或pipeline组件(如程序BUG)等原因导致pipeline异常,而为了避免打扰用户,期望有相应的运营工具可以辅助排查或自愈 期望: pipeline检测工具:可以对某一个pipeline实例进行检测,了解异常原因 pipeline修复工具:可以对异常pipeline异常辅助处理(如有影响需要有手动确认操作),将pipeline恢复到某一节点

type/feature

引擎中的mq 使用的是rabbitmq 是否可以替换成其他mq