Dify工作流执行1200秒后被用户手动停止的事件

工作流超时问题分析结论

坦白说，这个现象值得深入探讨。当我们运行一个Dify工作流（workflow），执行时间达到1200秒后，系统强制终止了进程。界面上显示的消息是“Stopped by user”——初看之下，很容易认为是某位用户手动点击了停止。但经过仔细排查，真正的原因很可能是应用级别的超时机制自动终止了工作流执行，只是系统提示信息的文案存在误导性。

根本原因：APP_MAX_EXECUTION_TIME 默认 1200 秒超时

问题的根源，位于 init.py 文件的第83至86行。该处定义了一个关键参数 APP_MAX_EXECUTION_TIME，其默认值恰好为1200秒。

核心执行逻辑位于 base_app_queue_manager.py 文件的第55至84行，集中在名为 listen() 的方法中。关键代码逻辑如下所示：

def listen(self):
    listen_timeout = dify_config.APP_MAX_EXECUTION_TIME  # 默认 1200s
    start_time = time.time()
    while True:
        ...
        finally:
            elapsed_time = time.time() - start_time
            if elapsed_time >= listen_timeout or self._is_stopped():
                # ⚠️ 发布 QueueStopEvent，但 stopped_by 硬编码为 USER_MANUAL
                self.publish(QueueStopEvent(stopped_by=QueueStopEvent.StopBy.USER_MANUAL), PublishFrom.TASK_PIPELINE)

请注意，此处无论是因超时触发，还是用户手动停止，最终都进入了同一个处理分支。发布的 QueueStopEvent 事件中，stopped_by 字段被硬编码为 USER_MANUAL。这就导致后续所有相关消息，都统一显示为“Stopped by user.”。

常见陷阱：超时终止被误标记为 "Stopped by user"

因此，整个逻辑链条梳理如下：

• 你的工作流（workflow）持续执行了整整1200秒。
• APP_MAX_EXECUTION_TIME 参数的默认值，恰好也是1200秒。
• 时间阈值达到后，超时自动终止机制被触发。
• 然而代码设计上，将超时终止与手动终止混为一谈，统一标记为“用户手动停止”。

结果就是，明明是系统程序自动中断的，你却看到一条“用户手动停止”的提示信息。这确实是一个代码命名上的疏忽。

另一个独立超时机制：WORKFLOW_MAX_EXECUTION_TIME

这里还有一层设计细节。在 init.py 文件的第784至787行，还定义了一个 WORKFLOW_MAX_EXECUTION_TIME 参数，其默认值同样为1200秒。

该配置作用于 workflow_entry.py 第228-229行中 GraphEngine 的 ExecutionLimitsLayer。如果该超时被触发，会走一条完全不同的失败路径（GraphRunAbortedEvent → QueueWorkflowFailedEvent），此时显示的不是“Stopped by user”，而是其他明确的错误信息。

因此，你看到的“Stopped by user”提示，几乎可以确定是由 APP_MAX_EXECUTION_TIME 这个队列监听器的超时机制导致的。

总结

解决方案

如果你的工作流（workflow）确实需要执行超过1200秒，解决方案也很直接——在环境变量中增大超时时间配置即可。

# 在 .env 中设置
APP_MAX_EXECUTION_TIME=3600
# 队列监听器超时，改为 1 小时
WORKFLOW_MAX_EXECUTION_TIME=3600
# GraphEngine 执行限制，也改为 1 小时

总结起来就几点：你的工作流执行了1200秒，正好触发了 APP_MAX_EXECUTION_TIME 的默认超时阈值，系统代码自动终止了工作流运行。但消息却显示为“Stopped by user”——归根结底，这是代码中一个命名上的小缺陷，将超时终止与手动停止混为一谈。