Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
D
dify
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
ai-tech
dify
Commits
6e02e82f
Commit
6e02e82f
authored
Mar 04, 2024
by
takatost
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
lint fix
parent
afd65c2f
Changes
5
Hide whitespace changes
Inline
Side-by-side
Showing
5 changed files
with
12 additions
and
11 deletions
+12
-11
workflow.py
api/controllers/console/app/workflow.py
+3
-4
app_generator.py
api/core/app/apps/advanced_chat/app_generator.py
+1
-1
app_runner.py
api/core/app/apps/advanced_chat/app_runner.py
+3
-2
workflow_engine_manager.py
api/core/workflow/workflow_engine_manager.py
+3
-3
workflow_service.py
api/services/workflow_service.py
+2
-1
No files found.
api/controllers/console/app/workflow.py
View file @
6e02e82f
import
json
import
json
import
logging
import
logging
from
typing
import
Generator
from
collections.abc
import
Generator
from
flask
import
Response
,
stream_with_context
from
flask
import
Response
,
stream_with_context
from
flask_restful
import
Resource
,
marshal_with
,
reqparse
from
flask_restful
import
Resource
,
marshal_with
,
reqparse
from
werkzeug.exceptions
import
NotFound
,
InternalServerError
from
werkzeug.exceptions
import
InternalServerError
,
NotFound
import
services
import
services
from
controllers.console
import
api
from
controllers.console
import
api
from
controllers.console.app.error
import
DraftWorkflowNotExist
,
ConversationCompletedError
from
controllers.console.app.error
import
ConversationCompletedError
,
DraftWorkflowNotExist
from
controllers.console.app.wraps
import
get_app_model
from
controllers.console.app.wraps
import
get_app_model
from
controllers.console.setup
import
setup_required
from
controllers.console.setup
import
setup_required
from
controllers.console.wraps
import
account_initialization_required
from
controllers.console.wraps
import
account_initialization_required
...
@@ -19,7 +19,6 @@ from libs.login import current_user, login_required
...
@@ -19,7 +19,6 @@ from libs.login import current_user, login_required
from
models.model
import
App
,
AppMode
from
models.model
import
App
,
AppMode
from
services.workflow_service
import
WorkflowService
from
services.workflow_service
import
WorkflowService
logger
=
logging
.
getLogger
(
__name__
)
logger
=
logging
.
getLogger
(
__name__
)
...
...
api/core/app/apps/advanced_chat/app_generator.py
View file @
6e02e82f
...
@@ -2,7 +2,7 @@ import logging
...
@@ -2,7 +2,7 @@ import logging
import
threading
import
threading
import
uuid
import
uuid
from
collections.abc
import
Generator
from
collections.abc
import
Generator
from
typing
import
Any
,
Union
from
typing
import
Union
from
flask
import
Flask
,
current_app
from
flask
import
Flask
,
current_app
from
pydantic
import
ValidationError
from
pydantic
import
ValidationError
...
...
api/core/app/apps/advanced_chat/app_runner.py
View file @
6e02e82f
...
@@ -6,7 +6,8 @@ from core.app.app_queue_manager import AppQueueManager, PublishFrom
...
@@ -6,7 +6,8 @@ from core.app.app_queue_manager import AppQueueManager, PublishFrom
from
core.app.apps.advanced_chat.app_config_manager
import
AdvancedChatAppConfig
from
core.app.apps.advanced_chat.app_config_manager
import
AdvancedChatAppConfig
from
core.app.apps.base_app_runner
import
AppRunner
from
core.app.apps.base_app_runner
import
AppRunner
from
core.app.entities.app_invoke_entities
import
(
from
core.app.entities.app_invoke_entities
import
(
AdvancedChatAppGenerateEntity
,
InvokeFrom
,
AdvancedChatAppGenerateEntity
,
InvokeFrom
,
)
)
from
core.app.entities.queue_entities
import
QueueStopEvent
from
core.app.entities.queue_entities
import
QueueStopEvent
from
core.moderation.base
import
ModerationException
from
core.moderation.base
import
ModerationException
...
@@ -14,7 +15,7 @@ from core.workflow.entities.node_entities import SystemVariable
...
@@ -14,7 +15,7 @@ from core.workflow.entities.node_entities import SystemVariable
from
core.workflow.workflow_engine_manager
import
WorkflowEngineManager
from
core.workflow.workflow_engine_manager
import
WorkflowEngineManager
from
extensions.ext_database
import
db
from
extensions.ext_database
import
db
from
models.account
import
Account
from
models.account
import
Account
from
models.model
import
App
,
Conversation
,
Message
,
EndUser
from
models.model
import
App
,
Conversation
,
EndUser
,
Message
logger
=
logging
.
getLogger
(
__name__
)
logger
=
logging
.
getLogger
(
__name__
)
...
...
api/core/workflow/workflow_engine_manager.py
View file @
6e02e82f
from
typing
import
Optional
,
Union
,
Generator
from
collections.abc
import
Generator
from
typing
import
Optional
,
Union
from
core.memory.token_buffer_memory
import
TokenBufferMemory
from
core.workflow.entities.node_entities
import
NodeType
from
core.workflow.entities.node_entities
import
NodeType
from
core.workflow.nodes.code.code_node
import
CodeNode
from
core.workflow.nodes.code.code_node
import
CodeNode
from
core.workflow.nodes.direct_answer.direct_answer_node
import
DirectAnswerNode
from
core.workflow.nodes.direct_answer.direct_answer_node
import
DirectAnswerNode
...
@@ -16,7 +16,7 @@ from core.workflow.nodes.tool.tool_node import ToolNode
...
@@ -16,7 +16,7 @@ from core.workflow.nodes.tool.tool_node import ToolNode
from
core.workflow.nodes.variable_assigner.variable_assigner_node
import
VariableAssignerNode
from
core.workflow.nodes.variable_assigner.variable_assigner_node
import
VariableAssignerNode
from
extensions.ext_database
import
db
from
extensions.ext_database
import
db
from
models.account
import
Account
from
models.account
import
Account
from
models.model
import
App
,
EndUser
,
Conversation
from
models.model
import
App
,
EndUser
from
models.workflow
import
Workflow
from
models.workflow
import
Workflow
node_classes
=
{
node_classes
=
{
...
...
api/services/workflow_service.py
View file @
6e02e82f
import
json
import
json
from
collections.abc
import
Generator
from
datetime
import
datetime
from
datetime
import
datetime
from
typing
import
Optional
,
Union
,
Any
,
Generator
from
typing
import
Optional
,
Union
from
core.app.apps.advanced_chat.app_config_manager
import
AdvancedChatAppConfigManager
from
core.app.apps.advanced_chat.app_config_manager
import
AdvancedChatAppConfigManager
from
core.app.apps.advanced_chat.app_generator
import
AdvancedChatAppGenerator
from
core.app.apps.advanced_chat.app_generator
import
AdvancedChatAppGenerator
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment