📦 langgenius / dify

Production-ready platform for agentic workflow development.

📂 main

📁 ..

📁 annotation

📁 rag_pipeline

📁 workflow_cfs_scheduler

📄 __init__.py

📄 add_document_to_index_task.py

📄 async_workflow_tasks.py

📄 batch_clean_document_task.py

📄 batch_create_segment_to_index_task.py

📄 clean_dataset_task.py

📄 clean_document_task.py

📄 clean_notion_document_task.py

📄 create_segment_to_index_task.py

📄 deal_dataset_index_update_task.py

📄 deal_dataset_vector_index_task.py

📄 delete_account_task.py

📄 delete_conversation_task.py

📄 delete_segment_from_index_task.py

📄 disable_segment_from_index_task.py

📄 disable_segments_from_index_task.py

📄 document_indexing_sync_task.py

📄 document_indexing_task.py

📄 document_indexing_update_task.py

📄 duplicate_document_indexing_task.py

📄 enable_segment_to_index_task.py

📄 enable_segments_to_index_task.py

📄 mail_account_deletion_task.py

📄 mail_change_mail_task.py

📄 mail_email_code_login.py

📄 mail_inner_task.py

📄 mail_invite_member_task.py

📄 mail_owner_transfer_task.py

📄 mail_register_task.py

📄 mail_reset_password_task.py

📄 ops_trace_task.py

📄 process_tenant_plugin_autoupgrade_check_task.py

📄 recover_document_indexing_task.py

📄 remove_app_and_related_data_task.py

📄 remove_document_from_index_task.py

📄 retry_document_indexing_task.py

📄 sync_website_document_indexing_task.py

📄 trigger_processing_tasks.py

📄 trigger_subscription_refresh_tasks.py

📄 workflow_draft_var_tasks.py

📄 workflow_execution_tasks.py

📄 workflow_node_execution_tasks.py

📄 workflow_schedule_tasks.py