twwu 56bf6e42cb fix(workflow): preserve shared draft queues and Redis Cluster support ...

Route coordination through workflow storage and scheduler workers. Keep
draft and lease keys in the same Redis Cluster slot for atomic updates.
Replace coordination test casts with explicit types and runtime checks.

2026-11-03 15:59:48 +08:00

..

annotation

refactor(api): isolate console annotation management (#43807)

2026-10-27 04:18:00 +00:00

app_generate

fix(workflow): preserve ordinary tool execution and credential bindings

2026-11-03 15:59:36 +08:00

rag_pipeline

Merge branch 'main' into feat/dify-builder

2026-10-26 17:50:58 +08:00

workflow_cfs_scheduler

refactor(api): consolidate deployment edition handling (#40142)

2026-08-11 07:39:01 +00:00

__init__.py

feat: mypy for all type check (#10921)

2024-12-24 18:38:51 +08:00

add_document_to_index_task.py

refactor(api): consolidate account modules and shared errors (#42570)

2026-09-30 07:26:44 +00:00

application_trace_task.py

refactor(tracing): one trace pipeline behind a minimal provider interface (#44673)

2026-11-02 12:16:49 +08:00

async_workflow_tasks.py

Merge main into feat/dify-builder

2026-11-03 13:33:30 +08:00

batch_clean_document_task.py

feat: KnowledgeFS and New Knowledge (#44165)

2026-10-23 03:34:59 +00:00

batch_create_segment_to_index_task.py

ci: enable Ruff B905 (#44094)

2026-10-15 01:01:21 +00:00

clean_dataset_task.py

feat: KnowledgeFS and New Knowledge (#44165)

2026-10-23 03:34:59 +00:00

clean_document_task.py

feat: KnowledgeFS and New Knowledge (#44165)

2026-10-23 03:34:59 +00:00

clean_notion_document_task.py

ci: enable Ruff UP032 (#44092)

2026-10-15 01:01:15 +00:00

collect_agent_resources_task.py

fix(agent): complete ownership-aware deletion lifecycle (#40888)

2026-08-20 07:48:02 +00:00

community_telemetry_task.py

feat: add CE telemetry report (#39452)

2026-07-27 02:04:28 +00:00

create_segment_to_index_task.py

refactor(api): consolidate account modules and shared errors (#42570)

2026-09-30 07:26:44 +00:00

deal_dataset_index_update_task.py

ci: enable Ruff E712 (#44114)

2026-10-15 07:37:57 +00:00

deal_dataset_vector_index_task.py

ci: enable Ruff E712 (#44114)

2026-10-15 07:37:57 +00:00

delete_account_task.py

refactor(api): consolidate deployment edition handling (#40142)

2026-08-11 07:39:01 +00:00

delete_conversation_task.py

ci: enable Ruff B904 (#44121)

2026-10-19 12:47:53 +00:00

delete_segment_from_index_task.py

refactor(api): consolidate account modules and shared errors (#42570)

2026-09-30 07:26:44 +00:00

dify_builder_advance_task.py

fix(builder): coordinate workflow sessions and resource planning

2026-10-30 07:26:12 -07:00

disable_segment_from_index_task.py

refactor(api): consolidate account modules and shared errors (#42570)

2026-09-30 07:26:44 +00:00

disable_segments_from_index_task.py

refactor(api): consolidate account modules and shared errors (#42570)

2026-09-30 07:26:44 +00:00

document_indexing_sync_task.py

refactor(api): consolidate account modules and shared errors (#42570)

2026-09-30 07:26:44 +00:00

document_indexing_task.py

refactor(api): establish dataset application boundaries (#41729)

2026-09-29 08:42:31 +00:00

document_indexing_update_task.py

ci: enable Ruff UP032 (#44092)

2026-10-15 01:01:15 +00:00

duplicate_document_indexing_task.py

refactor(api): consolidate account modules and shared errors (#42570)

2026-09-30 07:26:44 +00:00

enable_segment_to_index_task.py

refactor(api): consolidate account modules and shared errors (#42570)

2026-09-30 07:26:44 +00:00

enable_segments_to_index_task.py

fix(knowledge): only batch-enable segments whose indexing completed (#44017)

2026-10-15 05:34:50 +08:00

enterprise_telemetry_task.py

refactor(api): replace json.loads with Pydantic validation in repositories and tasks (#43704)

2026-10-09 16:39:48 +00:00

generate_summary_index_task.py

refactor(api): establish dataset application boundaries (#41729)

2026-09-29 08:42:31 +00:00

human_input_im_card_tasks.py

feat: HITL IM integration (#44864)

2026-10-30 02:43:31 +00:00

human_input_timeout_tasks.py

feat: HITL IM integration (#44864)

2026-10-30 02:43:31 +00:00

im_contact_sync_tasks.py

feat: HITL IM integration (#44864)

2026-10-30 02:43:31 +00:00

im_message_inbox_tasks.py

feat: HITL IM integration (#44864)

2026-10-30 02:43:31 +00:00

initialize_created_app_rbac_access_task.py

ci: enable Ruff B904 (#44121)

2026-10-19 12:47:53 +00:00

install_default_plugins_task.py

ci: enable Ruff B904 (#44121)

2026-10-19 12:47:53 +00:00

knowledge_fs_agent_investigation_tasks.py

feat: KnowledgeFS and New Knowledge (#44165)

2026-10-23 03:34:59 +00:00

knowledge_fs_background_tasks.py

feat: KnowledgeFS and New Knowledge (#44165)

2026-10-23 03:34:59 +00:00

knowledge_fs_failed_retrieval_tasks.py

feat: KnowledgeFS and New Knowledge (#44165)

2026-10-23 03:34:59 +00:00

knowledge_fs_initial_source_preview_tasks.py

feat: KnowledgeFS and New Knowledge (#44165)

2026-10-23 03:34:59 +00:00

knowledge_fs_initial_source_tasks.py

feat: KnowledgeFS and New Knowledge (#44165)

2026-10-23 03:34:59 +00:00

knowledge_fs_lifecycle_tasks.py

feat: KnowledgeFS and New Knowledge (#44165)

2026-10-23 03:34:59 +00:00

knowledge_fs_source_import_tasks.py

feat: KnowledgeFS and New Knowledge (#44165)

2026-10-23 03:34:59 +00:00

knowledge_fs_upgrade_tasks.py

feat: KnowledgeFS and New Knowledge (#44165)

2026-10-23 03:34:59 +00:00

mail_account_deletion_task.py

ci: enable Ruff UP032 (#44092)

2026-10-15 01:01:15 +00:00

mail_change_mail_task.py

remove bare list, dict, Sequence, None, Any (#25058)

2025-09-06 03:32:23 +08:00

mail_email_code_login.py

remove bare list, dict, Sequence, None, Any (#25058)

2025-09-06 03:32:23 +08:00

mail_human_input_delivery_task.py

feat: HITL IM integration (#44864)

2026-10-30 02:43:31 +00:00

mail_inner_task.py

refactor(api): decouple system features and web adapters (#40772)

2026-09-01 11:50:52 +00:00

mail_invite_member_task.py

remove bare list, dict, Sequence, None, Any (#25058)

2025-09-06 03:32:23 +08:00

mail_owner_transfer_task.py

remove bare list, dict, Sequence, None, Any (#25058)

2025-09-06 03:32:23 +08:00

mail_register_task.py

Feat/email register refactor (#25369)

2025-09-12 10:24:54 +08:00

mail_reset_password_task.py

Feat/email register refactor (#25369)

2025-09-12 10:24:54 +08:00

mail_workflow_comment_task.py

feat: collaboration (#30781)

2026-04-16 02:21:04 +00:00

ops_trace_task.py

refactor(tracing): one trace pipeline behind a minimal provider interface (#44673)

2026-11-02 12:16:49 +08:00

process_tenant_plugin_autoupgrade_check_task.py

ci: enable Ruff UP007 (#44106)

2026-10-16 01:34:03 +00:00

recover_document_indexing_task.py

refactor(api): establish dataset application boundaries (#41729)

2026-09-29 08:42:31 +00:00

refresh_billing_vector_space_task.py

ci: enable Ruff B904 (#44121)

2026-10-19 12:47:53 +00:00

regenerate_summary_index_task.py

ci: enable Ruff E712 (#44114)

2026-10-15 07:37:57 +00:00

remove_app_and_related_data_task.py

Merge main into feat/dify-builder

2026-11-03 13:33:30 +08:00

remove_document_from_index_task.py

chore: port Document to TypeBase (#36084)

2026-10-23 02:56:00 +00:00

retry_document_indexing_task.py

Integrate validated Builder backend testing and CI repairs

2026-10-20 15:40:06 -07:00

sync_website_document_indexing_task.py

chore: port Document to TypeBase (#36084)

2026-10-23 02:56:00 +00:00

trace_delivery_task.py

refactor(tracing): one trace pipeline behind a minimal provider interface (#44673)

2026-11-02 12:16:49 +08:00

trigger_processing_tasks.py

refactor(models): migrate workflow models to TypeBase (#40815)

2026-10-26 15:53:48 +00:00

trigger_subscription_refresh_tasks.py

refactor: cleanup duplicate code (#36173)

2026-05-14 10:34:31 +00:00

workflow_draft_coordination_task.py

fix(workflow): preserve shared draft queues and Redis Cluster support

2026-11-03 15:59:48 +08:00

workflow_draft_var_tasks.py

refactor: partition Celery task sessions into smaller, discrete execu… (#32085)

2026-02-08 21:01:54 +08:00

workflow_execution_tasks.py

refactor(workflow): adopt Graphon 0.8 execution orchestration (#40277)

2026-10-19 13:03:56 +00:00

workflow_node_execution_tasks.py

feat(workflow): execute workflow tools as nested containers (#42820)

2026-10-21 02:11:18 +00:00

workflow_run_archive_deletion_tasks.py

fix(dify): retry failed archive deletion instead of reporting success (#44061)

2026-10-17 17:53:19 +00:00

workflow_run_archive_download_tasks.py

feat: support permanent deletion of monthly workflow archives (#44052)

2026-10-14 07:46:14 +00:00

workflow_schedule_tasks.py

refactor(api): consolidate deployment edition handling (#40142)

2026-08-11 07:39:01 +00:00