Skip to content

feat(api/repo): Allow to config repository implementation #21458

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
laipz8200 merged 19 commits into from
Jul 14, 2025
Merged

feat(api/repo): Allow to config repository implementation #21458

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
19 commits
Select commit Hold shift + click to select a range
733386b
feat(api/repo): Allow to config repository implementation
laipz8200 Jun 24, 2025
b2b4049
feat: Create a DifyAPIRepositoryFactory to handle workflow node execu…
laipz8200 Jun 27, 2025
b450acf
feat: Create a APIWorkflowRunRepository
laipz8200 Jun 27, 2025
6a11105
test(workflow_service): Fix test
laipz8200 Jun 27, 2025
641cabc
chore: add new configs to env example
laipz8200 Jun 27, 2025
8e71a9a
test(test_workflow_draft_variable_service): Fix tests
laipz8200 Jul 7, 2025
6076240
feat: Integrates execution repository inheritance
laipz8200 Jul 9, 2025
63bbcaf
refactor(token_buffer_memory): Convert ValueError to AssertionError
laipz8200 Jul 10, 2025
cf2b5c7
refactor(workflow_response_converter): Remove unused workflow_executi…
laipz8200 Jul 10, 2025
f585431
refactor(factory): Move import statement to the top
laipz8200 Jul 10, 2025
a0cfdb4
docs(api_workflow_node_execution_repository): Add notice about datat …
laipz8200 Jul 10, 2025
40a7089
refactor(api_workflow_node_execution_repository): Refactors workflow …
laipz8200 Jul 10, 2025
00462a0
refactor(api): Simplify the constructor for WorkflowDraftVariableService
QuantumGhost Jul 10, 2025
115c6e2
chore(api): improve type hints for `DifyCoreRepositoryFactory`
QuantumGhost Jul 10, 2025
00c50ed
test(api): fix tests broken by refactor
QuantumGhost Jul 10, 2025
7a47b86
refactor(remove_app_and_related_data_task): Remove 'expire_on_commit'…
laipz8200 Jul 14, 2025
42a195e
feat(api/repositories/sqlalchemy_api_workflow_run_repository.py): Imp…
laipz8200 Jul 14, 2025
0d1b27f
docs(api/repositories/api_workflow_node_execution_repository.py): Add…
laipz8200 Jul 14, 2025
7cabcea
docs(api/repositories/sqlalchemy_api_workflow_node_execution_reposito…
laipz8200 Jul 14, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
chore: add new configs to env example 
Signed-off-by: -LAN- <laipz8200@outlook.com>
  • Loading branch information
@laipz8200
laipz8200 committed Jul 14, 2025
commit 641cabcbeb64a366c9c91b68bfa988cc97e9cbb9
13 changes: 13 additions & 0 deletions api/.env.example
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -449,6 +449,19 @@ MAX_VARIABLE_SIZE=204800
# hybrid: Save new data to object storage, read from both object storage and RDBMS
WORKFLOW_NODE_EXECUTION_STORAGE=rdbms

# Repository configuration
# Core workflow execution repository implementation
CORE_WORKFLOW_EXECUTION_REPOSITORY=core.repositories.sqlalchemy_workflow_execution_repository.SQLAlchemyWorkflowExecutionRepository

# Core workflow node execution repository implementation
CORE_WORKFLOW_NODE_EXECUTION_REPOSITORY=core.repositories.sqlalchemy_workflow_node_execution_repository.SQLAlchemyWorkflowNodeExecutionRepository

# API workflow node execution repository implementation
API_WORKFLOW_NODE_EXECUTION_REPOSITORY=repositories.sqlalchemy_api_workflow_node_execution_repository.DifyAPISQLAlchemyWorkflowNodeExecutionRepository

# API workflow run repository implementation
API_WORKFLOW_RUN_REPOSITORY=repositories.sqlalchemy_api_workflow_run_repository.DifyAPISQLAlchemyWorkflowRunRepository

# App configuration
APP_MAX_EXECUTION_TIME=1200
APP_MAX_ACTIVE_REQUESTS=0
Expand Down
13 changes: 13 additions & 0 deletions docker/.env.example
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -799,6 +799,19 @@ WORKFLOW_FILE_UPLOAD_LIMIT=10
# hybrid: Save new data to object storage, read from both object storage and RDBMS
WORKFLOW_NODE_EXECUTION_STORAGE=rdbms

# Repository configuration
# Core workflow execution repository implementation
CORE_WORKFLOW_EXECUTION_REPOSITORY=core.repositories.sqlalchemy_workflow_execution_repository.SQLAlchemyWorkflowExecutionRepository

# Core workflow node execution repository implementation
CORE_WORKFLOW_NODE_EXECUTION_REPOSITORY=core.repositories.sqlalchemy_workflow_node_execution_repository.SQLAlchemyWorkflowNodeExecutionRepository

# API workflow node execution repository implementation
API_WORKFLOW_NODE_EXECUTION_REPOSITORY=repositories.sqlalchemy_api_workflow_node_execution_repository.DifyAPISQLAlchemyWorkflowNodeExecutionRepository

# API workflow run repository implementation
API_WORKFLOW_RUN_REPOSITORY=repositories.sqlalchemy_api_workflow_run_repository.DifyAPISQLAlchemyWorkflowRunRepository

# HTTP request node in workflow configuration
HTTP_REQUEST_NODE_MAX_BINARY_SIZE=10485760
HTTP_REQUEST_NODE_MAX_TEXT_SIZE=1048576
Expand Down
4 changes: 4 additions & 0 deletions docker/docker-compose.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -354,6 +354,10 @@ x-shared-env: &shared-api-worker-env
WORKFLOW_PARALLEL_DEPTH_LIMIT: ${WORKFLOW_PARALLEL_DEPTH_LIMIT:-3}
WORKFLOW_FILE_UPLOAD_LIMIT: ${WORKFLOW_FILE_UPLOAD_LIMIT:-10}
WORKFLOW_NODE_EXECUTION_STORAGE: ${WORKFLOW_NODE_EXECUTION_STORAGE:-rdbms}
CORE_WORKFLOW_EXECUTION_REPOSITORY: ${CORE_WORKFLOW_EXECUTION_REPOSITORY:-core.repositories.sqlalchemy_workflow_execution_repository.SQLAlchemyWorkflowExecutionRepository}
CORE_WORKFLOW_NODE_EXECUTION_REPOSITORY: ${CORE_WORKFLOW_NODE_EXECUTION_REPOSITORY:-core.repositories.sqlalchemy_workflow_node_execution_repository.SQLAlchemyWorkflowNodeExecutionRepository}
API_WORKFLOW_NODE_EXECUTION_REPOSITORY: ${API_WORKFLOW_NODE_EXECUTION_REPOSITORY:-repositories.sqlalchemy_api_workflow_node_execution_repository.DifyAPISQLAlchemyWorkflowNodeExecutionRepository}
API_WORKFLOW_RUN_REPOSITORY: ${API_WORKFLOW_RUN_REPOSITORY:-repositories.sqlalchemy_api_workflow_run_repository.DifyAPISQLAlchemyWorkflowRunRepository}
HTTP_REQUEST_NODE_MAX_BINARY_SIZE: ${HTTP_REQUEST_NODE_MAX_BINARY_SIZE:-10485760}
HTTP_REQUEST_NODE_MAX_TEXT_SIZE: ${HTTP_REQUEST_NODE_MAX_TEXT_SIZE:-1048576}
HTTP_REQUEST_NODE_SSL_VERIFY: ${HTTP_REQUEST_NODE_SSL_VERIFY:-True}
Expand Down