liuzeming

这样重复插入，需要消费者去重吧！大佬 能够给一个联系方式吗，邮件沟通不是很方便。 ------------------ 原始邮件 ------------------ 发件人: "qiang.ou"; 发送时间: 2019年5月14日(星期二) 下午5:24 收件人: "ouqiang/delay-queue"; 抄送: "平凡亦是收获";"Author"; 主题: Re: [ouqiang/delay-queue] 请问一下这里为什么还要执行pushToBucket 扔回zset呢，不是已经在ready queue list准备执行了吗 (#16) 确保消息被成功消费了，如果消费者没有确认，会一直重试。 — You are receiving this because you...

> 确保消息被成功消费了，如果消费者没有确认，会一直重试。 这个方法是只是给http请求的客户端使用的吧 我看go这边消费没有使用！是类似于PHP这种拉取到期消息消费的吗？这个重复插入会导致客户端重复领取，需要客户端这边去重，删除job pool里面的job才不会重复拉取到这个job的吧

> Dify 0.8.3 版本中的 LLM 节点可能会由于以下几个原因长时间处于“正在运行”状态而不会终止： > > 1. **上下文获取**：该`_fetch_context`方法涉及一个产生`RunRetrieverResourceEvent`事件的生成器。如果上下文获取过程缓慢或上下文数据存在问题，则可能导致节点保持运行状态。 > 2. **模型调用**：该`_invoke_llm`方法涉及调用大型语言模型并通过生成器处理结果。如果模型调用需要很长时间或结果流式传输出现问题，则可能导致节点保持运行状态。 > 3. **事件处理**：该`_handle_invoke_result`方法处理模型调用的结果。如果在处理流式块或最终结果时出现延迟或问题，则可能导致节点保持运行状态。 > > 以下是显示这些过程的相关代码： > > ```python > def _fetch_context(self, node_data: LLMNodeData, variable_pool: VariablePool) ->...

@antipopp Hello, I'd like to ask if this feature is currently under active development? We're encountering the same issue while customizing AGNO OS and would like to discuss it further....